The producer class used in Liam

liam_producer.rb

# frozen_string_literal: true
# Author: Diego Acuña

module Liam
  class Producer
    def initialize(event, message, options = {})
      @event = event
      @message = message
      @options = options
    end

    def self.publish(*args)
      new(*args).send(:call)
    end

    private

    private_class_method :new
    
    attr_reader :message, :event, :options

    def call
      JSON.parse(message) # validate the message
      messageSNS = Aws::SNS::Client.new(aws_options).publish({
        topic_arn: Rails.configuration.liam['events'][event],
        message: message,
        subject: options[:subject],
        message_structure: "string",
        message_attributes: { "EventName" => { string_value: event, data_type: "String" } }.merge(extra_attributes)
      })
      { status: :ok, message_id: messageSNS.message_id }
    rescue JSON::ParserError, Seahorse::Client::NetworkingError, Aws::SNS::Errors::NotFound => e
      { status: :error, error: e }
    end

    def aws_options
      options = {
        region:            AWS_REGION          # Replace this!
        access_key_id:     ACCESS_KEY          # Replace this!
        secret_access_key: SECRET_ACCESS_KEY   # Replace this!
      }
      options.merge!(endpoint: Rails.configuration.liam['aws']['sns_endpoint']) if Rails.configuration.liam['aws']['sns_endpoint']
      options
    end

    def extra_attributes
      options[:message_attributes] || {}
    end
  end
end