Background jobs

app/jobs/
  brands/           # Brand lifecycle automation
  campaigns/        # Campaign processing
  creators/         # Creator sync and automation
  metrics/          # Data sync and reporting
  notifications/    # Notification delivery
  integrations/     # External service sync
  leaderboards/     # Monthly leaderboard processing
  ...

class Metrics::SyncJob < ApplicationJob
  queue_as :default

  def perform
    CreatorSocial.syncable.find_each do |social|
      posts = scrape_posts(social)
      Metrics::Ingestor.new.ingest_for_social(social, posts)
    end
  end
end

class Brands::PipelineAutoAdvanceJob < ApplicationJob
  def perform
    # Active → Ending Soon (14 days before contract end)
    advance_to_ending_soon!
    
    # Contract complete → Up for Renewal
    advance_to_up_for_renewal!
    
    # First post → Active
    advance_to_active!
  end
end

class Creators::WelcomeDmBackstopJob < ApplicationJob
  def perform
    User.creator
        .where(onboarded_at: 15.minutes.ago..Time.current)
        .where(welcome_dm_sent: false)
        .find_each do |creator|
      Notifications::WelcomeDmSender.new(creator).perform!
    end
  end
end

production:
  metrics_sync:
    class: Metrics::SyncJob
    schedule: "0 22 * * *"  # 10pm ET daily
    
  tier_sync:
    class: Creators::TierSyncJob
    schedule: "0 11 * * *"  # 11am ET daily
    
  rollover_contracts:
    class: Campaigns::RolloverActiveContractsJob
    schedule: "*/15 * * * *"  # Every 15 minutes

class NotificationJob < ApplicationJob
  queue_as :critical
end

class ReportJob < ApplicationJob
  queue_as :low
end

class Metrics::SyncJob < ApplicationJob
  retry_on StandardError, wait: :polynomially_longer, attempts: 3
  discard_on ActiveRecord::RecordNotFound

  def perform(social_id:)
    social = CreatorSocial.find(social_id)
    # ...
  end
end

# Set environment variable to pause all syncs
SCRAPE_SYNC_PAUSED=1

# Run a specific job
bin/rails runner "Metrics::SyncJob.perform_now"

# Run SolidQueue worker
bin/rails solid_queue:work

class Brands::PipelineAutoAdvanceJobTest < ActiveSupport::TestCase
  test "advances brand to ending_soon 14 days before end" do
    brand = create_brand(
      pipeline_status: "active",
      contract_end: 14.days.from_now
    )
    
    Brands::PipelineAutoAdvanceJob.perform_now
    
    assert_equal "ending_soon", brand.reload.pipeline_status
  end
end