Class: MnUtilsEmail::TransactionalEmail

Inherits:
Object
  • Object
show all
Includes:
Singleton
Defined in:
lib/mn_utils_gem/transactional_email.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TransactionalEmail

Returns a new instance of TransactionalEmail.



25
26
27
28
 
# File 'lib/mn_utils_gem/transactional_email.rb', line 25

def initialize
  # setup the logger
  @logger = defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end

Instance Method Details

#enqueue(message_type:, to_address:, subject:, fallback_text:, template_fields: {}, cc_addresses: '') ⇒ Object

Raises:

  • (ArgumentError) 


30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/mn_utils_gem/transactional_email.rb', line 30

def enqueue(message_type:, to_address:, subject:, fallback_text:, template_fields: {}, cc_addresses: '')

  # validate the parameters
  raise ArgumentError, "message_type cannot be blank" \
      if message_type.blank?
  raise ArgumentError, "to_address cannot be blank" \
      if to_address.blank?
  raise ArgumentError, "subject cannot be blank" \
      if subject.blank?
  raise ArgumentError, "fallback_text cannot be blank" \
      if fallback_text.blank?
  raise ArgumentError, "to_address #{to_address} is not a valid email address" \
      unless to_address =~ /@/

  # construct the message body for SQS
  message_body = {
      message_schema_version: 1,
      message_type: message_type,
      template_fields: template_fields.to_json,
      to_address: to_address,
      cc_addresses: cc_addresses,
      subject: subject,
      fallback_text: fallback_text
  }

  # add the request ID if available
  request_id = ''
  request_id = RequestStore.store[:request_id] if RequestStore.store[:request_id]
  message_body[:request_id] = request_id

  if ENV.key? 'SQS_MAIL2_QUEUE_URL'
    # put it on the SQS queue
    sqs = Aws::SQS::Client.new()
    sqs.send_message(
        queue_url: ENV['SQS_MAIL2_QUEUE_URL'],
        message_body: message_body.to_json
    )
  else
    @logger.debug("Payload for SQS: #{message_body}")
  end

end