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

@@ -4,6 +4,7 @@ PATH
     event_source (0.6.0)
       addressable (>= 2.8.0)
       bunny (>= 2.14)
+      concurrent-ruby
       deep_merge (~> 1.2.0)
       dry-configurable (~> 0.12)
       dry-events (~> 0.3)
@@ -345,6 +346,7 @@ PLATFORMS
 
 DEPENDENCIES
   aws-sdk-sns
+  concurrent-ruby
   database_cleaner
   event_source!
   faker

event_source.gemspec

@@ -55,6 +55,7 @@ Gem::Specification.new do |spec|
   spec.add_dependency 'oj', '~> 3.11'
   spec.add_dependency 'ox', '~> 2.14'
   spec.add_dependency 'typhoeus', '~> 1.4.0'
+  spec.add_dependency 'concurrent-ruby'
 
   # TODO: Change to development dependency
   spec.add_development_dependency 'database_cleaner'

lib/event_source.rb

@@ -30,6 +30,7 @@
 require 'event_source/channel'
 require 'event_source/queue'
 require 'event_source/worker'
+require 'event_source/worker_pool'
 require 'event_source/publish_operation'
 require 'event_source/subscribe_operation'
 require 'event_source/message'
@@ -45,6 +46,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/loggers.rb

@@ -0,0 +1,10 @@
+# frozen_string_literal: true
+
+require 'logging'
+require_relative "loggers/inherited_logger"
+
+module EventSource
+  # Logger implementations for EventSource, providing sensible defaults.
+  module Loggers
+  end
+end

lib/event_source/loggers/inherited_logger.rb

@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+require 'logging'
+
+module EventSource
+  module Loggers
+    # A logger which, no matter the name, inherits from the EventSource primary logger
+    class InheritedLogger < ::Logging::Logger
+      # Inherit from the logger for EventSource
+      # rubocop:disable Lint/MissingSuper
+      def initialize(name)
+        case name
+        when String
+          raise(ArgumentError, "logger must have a name") if name.empty?
+        else raise(ArgumentError, "logger name must be a String") end
+
+        _setup(name, :parent => ::Logging.logger["EventSource"])
+      end
+      # rubocop:enable Lint/MissingSuper
+    end
+  end
+end