Contents

# frozen_string_literal: true

module Eventboss
  class Publisher
    def initialize(event_name, sns_client, configuration, opts = {})
      @event_name = event_name
      @sns_client = sns_client
      @configuration = configuration
      @source = configuration.eventboss_app_name unless opts[:generic]
    end

    def publish(payload)
      topic_arn = Topic.build_arn(event_name: event_name, source_app: source)
      sns_client.publish(
        topic_arn: topic_arn,
        message: json_payload(payload)
      )
    end

    private

    attr_reader :event_name, :sns_client, :configuration, :source

    def json_payload(payload)
      payload.is_a?(String) ? payload : payload.to_json
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
eventboss-1.9.2	lib/eventboss/publisher.rb
eventboss-1.9.1	lib/eventboss/publisher.rb
eventboss-1.9.0	lib/eventboss/publisher.rb
eventboss-1.8.1	lib/eventboss/publisher.rb
eventboss-1.8.0	lib/eventboss/publisher.rb
eventboss-1.7.0	lib/eventboss/publisher.rb
eventboss-1.5.0	lib/eventboss/publisher.rb
eventboss-1.4.1	lib/eventboss/publisher.rb
eventboss-1.3.5	lib/eventboss/publisher.rb
eventboss-1.3.4	lib/eventboss/publisher.rb
eventboss-1.3.3	lib/eventboss/publisher.rb
eventboss-1.3.2	lib/eventboss/publisher.rb