gitcoinco/code_fund_ads

class EnsureDailySummariesJob < ApplicationJob
  queue_as :ensure_daily_summaries

  def perform(start_date = nil, end_date = nil)
    start_date = Date.coerce(start_date || 7.days.ago.to_date)
    end_date = Date.coerce(end_date || 1.day.ago.to_date)
    ensure_daily_summaries_for_campaigns start_date, end_date
    ensure_daily_summaries_for_properties start_date, end_date
  end

  private

  def ensure_daily_summaries_for_campaigns(start_date, end_date)
    Campaign.available_on(start_date).or(Campaign.available_on(end_date)).in_batches.each do |campaigns|
      campaigns.each do |campaign|
        next unless campaign.impressions.between(start_date, end_date).exists?
        CreateDailySummariesJob.perform_later campaign, start_date.iso8601, end_date.iso8601, nil
      end
    end
  end

  def ensure_daily_summaries_for_properties(start_date, end_date)
    Property.active.in_batches.each do |properties|
      properties.each do |property|
        next unless property.impressions.between(start_date, end_date).exists?
        CreateDailySummariesJob.perform_later property, start_date.iso8601, end_date.iso8601, nil
      end
    end
  end
end