mirror of
https://github.com/discourse/discourse.git
synced 2024-11-23 08:09:33 +08:00
145 lines
3.9 KiB
Ruby
145 lines
3.9 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'
|
|
require 'net/smtp'
|
|
|
|
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 if SiteSetting.disable_emails
|
|
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)
|
|
|
|
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_identifier = "<topic/#{topic_id}@#{host}>"
|
|
@message.header['In-Reply-To'] = topic_identifier
|
|
@message.header['References'] = topic_identifier
|
|
|
|
# http://www.ietf.org/rfc/rfc2919.txt
|
|
list_id = "<topic.#{topic_id}.#{host}>"
|
|
@message.header['List-ID'] = list_id
|
|
|
|
topic = Topic.where(id: topic_id).first
|
|
@message.header['List-Archive'] = topic.url if topic
|
|
end
|
|
|
|
if reply_key.present?
|
|
|
|
if @message.header['Reply-To'] =~ /\<([^\>]+)\>/
|
|
email = Regexp.last_match[1]
|
|
@message.header['List-Post'] = "<mailto:#{email}>"
|
|
end
|
|
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
|
|
|
|
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
|