Add protocol and configuration bindings for outbound SNS. (#126)

This adds protocol and configuration bindings for outbound SNS messaging
using AWS, particularly for SMS messages.

Author: TreyE

Gemfile

@@ -13,4 +13,5 @@ group :development, :test do
   gem 'rubocop'
   gem 'yard'
   gem 'rubocop-git'
+  gem 'aws-sdk-sns'
 end

Gemfile.lock

@@ -18,7 +18,7 @@ PATH
       faraday_middleware (~> 1.0)
       logging (~> 2.3.0)
       mime-types
-      nokogiri (= 1.15.7)
+      nokogiri (>= 1.13.0)
       oj (~> 3.11)
       ox (~> 2.14)
       typhoeus (~> 1.4.0)
@@ -89,6 +89,21 @@ GEM
       public_suffix (>= 2.0.2, < 5.0)
     amq-protocol (2.3.2)
     ast (2.4.2)
+    aws-eventstream (1.3.2)
+    aws-partitions (1.1098.0)
+    aws-sdk-core (3.223.0)
+      aws-eventstream (~> 1, >= 1.3.0)
+      aws-partitions (~> 1, >= 1.992.0)
+      aws-sigv4 (~> 1.9)
+      base64
+      jmespath (~> 1, >= 1.6.1)
+      logger
+    aws-sdk-sns (1.98.0)
+      aws-sdk-core (~> 3, >= 3.216.0)
+      aws-sigv4 (~> 1.5)
+    aws-sigv4 (1.11.0)
+      aws-eventstream (~> 1, >= 1.0.2)
+    base64 (0.2.0)
     bson (4.12.1)
     builder (3.2.4)
     bunny (2.19.0)
@@ -179,7 +194,9 @@ GEM
     i18n (1.8.10)
       concurrent-ruby (~> 1.0)
     ice_nine (0.11.2)
+    jmespath (1.6.2)
     little-plugger (1.1.4)
+    logger (1.7.0)
     logging (2.3.0)
       little-plugger (~> 1.1)
       multi_json (~> 1.14)
@@ -327,6 +344,7 @@ PLATFORMS
   ruby
 
 DEPENDENCIES
+  aws-sdk-sns
   database_cleaner
   event_source!
   faker

lib/event_source.rb

@@ -24,6 +24,7 @@
 require 'event_source/async_api/async_api'
 require 'event_source/railtie' if defined?(Rails)
 require 'event_source/configure'
+require 'event_source/protocols'
 require 'event_source/connection'
 require 'event_source/connection_manager'
 require 'event_source/channel'

lib/event_source/async_api/async_api.rb

@@ -14,7 +14,6 @@ module EventSource
   #
   # See {Protocols} for the data communication protocols EventSource supports.
   module AsyncApi
-    require 'event_source/uris/amqp_uri'
     require_relative 'error'
     require_relative 'types'
     require_relative 'external_documentation'

lib/event_source/async_api/contracts/publish_operation_bindings_contract.rb

@@ -2,6 +2,7 @@
 
 require "event_source/protocols/http/contracts/publish_operation_bindings_contract"
 require "event_source/protocols/amqp/contracts/publish_operation_binding_contract"
+require "event_source/protocols/sns/contracts/publish_operation_binding_contract"
 
 module EventSource
   module AsyncApi
@@ -11,6 +12,21 @@ class PublishOperationBindingsContract < Contract
         params do
           optional(:http).hash
           optional(:amqp).hash
+          optional(:sns).hash
+        end
+
+        rule(:sns) do
+          if key? && value
+            validation_result = ::EventSource::Protocols::Sns::Contracts::PublishOperationBindingsContract.new.call(value)
+            if validation_result&.failure?
+              key.failure(
+                text: 'invalid operation bindings',
+                error: validation_result.errors.to_h
+              )
+            else
+              values.data.merge({ sns: validation_result.values })
+            end
+          end
         end
 
         rule(:http) do

lib/event_source/async_api/publish_bindings.rb

@@ -4,6 +4,7 @@
 require "event_source/protocols/http/publish_bindings"
 require "event_source/protocols/amqp/types"
 require "event_source/protocols/amqp/publish_bindings"
+require "event_source/protocols/sns/publish_bindings"
 
 module EventSource
   module AsyncApi
@@ -12,6 +13,7 @@ class PublishBindings < Dry::Struct
       transform_keys(&:to_sym)
       attribute :http, ::EventSource::Protocols::Http::PublishBindings.meta(omittable: true)
       attribute :amqp, Types::Hash.meta(omittable: true)
+      attribute :sns, ::EventSource::Protocols::Sns::PublishBindings.meta(omittable: true)
       attribute :x_amqp_exchange_to_exchanges, Types::Hash.meta(omittable: true)
     end
   end

lib/event_source/channel.rb

@@ -76,7 +76,7 @@ def add_publish_operation(async_api_channel_item)
         @channel_proxy.add_publish_operation(async_api_channel_item)
       return false unless publish_proxy
 
-      @channel_proxy.create_exchange_to_exchange_bindings(publish_proxy) if @connection.protocol == :amqp
+      @channel_proxy.publish_proxy_created(publish_proxy)
       operation_id = async_api_channel_item.publish.operationId
 
       logger.info "Adding Publish Operation:  #{operation_id}"

lib/event_source/configure/config.rb

@@ -19,6 +19,10 @@ def initialize
       def load_protocols
         @protocols.each do |protocol|
           require "event_source/protocols/#{protocol}_protocol"
+          protocol_module = EventSource::Protocols.const_get(protocol.camelize)
+          EventSource::Protocols::Registry.register_protocol(
+            protocol_module
+          )
         end
       end
 

lib/event_source/configure/contracts.rb

@@ -3,6 +3,7 @@
 require_relative "contracts/client_certificate_settings_contract"
 require_relative "contracts/soap_settings_contract"
 require_relative "contracts/http_configuration_contract"
+require_relative "contracts/sns_configuration_contract"
 
 module EventSource
   module Configure

lib/event_source/configure/contracts/sns_configuration_contract.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+module EventSource
+  module Configure
+    module Contracts
+      # Contract for SNS configuration.
+      class SnsConfigurationContract < Dry::Validation::Contract
+        params do
+          required(:url).value(:string)
+          required(:region).value(:string)
+          required(:access_key_id).value(:string)
+          required(:secret_access_key).value(:string)
+        end
+      end
+    end
+  end
+end