62 lines
1.7 KiB
Ruby
62 lines
1.7 KiB
Ruby
module Messagebus
|
|
class Mailer
|
|
unless defined?(MessagebusRubyApi::VERSION)
|
|
MessagebusRubyApi::VERSION = '0.4.8'
|
|
end
|
|
|
|
def initialize(api_key)
|
|
@client = MessagebusRubyApi::Client.new(api_key)
|
|
end
|
|
|
|
attr_accessor :settings
|
|
|
|
def new(*settings)
|
|
self
|
|
end
|
|
|
|
def deliver!(message)
|
|
deliver(message)
|
|
end
|
|
|
|
def message_parse(string)
|
|
string.split('<')[0]
|
|
end
|
|
|
|
def from_header_parse(message)
|
|
AppConfig[:smtp_sender_address]
|
|
end
|
|
|
|
private
|
|
|
|
def deliver(message)
|
|
# here we want = {:fromEmail => message['from'].to_s}
|
|
#this is required due to weird bug in action mailer
|
|
from_header = from_header_parse(message)
|
|
|
|
@client.send_common_info = {:fromEmail => from_header, :customHeaders => {"sender"=> from_header}}
|
|
message.to.each do |addressee|
|
|
m = {:toEmail => addressee, :fromEmail => from_header, :subject => message.subject, :fromName => message_parse(from_header)}
|
|
@things = []
|
|
|
|
if message.multipart?
|
|
m[:plaintextBody] = message.text_part.body.to_s if message.text_part
|
|
m[:htmlBody] = message.html_part.body.to_s if message.html_part
|
|
else
|
|
m[:plaintextBody] = message.body.to_s
|
|
m[:htmlBody] = message.body.to_s
|
|
end
|
|
|
|
@client.add_message(m)
|
|
@things << m
|
|
end
|
|
begin
|
|
status = @client.flush
|
|
rescue Exception => e
|
|
raise "message bus failures: #{e.message} #{@things.map{|x| x[:fromEmail]}.inspect}, #{message['from']}"
|
|
end
|
|
if status[:failureCount] && status[:failureCount] > 0
|
|
raise "Messagebus failure. failureCount=#{failureCount}, message=#{message.inspect}"
|
|
end
|
|
end
|
|
end
|
|
end
|