mirror of
https://github.com/discourse/discourse.git
synced 2024-12-01 13:09:33 -06:00
30990006a9
This reduces chances of errors where consumers of strings mutate inputs and reduces memory usage of the app. Test suite passes now, but there may be some stuff left, so we will run a few sites on a branch prior to merging
114 lines
3.6 KiB
Ruby
114 lines
3.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_dependency 'post'
|
|
|
|
module Jobs
|
|
|
|
class NotifyMailingListSubscribers < Jobs::Base
|
|
include Skippable
|
|
|
|
RETRY_TIMES = [5.minute, 15.minute, 30.minute, 45.minute, 90.minute, 180.minute, 300.minute]
|
|
|
|
sidekiq_options queue: 'low'
|
|
|
|
sidekiq_options retry: RETRY_TIMES.size
|
|
|
|
sidekiq_retry_in do |count, exception|
|
|
case exception.wrapped
|
|
when SocketError
|
|
RETRY_TIMES[count]
|
|
else
|
|
Jobs::UserEmail.seconds_to_delay(count)
|
|
end
|
|
end
|
|
|
|
def execute(args)
|
|
return if SiteSetting.disable_mailing_list_mode
|
|
|
|
post_id = args[:post_id]
|
|
post = post_id ? Post.with_deleted.find_by(id: post_id) : nil
|
|
|
|
return if !post || post.trashed? || post.user_deleted? || !post.topic
|
|
|
|
users =
|
|
User.activated.not_silenced.not_suspended.real
|
|
.joins(:user_option)
|
|
.where('user_options.mailing_list_mode AND user_options.mailing_list_mode_frequency > 0')
|
|
.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 (
|
|
SELECT 1
|
|
FROM ignored_users iu
|
|
WHERE iu.ignored_user_id = ? AND iu.user_id = users.id
|
|
)', post.user_id)
|
|
.where('NOT EXISTS (
|
|
SELECT 1
|
|
FROM topic_users tu
|
|
WHERE tu.topic_id = ? AND tu.user_id = users.id AND tu.notification_level = ?
|
|
)', post.topic_id, TopicUser.notification_levels[:muted])
|
|
.where('NOT EXISTS (
|
|
SELECT 1
|
|
FROM category_users cu
|
|
WHERE cu.category_id = ? AND cu.user_id = users.id AND cu.notification_level = ?
|
|
)', post.topic.category_id, CategoryUser.notification_levels[:muted])
|
|
|
|
if SiteSetting.must_approve_users
|
|
users = users.where(approved: true)
|
|
end
|
|
|
|
DiscourseEvent.trigger(:notify_mailing_list_subscribers, users, post)
|
|
users.find_each do |user|
|
|
if Guardian.new(user).can_see?(post)
|
|
if EmailLog.reached_max_emails?(user)
|
|
skip(user.email, user.id, post.id,
|
|
SkippedEmailLog.reason_types[:exceeded_emails_limit]
|
|
)
|
|
|
|
next
|
|
end
|
|
|
|
if user.user_stat.bounce_score >= SiteSetting.bounce_score_threshold
|
|
skip(user.email, user.id, post.id,
|
|
SkippedEmailLog.reason_types[:exceeded_bounces_limit]
|
|
)
|
|
|
|
next
|
|
end
|
|
|
|
if (user.id == post.user_id) && (user.user_option.mailing_list_mode_frequency == 2)
|
|
skip(user.email, user.id, post.id,
|
|
SkippedEmailLog.reason_types[:mailing_list_no_echo_mode]
|
|
)
|
|
|
|
next
|
|
end
|
|
|
|
begin
|
|
if message = UserNotifications.mailing_list_notify(user, post)
|
|
EmailLog.unique_email_per_post(post, user) do
|
|
Email::Sender.new(message, :mailing_list, user).send
|
|
end
|
|
end
|
|
rescue => e
|
|
Discourse.handle_job_exception(e, error_context(args, "Sending post to mailing list subscribers", user_id: user.id, user_email: user.email))
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
def skip(to_address, user_id, post_id, reason_type)
|
|
create_skipped_email_log(
|
|
email_type: 'mailing_list',
|
|
to_address: to_address,
|
|
user_id: user_id,
|
|
post_id: post_id,
|
|
reason_type: reason_type
|
|
)
|
|
end
|
|
end
|
|
end
|