discourse/app/jobs/scheduled/enqueue_digest_emails.rb

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

53 lines
1.9 KiB
Ruby
Raw Normal View History

# frozen_string_literal: true
2013-02-05 14:16:51 -05:00
module Jobs
class EnqueueDigestEmails < ::Jobs::Scheduled
every 30.minutes
2013-02-05 14:16:51 -05:00
def execute(args)
if SiteSetting.disable_digest_emails? || SiteSetting.private_email? ||
SiteSetting.disable_emails == "yes"
return
end
users = target_user_ids
users.each { |user_id| ::Jobs.enqueue(:user_email, type: "digest", user_id: user_id) }
2013-02-05 14:16:51 -05:00
end
def target_user_ids
# Users who want to receive digest email within their chosen digest email frequency
query =
User
.real
.activated
.not_suspended
.where(staged: false)
.joins(:user_option, :user_stat, :user_emails)
.where("user_options.email_digests")
.where("user_stats.bounce_score < ?", SiteSetting.bounce_score_threshold)
.where("user_emails.primary")
.where(
"COALESCE(last_emailed_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 MINUTE'::INTERVAL * user_options.digest_after_minutes)",
)
.where(
"COALESCE(user_stats.digest_attempted_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 MINUTE'::INTERVAL * user_options.digest_after_minutes)",
)
.where(
"COALESCE(last_seen_at, '2010-01-01') <= CURRENT_TIMESTAMP - ('1 MINUTE'::INTERVAL * user_options.digest_after_minutes)",
)
.where(
"COALESCE(last_seen_at, '2010-01-01') >= CURRENT_TIMESTAMP - ('1 DAY'::INTERVAL * ?)",
SiteSetting.suppress_digest_email_after_days,
)
.order("user_stats.digest_attempted_at ASC NULLS FIRST")
# If the site requires approval, make sure the user is approved
query = query.where("approved OR moderator OR admin") if SiteSetting.must_approve_users?
query = query.limit(GlobalSetting.max_digests_enqueued_per_30_mins_per_site)
query.pluck(:id)
2013-02-05 14:16:51 -05:00
end
end
2013-02-25 11:42:20 -05:00
end