Eh main/feature/consumer

.env.local

@@ -0,0 +1,4 @@
+  export AWS_ACCESS_KEY_ID=foo
+  export AWS_SECRET_ACCESS_KEY=bar
+  export AWS_ENDPOINT="http://localhost:4566"
+  export ENABLE_AWS_CLIENT_CONFIG=true

.gitignore

@@ -57,3 +57,5 @@ build-iPhoneSimulator/
 
 .idea
 .rspec_status
+
+/log/

.rubocop.yml

@@ -1,5 +1,6 @@
 AllCops:
   TargetRubyVersion: 2.6
+  NewCops: enable
 
 Style/StringLiterals:
   Enabled: true
@@ -13,4 +14,21 @@ Layout/LineLength:
   Max: 120
 
 Metrics/BlockLength:
-  IgnoredMethods: ['describe', 'context']
+  IgnoredMethods: ["describe", "context"]
+
+Style/GlobalVars:
+  Exclude:
+    - "spec/worker_spec.rb"
+    # The introduction of a dummy global variable greatly simplified
+    # testing in this case, as it made reassignment between scopes much
+    # more straightforward. I didn't consider that particularly harmful.
+    # Thoughts?
+
+Lint/MissingSuper:
+  Enabled: false
+
+Metrics/MethodLength:
+  Enabled: false
+
+Metrics/AbcSize:
+  Enabled: false

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "rufo.useBundler": false,
+}

Gemfile

@@ -16,4 +16,5 @@ group :development, :test do
   gem "pry-doc"
   gem "rspec", "~> 3.0"
   gem "rubocop", "~> 1.21"
+  gem "solargraph"
 end

Gemfile.lock

@@ -29,15 +29,27 @@ GEM
       aws-sigv4 (~> 1.1)
     aws-sigv4 (1.4.0)
       aws-eventstream (~> 1, >= 1.0.2)
+    backport (1.2.0)
+    benchmark (0.2.0)
     coderay (1.1.3)
     concurrent-ruby (1.1.9)
     diff-lcs (1.3)
+    e2mmap (0.1.0)
     i18n (1.10.0)
       concurrent-ruby (~> 1.0)
+    jaro_winkler (1.5.4)
     jmespath (1.5.0)
+    kramdown (2.3.2)
+      rexml
+    kramdown-parser-gfm (1.1.0)
+      kramdown (~> 2.0)
     logger (1.3.0)
     method_source (1.0.0)
     minitest (5.15.0)
+    nokogiri (1.13.3-x86_64-darwin)
+      racc (~> 1.4)
+    nokogiri (1.13.3-x86_64-linux)
+      racc (~> 1.4)
     parallel (1.21.0)
     parser (3.0.2.0)
       ast (~> 2.4.1)
@@ -47,9 +59,12 @@ GEM
     pry-doc (1.3.0)
       pry (~> 0.11)
       yard (~> 0.9.11)
+    racc (1.6.0)
     rainbow (3.0.0)
     rake (13.0.6)
     regexp_parser (2.1.1)
+    reverse_markdown (2.1.1)
+      nokogiri
     rexml (3.2.5)
     rspec (3.8.0)
       rspec-core (~> 3.8.0)
@@ -76,7 +91,23 @@ GEM
     rubocop-ast (1.12.0)
       parser (>= 3.0.1.1)
     ruby-progressbar (1.11.0)
+    solargraph (0.41.2)
+      backport (~> 1.1)
+      benchmark
+      bundler (>= 1.17.2)
+      e2mmap
+      jaro_winkler (~> 1.5)
+      kramdown (~> 2.3)
+      kramdown-parser-gfm (~> 1.1)
+      parser (~> 3.0)
+      reverse_markdown (>= 1.0.5, < 3)
+      rubocop (>= 0.52)
+      thor (~> 1.0)
+      tilt (~> 2.0)
+      yard (~> 0.9, >= 0.9.24)
+    thor (1.2.1)
     thread_safe (0.3.6)
+    tilt (2.0.10)
     tzinfo (1.2.9)
       thread_safe (~> 0.1)
     unicode-display_width (2.1.0)
@@ -85,6 +116,7 @@ GEM
       webrick (~> 1.7.0)
 
 PLATFORMS
+  ruby
   x86_64-darwin-20
   x86_64-linux
 
@@ -99,6 +131,7 @@ DEPENDENCIES
   rake (~> 13.0)
   rspec (~> 3.0)
   rubocop (~> 1.21)
+  solargraph
 
 BUNDLED WITH
    2.3.9

README.md

@@ -68,11 +68,22 @@ On the irb console:
 
 * Consume a message
     ```ruby
-    require 'pipefy_message'
-    message = PipefyMessage::Test.new
-    message.consume
+      require "pipefy_message"
+
+      class TestWorker
+        include PipefyMessage::Worker
+        pipefymessage_options broker: "aws", queue_name: "pipefy-local-queue"
+
+        def perform(message)
+          puts message
+        end
+      end
+
+      TestWorker.perform_async
     ```
 
+
+
 * Publish and Consume a message
     ```ruby
     require 'pipefy_message'
@@ -82,7 +93,7 @@ On the irb console:
 
 ## Project Stack
 
-- [Aws SDK Ruby - SNS & SQS](https://github.com/aws/aws-sdk-ruby)
+- [Aws SDK Ruby - SNS & SQS](https://github.com/aws_client/aws-sdk-ruby)
 - [Bundler](https://bundler.io/)
 - Docker-compose
 - [GitHub Actions](https://docs.github.com/en/actions)
@@ -92,7 +103,7 @@ On the irb console:
 
 ## Brokers Documentation
 
-* [SNS & SQS User guide](https://github.com/pipefy/pipefy_message/tree/main/lib/pipefy_message/broker/aws/README.md)
+* [SNS & SQS User guide](https://github.com/pipefy/pipefy_message/tree/main/lib/pipefy_message/broker/aws_client/README.md)
 
 ## Contributing
 

lib/pipefy_message.rb

@@ -1,35 +1,20 @@
 # frozen_string_literal: true
 
 require_relative "pipefy_message/version"
-require_relative "pipefy_message/broker/aws/configuration"
-require_relative "pipefy_message/broker/aws/sns/publisher"
-require_relative "pipefy_message/base_consumer"
-require_relative "pipefy_message/base_publisher"
-require_relative "pipefy_message/logger"
+require_relative "pipefy_message/logging"
+require_relative "pipefy_message/publisher"
+require_relative "pipefy_message/worker"
+require_relative "pipefy_message/providers/broker"
+require_relative "pipefy_message/providers/errors"
+
 require "logger"
+require "json"
+require "benchmark"
+require "active_support"
+require "active_support/core_ext/string/inflections"
 
+##
+# PipefyMessage abstraction async process
+##
 module PipefyMessage
-  # Simple Test class to validate the project
-  class Test
-    def initialize
-      @log = PipefyMessage::CustomLogger.new
-    end
-
-    def publish
-      payload = { foo: "bar" }
-      puts Publisher::BasePublisher.new.publish(payload, "pipefy-local-topic")
-    end
-
-    def consume
-      @log.info("Starting the consumer process")
-      consumer = BaseConsumer.new("http://localhost:4566/000000000000/pipefy-local-queue")
-      @log.info("Creating new instance of consumer #{consumer}")
-      consumer.consume_message
-    end
-
-    def publish_and_consume
-      publish
-      consume
-    end
-  end
 end