Contents

require 'retries'
# This is a basic implementation of the Notification service using Amazon SNS.
# The expected usage is as follows :
#   notification_service = DispatchRider::NotificationServices::AwsSns.new
#   notification_service.publish(:to => [:foo, :oof], :message => {:subject => "bar", :body => "baz"})
module DispatchRider
  module NotificationServices
    class AwsSns < Base
      def notifier_builder
        AWS::SNS
      rescue NameError
        raise AdapterNotFoundError.new(self.class.name, 'aws-sdk')
      end

      def channel_registrar_builder
        Registrars::SnsChannel
      end

      def publish(options)
        channels(options[:to]).each do |channel|
          with_retries(max_retries: 10, rescue: AWS::Errors::MissingCredentialsError) do
            channel.publish(serialize(message(options[:message])))
          end
        end
      end

      # not really happy with this, but the notification service registrar system is way too rigid to do this cleaner
      # since you only can have one notifier for the whole service, but you need to create a new one for each region
      def channel(name)
        arn = self.fetch(name)
        region = arn.split(':')[3]
        notifier_builder.new(region: region).topics[arn]
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
dispatch-rider-1.5.1	lib/dispatch-rider/notification_services/aws_sns.rb
dispatch-rider-1.5.0	lib/dispatch-rider/notification_services/aws_sns.rb
dispatch-rider-1.4.2	lib/dispatch-rider/notification_services/aws_sns.rb