Add SNS sdk inbound/outbound resource management.

Author: TreyE

Gemfile

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

Gemfile.lock

@@ -345,6 +345,7 @@ PLATFORMS
 
 DEPENDENCIES
   aws-sdk-sns
+  concurrent-ruby
   database_cleaner
   event_source!
   faker

lib/event_source.rb

@@ -45,6 +45,7 @@
 require 'event_source/operations/build_message_options'
 require 'event_source/operations/build_message'
 require 'event_source/boot_registry'
+require 'event_source/paginator'
 
 # Event source provides ability to compose, publish and subscribe to events
 module EventSource

lib/event_source/async_api/contracts/subscribe_operation_bindings_contract.rb

@@ -2,6 +2,7 @@
 
 require "event_source/protocols/http/contracts/subscribe_operation_bindings_contract"
 require "event_source/protocols/amqp/contracts/subscribe_operation_binding_contract"
+require "event_source/protocols/sns/contracts/subscribe_operation_binding_contract"
 
 module EventSource
   module AsyncApi
@@ -11,6 +12,7 @@ class SubscribeOperationBindingsContract < Contract
         params do
           optional(:http).hash
           optional(:amqp).hash
+          optional(:sns).hash
         end
 
         rule(:http) do
@@ -24,6 +26,20 @@ class SubscribeOperationBindingsContract < Contract
             end
           end
         end
+
+        rule(:sns) do
+          if key? && value
+            validation_result = ::EventSource::Protocols::Sns::Contracts::SubscribeOperationBindingsContract.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
       end
     end
   end

lib/event_source/async_api/publish_bindings.rb

@@ -4,7 +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"
+require "event_source/protocols/sns/operation_bindings"
 
 module EventSource
   module AsyncApi

lib/event_source/async_api/subscribe_bindings.rb

@@ -3,13 +3,15 @@
 require "event_source/protocols/http/types"
 require "event_source/protocols/http/subscribe_bindings"
 require "event_source/protocols/amqp/subscribe_bindings"
+require "event_source/protocols/sns/operation_bindings"
 
 module EventSource
   module AsyncApi
     class SubscribeBindings < Dry::Struct
       transform_keys(&:to_sym)
       attribute :http, ::EventSource::Protocols::Http::SubscribeBindings.meta(omittable: true)
       attribute :amqp, Types::Hash.meta(omittable: true)
+      attribute :sns, ::EventSource::Protocols::Sns::SubscribeBindings.meta(omittable: true)
     end
   end
 end

lib/event_source/connection_manager.rb

@@ -89,6 +89,8 @@ def find_connection(params)
           connection.publish_operation_exists?(params[:publish_operation_name])
         end
       else
+        # raise params[:subscribe_operation_name].inspect if params[:protocol] == :sns
+        # raise connections.first.subscribe_operations.keys.inspect
         connections.detect do |connection|
           connection.subscribe_operation_exists?(
             params[:subscribe_operation_name]

lib/event_source/paginator.rb

@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+module EventSource
+  # Abstract paginator for protocols which support it.
+  class Paginator
+    attr_reader :state, :continuation_data
+
+    def initialize(more, state, continue_data)
+      @more = more
+      @state = state
+      @continuation_data = continue_data
+    end
+
+    def more?
+      @more
+    end
+
+    def self.continue(state, continue_data)
+      self.new(true, state, continue_data)
+    end
+
+    def self.finished
+      self.new(false, nil, nil)
+    end
+  end
+end

lib/event_source/protocols/amqp_protocol.rb

@@ -32,6 +32,10 @@ def self.scheme_patterns
       def self.proxy_klass
         EventSource::Protocols::Amqp::BunnyConnectionProxy
       end
+
+      def self.subscribe_operation_name_for(app_name, subscriber_key)
+        "on_#{app_name}.#{subscriber_key}"
+      end
     end
   end
-end
+end

lib/event_source/protocols/http_protocol.rb

@@ -31,6 +31,10 @@ def self.scheme_patterns
       def self.proxy_klass
         EventSource::Protocols::Http::FaradayConnectionProxy
       end
+
+      def self.subscribe_operation_name_for(_app_name, subscriber_key)
+        "/on#{subscriber_key}"
+      end
     end
   end
 end