discourse/lib/jobs/enqueue_digest_emails.rb

31 lines
993 B
Ruby
Raw Normal View History

2013-02-05 14:16:51 -05:00
module Jobs
# A daily job that will enqueue digest emails to be sent to users
2013-08-07 13:25:05 -04:00
class EnqueueDigestEmails < Jobs::Scheduled
recurrence { daily.hour_of_day(6) }
2013-02-05 14:16:51 -05:00
def execute(args)
target_user_ids.each do |user_id|
Jobs.enqueue(:user_email, type: :digest, user_id: user_id)
2013-02-25 11:42:20 -05:00
end
2013-02-05 14:16:51 -05:00
end
def target_user_ids
# Users who want to receive emails and haven't been emailed in the last day
query = User.real
.where(email_digests: true, active: true)
.where("COALESCE(last_emailed_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 DAY'::INTERVAL * digest_after_days)")
.where("COALESCE(last_seen_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 DAY'::INTERVAL * digest_after_days)")
# If the site requires approval, make sure the user is approved
if SiteSetting.must_approve_users?
query = query.where("approved OR moderator OR admin")
end
query.pluck(:id)
2013-02-05 14:16:51 -05:00
end
end
2013-02-25 11:42:20 -05:00
end