2013-06-11 03:33:37 +08:00
|
|
|
require_dependency 'email/sender'
|
2013-02-06 03:16:51 +08:00
|
|
|
|
|
|
|
module Jobs
|
|
|
|
|
|
|
|
# Asynchronously send an email to a user
|
|
|
|
class UserEmail < Jobs::Base
|
|
|
|
|
|
|
|
def execute(args)
|
2016-01-29 23:49:49 +08:00
|
|
|
notification, post = nil
|
2014-02-15 02:06:21 +08:00
|
|
|
|
2013-02-06 03:16:51 +08:00
|
|
|
raise Discourse::InvalidParameters.new(:user_id) unless args[:user_id].present?
|
2016-01-29 23:49:49 +08:00
|
|
|
raise Discourse::InvalidParameters.new(:type) unless args[:type].present?
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
type = args[:type]
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
user = User.find_by(id: args[:user_id])
|
2015-11-07 02:19:13 +08:00
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
set_skip_context(type, args[:user_id], args[:to_address] || user.try(:email) || "no_email_found")
|
|
|
|
return skip(I18n.t("email_log.no_user", user_id: args[:user_id])) unless user
|
2013-02-26 00:42:20 +08:00
|
|
|
|
2013-02-06 03:16:51 +08:00
|
|
|
if args[:post_id]
|
2014-05-06 21:41:59 +08:00
|
|
|
post = Post.find_by(id: args[:post_id])
|
2016-01-29 23:49:49 +08:00
|
|
|
return skip(I18n.t('email_log.post_not_found', post_id: args[:post_id])) unless post.present?
|
2016-01-27 09:19:49 +08:00
|
|
|
end
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
if args[:notification_id].present?
|
|
|
|
notification = Notification.find_by(id: args[:notification_id])
|
|
|
|
end
|
|
|
|
|
|
|
|
message, skip_reason = message_for_email( user,
|
|
|
|
post,
|
|
|
|
type,
|
|
|
|
notification,
|
|
|
|
args[:notification_type],
|
|
|
|
args[:notification_data_hash],
|
|
|
|
args[:email_token],
|
|
|
|
args[:to_address] )
|
|
|
|
|
|
|
|
|
|
|
|
if message
|
2016-01-29 23:49:49 +08:00
|
|
|
Email::Sender.new(message, args[:type], user).send
|
2016-01-27 09:19:49 +08:00
|
|
|
else
|
|
|
|
skip_reason
|
2013-02-06 03:16:51 +08:00
|
|
|
end
|
2016-01-27 09:19:49 +08:00
|
|
|
end
|
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
def set_skip_context(type, user_id, to_address)
|
|
|
|
@skip_context = {type: type, user_id: user_id, to_address: to_address}
|
2016-01-27 09:19:49 +08:00
|
|
|
end
|
|
|
|
|
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
def message_for_email(user, post, type, notification,
|
|
|
|
notification_type=nil, notification_data_hash=nil,
|
|
|
|
email_token=nil, to_address=nil)
|
2016-01-27 09:19:49 +08:00
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
set_skip_context(type, user.id, to_address || user.email)
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
return skip_message(I18n.t("email_log.anonymous_user")) if user.anonymous?
|
2016-01-27 09:19:49 +08:00
|
|
|
return skip_message(I18n.t("email_log.suspended_not_pm")) if user.suspended? && type != :user_private_message
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
return if user.staged && type == :digest
|
2013-02-26 00:42:20 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
seen_recently = (user.last_seen_at.present? && user.last_seen_at > SiteSetting.email_time_window_mins.minutes.ago)
|
|
|
|
seen_recently = false if user.email_always || user.staged
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
email_args = {}
|
|
|
|
|
|
|
|
if post || notification || notification_type
|
|
|
|
return skip_message(I18n.t('email_log.seen_recently')) if seen_recently && !user.suspended?
|
|
|
|
end
|
|
|
|
|
|
|
|
if post
|
|
|
|
email_args[:post] = post
|
2013-02-06 03:16:51 +08:00
|
|
|
end
|
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
if notification || notification_type
|
|
|
|
email_args[:notification_type] ||= notification_type || notification.try(:notification_type)
|
|
|
|
email_args[:notification_data_hash] ||= notification_data_hash || notification.try(:data_hash)
|
|
|
|
|
|
|
|
unless user.email_always?
|
|
|
|
if (notification && notification.read?) || (post && post.seen?(user))
|
|
|
|
return skip_message(I18n.t('email_log.notification_already_read'))
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
skip_reason = skip_email_for_post(post, user)
|
|
|
|
return skip_message(skip_reason) if skip_reason
|
2013-06-11 00:02:04 +08:00
|
|
|
|
2013-02-06 03:16:51 +08:00
|
|
|
# Make sure that mailer exists
|
2016-01-27 09:19:49 +08:00
|
|
|
raise Discourse::InvalidParameters.new("type=#{type}") unless UserNotifications.respond_to?(type)
|
|
|
|
|
|
|
|
if email_token.present?
|
|
|
|
email_args[:email_token] = email_token
|
|
|
|
end
|
2013-02-26 00:42:20 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
message = UserNotifications.send(type, user, email_args)
|
2015-12-01 09:12:55 +08:00
|
|
|
|
2013-02-06 03:16:51 +08:00
|
|
|
# Update the to address if we have a custom one
|
2016-01-27 09:19:49 +08:00
|
|
|
if to_address.present?
|
|
|
|
message.to = [to_address]
|
2013-02-06 03:16:51 +08:00
|
|
|
end
|
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
[message, nil]
|
2013-06-11 04:46:08 +08:00
|
|
|
end
|
|
|
|
|
|
|
|
private
|
2013-02-06 03:16:51 +08:00
|
|
|
|
2016-01-27 09:19:49 +08:00
|
|
|
def skip_message(reason)
|
2016-01-29 23:49:49 +08:00
|
|
|
[nil, skip(reason)]
|
2016-01-27 09:19:49 +08:00
|
|
|
end
|
|
|
|
|
2013-06-11 04:46:08 +08:00
|
|
|
# If this email has a related post, don't send an email if it's been deleted or seen recently.
|
|
|
|
def skip_email_for_post(post, user)
|
2014-02-15 02:06:21 +08:00
|
|
|
if post
|
2016-01-29 02:01:35 +08:00
|
|
|
return I18n.t('email_log.topic_nil') if post.topic.blank?
|
|
|
|
return I18n.t('email_log.post_deleted') if post.user_deleted?
|
2014-02-15 02:06:21 +08:00
|
|
|
return I18n.t('email_log.user_suspended') if (user.suspended? && !post.user.try(:staff?))
|
2016-01-29 02:01:35 +08:00
|
|
|
return I18n.t('email_log.already_read') if PostTiming.where(topic_id: post.topic_id, post_number: post.post_number, user_id: user.id).present?
|
2014-02-15 02:06:21 +08:00
|
|
|
else
|
|
|
|
false
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
def skip(reason)
|
|
|
|
EmailLog.create!(
|
|
|
|
email_type: @skip_context[:type],
|
|
|
|
to_address: @skip_context[:to_address],
|
|
|
|
user_id: @skip_context[:user_id],
|
|
|
|
skipped: true,
|
|
|
|
skipped_reason: reason,
|
|
|
|
)
|
2013-02-06 03:16:51 +08:00
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|