23 lines
702 B
Ruby
23 lines
702 B
Ruby
|
module Jobs
|
||
|
|
|
||
|
|
# A daily job that will enqueue digest emails to be sent to users
|
||
|
|
class EnqueueDigestEmails < Jobs::Base
|
||
|
|
|
||
|
|
def execute(args)
|
||
|
|
target_users.each do |u|
|
||
|
|
Jobs.enqueue(:user_email, type: :digest, user_id: u.id)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def target_users
|
||
|
|
# Users who want to receive emails and haven't been emailed int he last day
|
||
|
|
User
|
||
|
|
.select(:id)
|
||
|
|
.where(email_digests: 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)")
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|