dawarich/app/jobs/tracks/daily_generation_job.rb

# frozen_string_literal: true

# Daily Track Generation Job
#
# Automatically processes new location points for all active/trial users on a regular schedule.
# This job runs periodically (recommended: every 2-4 hours) to generate tracks from newly
# received location data.
#
# Process:
# 1. Iterates through all active or trial users
# 2. For each user, finds the timestamp of their last track's end_at
# 3. Checks if there are new points since that timestamp
# 4. If new points exist, triggers parallel track generation using the existing system
# 5. Uses the parallel generator with 'daily' mode for optimal performance
#
# The job leverages the existing parallel track generation infrastructure,
# ensuring consistency with bulk operations while providing automatic daily processing.

class Tracks::DailyGenerationJob < ApplicationJob
  queue_as :tracks

  def perform
    User.active_or_trial.find_each do |user|
      next if user.points_count&.zero?

      process_user_daily_tracks(user)
    rescue StandardError => e
      ExceptionReporter.call(e, "Failed to process daily tracks for user #{user.id}")
    end
  end

  private

  def process_user_daily_tracks(user)
    start_timestamp = start_timestamp(user)

    return unless user.points.where('timestamp >= ?', start_timestamp).exists?

    Tracks::ParallelGeneratorJob.perform_later(
      user.id,
      start_at: Time.zone.at(start_timestamp),
      end_at: Time.current,
      mode: 'daily'
    )
  end

  def start_timestamp(user)
    last_end = user.tracks.maximum(:end_at)&.to_i
    return last_end + 1 if last_end

    user.points.minimum(:timestamp) || 1.week.ago.to_i
  end
end