2013-06-11 03:33:37 +08:00
|
|
|
#
|
|
|
|
# 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'
|
2013-07-03 02:13:46 +08:00
|
|
|
require 'uri'
|
2014-03-12 18:55:08 +08:00
|
|
|
require 'net/smtp'
|
2013-06-11 03:33:37 +08:00
|
|
|
|
2014-03-07 23:33:15 +08:00
|
|
|
SMTP_CLIENT_ERRORS = [Net::SMTPFatalError, Net::SMTPSyntaxError]
|
|
|
|
|
2013-06-11 03:33:37 +08:00
|
|
|
module Email
|
|
|
|
class Sender
|
|
|
|
|
2017-07-28 09:20:09 +08:00
|
|
|
def initialize(message, email_type, user = nil)
|
2013-06-11 03:33:37 +08:00
|
|
|
@message = message
|
|
|
|
@email_type = email_type
|
|
|
|
@user = user
|
|
|
|
end
|
|
|
|
|
|
|
|
def send
|
2016-04-08 13:23:16 +08:00
|
|
|
return if SiteSetting.disable_emails && @email_type.to_s != "admin_login"
|
2016-02-18 00:31:46 +08:00
|
|
|
|
|
|
|
return if ActionMailer::Base::NullMail === @message
|
|
|
|
return if ActionMailer::Base::NullMail === (@message.message rescue nil)
|
|
|
|
|
2016-02-16 00:53:07 +08:00
|
|
|
return skip(I18n.t('email_log.message_blank')) if @message.blank?
|
2014-02-15 02:06:21 +08:00
|
|
|
return skip(I18n.t('email_log.message_to_blank')) if @message.to.blank?
|
2013-11-29 06:20:56 +08:00
|
|
|
|
|
|
|
if @message.text_part
|
2014-02-15 02:06:21 +08:00
|
|
|
return skip(I18n.t('email_log.text_part_body_blank')) if @message.text_part.body.to_s.blank?
|
2013-11-29 06:20:56 +08:00
|
|
|
else
|
2014-02-15 02:06:21 +08:00
|
|
|
return skip(I18n.t('email_log.body_blank')) if @message.body.to_s.blank?
|
2013-11-29 06:20:56 +08:00
|
|
|
end
|
2013-06-11 03:33:37 +08:00
|
|
|
|
|
|
|
@message.charset = 'UTF-8'
|
|
|
|
|
|
|
|
opts = {}
|
|
|
|
|
|
|
|
renderer = Email::Renderer.new(@message, opts)
|
|
|
|
|
2013-11-30 01:21:21 +08:00
|
|
|
if @message.html_part
|
|
|
|
@message.html_part.body = renderer.html
|
|
|
|
else
|
2013-07-24 15:13:15 +08:00
|
|
|
@message.html_part = Mail::Part.new do
|
|
|
|
content_type 'text/html; charset=UTF-8'
|
|
|
|
body renderer.html
|
|
|
|
end
|
2013-06-11 03:33:37 +08:00
|
|
|
end
|
|
|
|
|
2015-01-17 18:07:58 +08:00
|
|
|
# Fix relative (ie upload) HTML links in markdown which do not work well in plain text emails.
|
|
|
|
# These are the links we add when a user uploads a file or image.
|
|
|
|
# Ideally we would parse general markdown into plain text, but that is almost an intractable problem.
|
|
|
|
url_prefix = Discourse.base_url
|
2017-07-28 09:20:09 +08:00
|
|
|
@message.parts[0].body = @message.parts[0].body.to_s.gsub(/<a class="attachment" href="(\/uploads\/default\/[^"]+)">([^<]*)<\/a>/, '[\2](' + url_prefix + '\1)')
|
|
|
|
@message.parts[0].body = @message.parts[0].body.to_s.gsub(/<img src="(\/uploads\/default\/[^"]+)"([^>]*)>/, '![](' + url_prefix + '\1)')
|
2015-01-17 18:07:58 +08:00
|
|
|
|
2013-06-11 03:33:37 +08:00
|
|
|
@message.text_part.content_type = 'text/plain; charset=UTF-8'
|
|
|
|
|
2013-06-25 23:35:26 +08:00
|
|
|
# Set up the email log
|
2016-01-29 23:49:49 +08:00
|
|
|
email_log = EmailLog.new(email_type: @email_type, to_address: to_address, user_id: @user.try(:id))
|
2013-07-03 02:13:46 +08:00
|
|
|
|
2013-07-08 23:48:40 +08:00
|
|
|
host = Email::Sender.host_for(Discourse.base_url)
|
2013-07-03 02:13:46 +08:00
|
|
|
|
2017-02-02 06:02:41 +08:00
|
|
|
post_id = header_value('X-Discourse-Post-Id')
|
|
|
|
topic_id = header_value('X-Discourse-Topic-Id')
|
2013-07-08 23:48:40 +08:00
|
|
|
reply_key = header_value('X-Discourse-Reply-Key')
|
|
|
|
|
2015-01-28 17:12:49 +08:00
|
|
|
# always set a default Message ID from the host
|
2016-11-26 06:25:39 +08:00
|
|
|
@message.header['Message-ID'] = "<#{SecureRandom.uuid}@#{host}>"
|
2015-01-28 17:12:49 +08:00
|
|
|
|
2013-07-08 23:48:40 +08:00
|
|
|
if topic_id.present?
|
|
|
|
email_log.topic_id = topic_id
|
|
|
|
|
2016-11-26 06:25:39 +08:00
|
|
|
post = Post.find_by(id: post_id)
|
|
|
|
topic = Topic.find_by(id: topic_id)
|
2017-02-02 06:02:41 +08:00
|
|
|
first_post = topic.ordered_posts.first
|
2016-04-07 03:04:30 +08:00
|
|
|
|
2017-03-17 03:40:14 +08:00
|
|
|
topic_message_id = first_post.incoming_email&.message_id.present? ?
|
2017-02-02 06:02:41 +08:00
|
|
|
"<#{first_post.incoming_email.message_id}>" :
|
|
|
|
"<topic/#{topic_id}@#{host}>"
|
2016-04-07 03:04:30 +08:00
|
|
|
|
2017-02-02 06:02:41 +08:00
|
|
|
post_message_id = post.incoming_email&.message_id.present? ?
|
|
|
|
"<#{post.incoming_email.message_id}>" :
|
|
|
|
"<topic/#{topic_id}/#{post_id}@#{host}>"
|
2016-11-26 06:25:39 +08:00
|
|
|
|
|
|
|
referenced_posts = Post.includes(:incoming_email)
|
2017-07-28 09:20:09 +08:00
|
|
|
.where(id: PostReply.where(reply_id: post_id).select(:post_id))
|
|
|
|
.order(id: :desc)
|
2016-11-26 06:25:39 +08:00
|
|
|
|
|
|
|
referenced_post_message_ids = referenced_posts.map do |post|
|
2017-02-02 06:02:41 +08:00
|
|
|
if post.incoming_email&.message_id.present?
|
2016-11-26 06:25:39 +08:00
|
|
|
"<#{post.incoming_email.message_id}>"
|
|
|
|
else
|
2017-02-02 06:02:41 +08:00
|
|
|
if post.post_number == 1
|
|
|
|
"<topic/#{topic_id}@#{host}>"
|
|
|
|
else
|
|
|
|
"<topic/#{topic_id}/#{post.id}@#{host}>"
|
|
|
|
end
|
2016-11-26 06:25:39 +08:00
|
|
|
end
|
|
|
|
end
|
2014-06-14 06:42:14 +08:00
|
|
|
|
2017-02-02 06:02:41 +08:00
|
|
|
# https://www.ietf.org/rfc/rfc2822.txt
|
|
|
|
if post.post_number == 1
|
|
|
|
@message.header['Message-ID'] = topic_message_id
|
|
|
|
else
|
|
|
|
@message.header['Message-ID'] = post_message_id
|
|
|
|
@message.header['In-Reply-To'] = referenced_post_message_ids[0] || topic_message_id
|
2018-02-22 17:48:23 +08:00
|
|
|
@message.header['References'] = [topic_message_id, referenced_post_message_ids].flatten.compact.uniq
|
2016-11-26 06:25:39 +08:00
|
|
|
end
|
2014-10-09 02:09:21 +08:00
|
|
|
|
2017-02-02 06:02:41 +08:00
|
|
|
# https://www.ietf.org/rfc/rfc2919.txt
|
2014-10-09 02:09:21 +08:00
|
|
|
if topic && topic.category && !topic.category.uncategorized?
|
2018-05-03 22:39:25 +08:00
|
|
|
list_id = "#{SiteSetting.title} | #{topic.category.name} <#{topic.category.name.downcase.tr(' ', '-')}.#{host}>"
|
2014-10-09 02:09:21 +08:00
|
|
|
|
|
|
|
# subcategory case
|
|
|
|
if !topic.category.parent_category_id.nil?
|
|
|
|
parent_category_name = Category.find_by(id: topic.category.parent_category_id).name
|
2018-05-05 07:51:53 +08:00
|
|
|
list_id = "#{SiteSetting.title} | #{parent_category_name} #{topic.category.name} <#{topic.category.name.downcase.tr(' ', '-')}.#{parent_category_name.downcase.tr(' ', '-')}.#{host}>"
|
2014-10-09 02:09:21 +08:00
|
|
|
end
|
|
|
|
else
|
2018-05-03 22:39:25 +08:00
|
|
|
list_id = "#{SiteSetting.title} <#{host}>"
|
2014-10-09 02:09:21 +08:00
|
|
|
end
|
2014-10-09 03:57:30 +08:00
|
|
|
|
2017-02-02 06:02:41 +08:00
|
|
|
# https://www.ietf.org/rfc/rfc3834.txt
|
2018-05-03 22:39:25 +08:00
|
|
|
@message.header['Precedence'] = 'list'
|
|
|
|
@message.header['List-ID'] = list_id
|
2017-04-25 03:26:06 +08:00
|
|
|
|
|
|
|
if topic
|
|
|
|
if SiteSetting.private_email?
|
|
|
|
@message.header['List-Archive'] = "#{Discourse.base_url}#{topic.slugless_url}"
|
|
|
|
else
|
|
|
|
@message.header['List-Archive'] = topic.url
|
|
|
|
end
|
|
|
|
end
|
2014-06-14 06:49:11 +08:00
|
|
|
end
|
|
|
|
|
2016-01-29 23:49:49 +08:00
|
|
|
if reply_key.present? && @message.header['Reply-To'] =~ /\<([^\>]+)\>/
|
|
|
|
email = Regexp.last_match[1]
|
|
|
|
@message.header['List-Post'] = "<mailto:#{email}>"
|
2013-07-08 23:48:40 +08:00
|
|
|
end
|
|
|
|
|
2016-04-26 02:06:45 +08:00
|
|
|
if SiteSetting.reply_by_email_address.present? && SiteSetting.reply_by_email_address["+"]
|
2016-04-18 15:13:41 +08:00
|
|
|
email_log.bounce_key = SecureRandom.hex
|
|
|
|
|
|
|
|
# WARNING: RFC claims you can not set the Return Path header, this is 100% correct
|
|
|
|
# however Rails has special handling for this header and ends up using this value
|
|
|
|
# as the Envelope From address so stuff works as expected
|
2016-04-26 02:06:45 +08:00
|
|
|
@message.header[:return_path] = SiteSetting.reply_by_email_address.sub("%{reply_key}", "verp-#{email_log.bounce_key}")
|
2016-04-18 15:13:41 +08:00
|
|
|
end
|
|
|
|
|
2013-07-08 23:48:40 +08:00
|
|
|
email_log.post_id = post_id if post_id.present?
|
|
|
|
email_log.reply_key = reply_key if reply_key.present?
|
2013-06-13 22:56:16 +08:00
|
|
|
|
2013-06-25 23:35:26 +08:00
|
|
|
# Remove headers we don't need anymore
|
2016-01-29 23:49:49 +08:00
|
|
|
@message.header['X-Discourse-Topic-Id'] = nil if topic_id.present?
|
|
|
|
@message.header['X-Discourse-Post-Id'] = nil if post_id.present?
|
2015-01-29 19:53:10 +08:00
|
|
|
@message.header['X-Discourse-Reply-Key'] = nil if reply_key.present?
|
2013-06-25 23:35:26 +08:00
|
|
|
|
2016-10-28 01:35:50 +08:00
|
|
|
# pass the original message_id when using mailjet/mandrill/sparkpost
|
2016-06-13 18:31:01 +08:00
|
|
|
case ActionMailer::Base.smtp_settings[:address]
|
|
|
|
when /\.mailjet\.com/
|
2016-06-07 01:47:45 +08:00
|
|
|
@message.header['X-MJ-CustomID'] = @message.message_id
|
2016-06-13 18:31:01 +08:00
|
|
|
when "smtp.mandrillapp.com"
|
2017-07-28 09:20:09 +08:00
|
|
|
merge_json_x_header('X-MC-Metadata', message_id: @message.message_id)
|
2016-10-28 01:35:50 +08:00
|
|
|
when "smtp.sparkpostmail.com"
|
2017-07-28 09:20:09 +08:00
|
|
|
merge_json_x_header('X-MSYS-API', metadata: { message_id: @message.message_id })
|
2016-06-07 01:47:45 +08:00
|
|
|
end
|
|
|
|
|
2014-09-13 13:26:31 +08:00
|
|
|
# Suppress images from short emails
|
2016-01-29 23:49:49 +08:00
|
|
|
if SiteSetting.strip_images_from_short_emails &&
|
2016-05-10 02:37:33 +08:00
|
|
|
@message.html_part.body.to_s.bytesize <= SiteSetting.short_email_length &&
|
|
|
|
@message.html_part.body =~ /<img[^>]+>/
|
2014-09-13 13:26:31 +08:00
|
|
|
style = Email::Styles.new(@message.html_part.body.to_s)
|
|
|
|
@message.html_part.body = style.strip_avatars_and_emojis
|
|
|
|
end
|
|
|
|
|
2016-06-02 03:48:06 +08:00
|
|
|
email_log.message_id = @message.message_id
|
|
|
|
|
2014-03-07 23:33:15 +08:00
|
|
|
begin
|
2014-10-15 15:04:47 +08:00
|
|
|
@message.deliver_now
|
2014-03-09 20:06:54 +08:00
|
|
|
rescue *SMTP_CLIENT_ERRORS => e
|
2014-03-07 23:33:15 +08:00
|
|
|
return skip(e.message)
|
|
|
|
end
|
2013-06-25 23:35:26 +08:00
|
|
|
|
|
|
|
# Save and return the email log
|
2013-06-13 22:56:16 +08:00
|
|
|
email_log.save!
|
|
|
|
email_log
|
2013-06-11 03:33:37 +08:00
|
|
|
end
|
|
|
|
|
2014-02-15 02:06:21 +08:00
|
|
|
def to_address
|
|
|
|
@to_address ||= begin
|
2016-02-16 00:53:07 +08:00
|
|
|
to = @message.try(:to)
|
2016-01-29 23:49:49 +08:00
|
|
|
to = to.first if Array === to
|
|
|
|
to.presence || "no_email_found"
|
2014-02-15 02:06:21 +08:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2013-07-08 23:48:40 +08:00
|
|
|
def self.host_for(base_url)
|
2013-07-03 02:13:46 +08:00
|
|
|
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
|
2013-07-08 23:48:40 +08:00
|
|
|
host
|
|
|
|
end
|
2013-07-03 02:13:46 +08:00
|
|
|
|
2013-06-14 06:11:10 +08:00
|
|
|
private
|
|
|
|
|
2013-07-08 23:48:40 +08:00
|
|
|
def header_value(name)
|
2013-06-14 06:11:10 +08:00
|
|
|
header = @message.header[name]
|
2013-07-08 23:48:40 +08:00
|
|
|
return nil unless header
|
|
|
|
header.value
|
2013-06-14 06:11:10 +08:00
|
|
|
end
|
|
|
|
|
2014-02-15 02:06:21 +08:00
|
|
|
def skip(reason)
|
2016-01-29 23:49:49 +08:00
|
|
|
EmailLog.create!(
|
|
|
|
email_type: @email_type,
|
|
|
|
to_address: to_address,
|
|
|
|
user_id: @user.try(:id),
|
|
|
|
skipped: true,
|
2016-02-16 00:53:07 +08:00
|
|
|
skipped_reason: "[Sender] #{reason}"
|
2016-01-29 23:49:49 +08:00
|
|
|
)
|
2014-02-15 02:06:21 +08:00
|
|
|
end
|
|
|
|
|
2016-10-30 18:38:55 +08:00
|
|
|
def merge_json_x_header(name, value)
|
2016-11-03 09:26:12 +08:00
|
|
|
data = JSON.parse(@message.header[name].to_s) rescue nil
|
|
|
|
data ||= {}
|
|
|
|
data.merge!(value)
|
|
|
|
# /!\ @message.header is not a standard ruby hash.
|
|
|
|
# It can have multiple values attached to the same key...
|
|
|
|
# In order to remove all the previous keys, we have to "nil" it.
|
|
|
|
# But for "nil" to work, there must already be a key...
|
|
|
|
@message.header[name] = ""
|
2016-10-30 18:38:55 +08:00
|
|
|
@message.header[name] = nil
|
2016-11-03 09:26:12 +08:00
|
|
|
@message.header[name] = data.to_json
|
2016-10-30 18:38:55 +08:00
|
|
|
end
|
|
|
|
|
2013-06-11 03:33:37 +08:00
|
|
|
end
|
2013-07-24 15:13:15 +08:00
|
|
|
end
|