Contents

# frozen_string_literal: true

require 'aws-sdk-sns'
require_relative 'abstract/client'

module CycloneLariat
  class SnsClient < Abstract::Client
    include LunaPark::Extensions::Injector

    dependency(:aws_client_class) { Aws::SNS::Client }

    SNS_SUFFIX = :fanout

    def publish(msg, topic: nil)
      topic ||= [instance, msg.kind, SNS_SUFFIX, publisher, msg.type].join('-')

      aws_client.publish(
        topic_arn: topic_arn(topic),
        message: msg.to_json
      )
    end

    def publish_event(type, data: {}, version: self.version, uuid: SecureRandom.uuid, topic: nil)
      publish event(type, data: data, version: version, uuid: uuid), topic: topic
    end

    def publish_command(type, data: {}, version: self.version, uuid: SecureRandom.uuid, topic: nil)
      publish command(type, data: data, version: version, uuid: uuid), topic: topic
    end

    private

    def topic_arn(topic_name)
      list  = aws_client.list_topics.topics
      topic = list.find { |t| t.topic_arn.match?(topic_name) }
      raise Errors::TopicNotFound.new(expected_topic: topic_name, existed_topics: list.map(&:topic_arn)) if topic.nil?

      topic.topic_arn
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
cyclone_lariat-0.3.7	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.6	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.5	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.4	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.3	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.2	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.1	lib/cyclone_lariat/sns_client.rb
cyclone_lariat-0.3.0	lib/cyclone_lariat/sns_client.rb