mirror of
https://github.com/discourse/discourse.git
synced 2025-06-24 15:27:53 +08:00
18e9d319fd
Will log the exception message in the skipped reason instead of keeping the job in the queue whenever the email address is invalid
136 lines
3.7 KiB
Ruby
136 lines
3.7 KiB
Ruby
#
|
|
# A helper class to send an email. It will also handle a nil message, which it considers
|
|
# to be "do nothing". This is because some Mailers will decide not to do work for some
|
|
# reason. For example, emailing a user too frequently. A nil to address is also considered
|
|
# "do nothing"
|
|
#
|
|
# It also adds an HTML part for the plain text body
|
|
#
|
|
require_dependency 'email/renderer'
|
|
require 'uri'
|
|
|
|
SMTP_CLIENT_ERRORS = [Net::SMTPFatalError, Net::SMTPSyntaxError]
|
|
|
|
module Email
|
|
class Sender
|
|
|
|
def initialize(message, email_type, user=nil)
|
|
@message = message
|
|
@email_type = email_type
|
|
@user = user
|
|
end
|
|
|
|
def send
|
|
return skip(I18n.t('email_log.message_blank')) if @message.blank?
|
|
return skip(I18n.t('email_log.message_to_blank')) if @message.to.blank?
|
|
|
|
if @message.text_part
|
|
return skip(I18n.t('email_log.text_part_body_blank')) if @message.text_part.body.to_s.blank?
|
|
else
|
|
return skip(I18n.t('email_log.body_blank')) if @message.body.to_s.blank?
|
|
end
|
|
|
|
@message.charset = 'UTF-8'
|
|
|
|
opts = {}
|
|
|
|
renderer = Email::Renderer.new(@message, opts)
|
|
|
|
if @message.html_part
|
|
@message.html_part.body = renderer.html
|
|
else
|
|
@message.html_part = Mail::Part.new do
|
|
content_type 'text/html; charset=UTF-8'
|
|
body renderer.html
|
|
end
|
|
end
|
|
|
|
@message.parts[0].body = @message.parts[0].body.to_s.gsub(/\[\/?email-indent\]/, '')
|
|
|
|
@message.text_part.content_type = 'text/plain; charset=UTF-8'
|
|
|
|
# Set up the email log
|
|
email_log = EmailLog.new(email_type: @email_type,
|
|
to_address: to_address,
|
|
user_id: @user.try(:id))
|
|
|
|
|
|
host = Email::Sender.host_for(Discourse.base_url)
|
|
|
|
@message.header['List-Id'] = Email::Sender.list_id_for(SiteSetting.title, host)
|
|
|
|
topic_id = header_value('X-Discourse-Topic-Id')
|
|
post_id = header_value('X-Discourse-Post-Id')
|
|
reply_key = header_value('X-Discourse-Reply-Key')
|
|
|
|
if topic_id.present?
|
|
email_log.topic_id = topic_id
|
|
|
|
topic_identitfier = "<topic/#{topic_id}@#{host}>"
|
|
@message.header['In-Reply-To'] = topic_identitfier
|
|
@message.header['References'] = topic_identitfier
|
|
end
|
|
|
|
email_log.post_id = post_id if post_id.present?
|
|
email_log.reply_key = reply_key if reply_key.present?
|
|
|
|
# Remove headers we don't need anymore
|
|
@message.header['X-Discourse-Topic-Id'] = nil
|
|
@message.header['X-Discourse-Post-Id'] = nil
|
|
@message.header['X-Discourse-Reply-Key'] = nil
|
|
|
|
begin
|
|
@message.deliver
|
|
rescue SMTP_CLIENT_ERRORS => e
|
|
return skip(e.message)
|
|
end
|
|
|
|
# Save and return the email log
|
|
email_log.save!
|
|
email_log
|
|
end
|
|
|
|
def to_address
|
|
@to_address ||= begin
|
|
to = @message ? @message.to : nil
|
|
to.is_a?(Array) ? to.first : to
|
|
end
|
|
end
|
|
|
|
def self.host_for(base_url)
|
|
host = "localhost"
|
|
if base_url.present?
|
|
begin
|
|
uri = URI.parse(base_url)
|
|
host = uri.host.downcase if uri.host.present?
|
|
rescue URI::InvalidURIError
|
|
end
|
|
end
|
|
host
|
|
end
|
|
|
|
def self.list_id_for(site_name, host)
|
|
"\"#{site_name.gsub(/\"/, "'")}\" <discourse.forum.#{Slug.for(site_name)}.#{host}>"
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
def header_value(name)
|
|
header = @message.header[name]
|
|
return nil unless header
|
|
header.value
|
|
end
|
|
|
|
def skip(reason)
|
|
EmailLog.create(email_type: @email_type,
|
|
to_address: to_address,
|
|
user_id: @user.try(:id),
|
|
skipped: true,
|
|
skipped_reason: reason)
|
|
end
|
|
|
|
end
|
|
end
|