2014-02-06 19:06:35 -05:00
|
|
|
module Jobs
|
|
|
|
|
|
|
|
class NotifyMailingListSubscribers < Jobs::Base
|
|
|
|
|
2016-04-06 22:56:43 -04:00
|
|
|
sidekiq_options queue: 'low'
|
|
|
|
|
2014-02-06 19:06:35 -05:00
|
|
|
def execute(args)
|
2016-03-21 23:50:35 -04:00
|
|
|
return if SiteSetting.disable_mailing_list_mode
|
|
|
|
|
2014-02-06 19:06:35 -05:00
|
|
|
post_id = args[:post_id]
|
2014-11-24 11:40:21 -05:00
|
|
|
post = post_id ? Post.with_deleted.find_by(id: post_id) : nil
|
2014-02-06 19:06:35 -05:00
|
|
|
|
2017-05-08 15:08:29 -04:00
|
|
|
return if !post || post.trashed? || post.user_deleted? || !post.topic
|
2014-02-06 19:06:35 -05:00
|
|
|
|
2014-09-03 17:50:19 -04:00
|
|
|
users =
|
|
|
|
User.activated.not_blocked.not_suspended.real
|
2016-02-16 23:46:19 -05:00
|
|
|
.joins(:user_option)
|
2016-10-05 19:28:58 -04:00
|
|
|
.where('user_options.mailing_list_mode AND user_options.mailing_list_mode_frequency > 0')
|
2016-12-12 09:28:26 -05:00
|
|
|
.where('NOT EXISTS (
|
|
|
|
SELECT 1
|
|
|
|
FROM muted_users mu
|
|
|
|
WHERE mu.muted_user_id = ? AND mu.user_id = users.id
|
|
|
|
)', post.user_id)
|
|
|
|
.where('NOT EXISTS (
|
2014-02-06 19:06:35 -05:00
|
|
|
SELECT 1
|
|
|
|
FROM topic_users tu
|
2016-12-12 09:28:26 -05:00
|
|
|
WHERE tu.topic_id = ? AND tu.user_id = users.id AND tu.notification_level = ?
|
2014-02-06 19:06:35 -05:00
|
|
|
)', post.topic_id, TopicUser.notification_levels[:muted])
|
2016-12-12 09:28:26 -05:00
|
|
|
.where('NOT EXISTS (
|
2014-02-06 19:06:35 -05:00
|
|
|
SELECT 1
|
|
|
|
FROM category_users cu
|
2016-12-12 09:28:26 -05:00
|
|
|
WHERE cu.category_id = ? AND cu.user_id = users.id AND cu.notification_level = ?
|
2014-02-06 19:06:35 -05:00
|
|
|
)', post.topic.category_id, CategoryUser.notification_levels[:muted])
|
2014-09-03 17:50:19 -04:00
|
|
|
|
2017-07-19 16:51:32 -04:00
|
|
|
DiscourseEvent.trigger(:notify_mailing_list_subscribers, users, post)
|
2017-05-04 22:57:31 -04:00
|
|
|
users.find_each do |user|
|
2014-09-03 17:50:19 -04:00
|
|
|
if Guardian.new(user).can_see?(post)
|
2016-07-05 06:20:07 -04:00
|
|
|
if EmailLog.reached_max_emails?(user)
|
|
|
|
skip(user.email, user.id, post.id, I18n.t('email_log.exceeded_emails_limit'))
|
|
|
|
next
|
|
|
|
end
|
|
|
|
|
|
|
|
if user.user_stat.bounce_score >= SiteSetting.bounce_score_threshold
|
|
|
|
skip(user.email, user.id, post.id, I18n.t('email_log.exceeded_bounces_limit'))
|
|
|
|
next
|
|
|
|
end
|
|
|
|
|
2016-10-05 19:28:58 -04:00
|
|
|
if (user.id == post.user_id) && (user.user_option.mailing_list_mode_frequency == 2)
|
|
|
|
skip(user.email, user.id, post.id, I18n.t('email_log.no_echo_mailing_list_mode'))
|
|
|
|
next
|
|
|
|
end
|
|
|
|
|
2014-09-03 17:50:19 -04:00
|
|
|
begin
|
2016-07-05 06:20:07 -04:00
|
|
|
if message = UserNotifications.mailing_list_notify(user, post)
|
|
|
|
EmailLog.unique_email_per_post(post, user) do
|
|
|
|
Email::Sender.new(message, :mailing_list, user).send
|
2016-04-15 01:59:01 -04:00
|
|
|
end
|
2016-03-23 00:08:34 -04:00
|
|
|
end
|
2014-09-03 17:50:19 -04:00
|
|
|
rescue => e
|
2016-02-03 13:27:58 -05:00
|
|
|
Discourse.handle_job_exception(e, error_context(args, "Sending post to mailing list subscribers", { user_id: user.id, user_email: user.email }))
|
2014-09-03 17:50:19 -04:00
|
|
|
end
|
|
|
|
end
|
2014-02-06 19:06:35 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
end
|
2016-07-05 06:20:07 -04:00
|
|
|
|
|
|
|
def skip(to_address, user_id, post_id, reason)
|
|
|
|
EmailLog.create!(
|
|
|
|
email_type: 'mailing_list',
|
|
|
|
to_address: to_address,
|
|
|
|
user_id: user_id,
|
|
|
|
post_id: post_id,
|
|
|
|
skipped: true,
|
|
|
|
skipped_reason: "[MailingList] #{reason}"
|
|
|
|
)
|
|
|
|
end
|
2014-02-06 19:06:35 -05:00
|
|
|
end
|
|
|
|
end
|