feat: bump version to 1.0.2

fix: use Aws::Query::ParamList::IoWrapper#read when building an async buffered body

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    async-aws (1.0.1)
+    async-aws (1.0.2)
       async-http (~> 0.51)
 
 GEM
@@ -39,6 +39,9 @@ GEM
       aws-sdk-core (~> 3, >= 3.83.0)
       aws-sdk-kms (~> 1)
       aws-sigv4 (~> 1.1)
+    aws-sdk-sqs (1.24.0)
+      aws-sdk-core (~> 3, >= 3.71.0)
+      aws-sigv4 (~> 1.1)
     aws-sigv4 (1.1.1)
       aws-eventstream (~> 1.0, >= 1.0.2)
     console (1.8.2)
@@ -76,6 +79,7 @@ DEPENDENCIES
   async-aws!
   aws-sdk-dynamodb
   aws-sdk-s3
+  aws-sdk-sqs
   bundler (~> 2.0)
   rake (~> 13.0)
   rspec (~> 3.0)

async-aws.gemspec

@@ -35,5 +35,6 @@ Gem::Specification.new do |spec|
   spec.add_development_dependency "rspec", "~> 3.0"
   spec.add_development_dependency "aws-sdk-s3"
   spec.add_development_dependency "aws-sdk-dynamodb"
+  spec.add_development_dependency "aws-sdk-sqs"
   spec.add_development_dependency "async"
 end

lib/async/aws/http_handler.rb

@@ -33,7 +33,7 @@ def call(context)
               k == 'host' || k == 'content-length'
             end
           )
-          buffered_body = Async::HTTP::Body::Buffered.wrap(req.body)
+          buffered_body = Async::HTTP::Body::Buffered.wrap(req.body.read)
           request = ::Protocol::HTTP::Request.new(
             client.scheme, endpoint.authority, req.http_method, endpoint.path,
             nil, headers, buffered_body

lib/async/aws/version.rb

@@ -1,5 +1,5 @@
 module Async
   module Aws
-    VERSION = '1.0.1'
+    VERSION = '1.0.2'
   end
 end

spec/async/aws_spec.rb

@@ -14,38 +14,4 @@
     end
     expect(handler_klass).not_to be_nil
   end
-
-  it 'should send an async request to AWS' do
-    Async::Reactor.run do |reactor|
-      tasks = 10.times.collect do
-        s3 = Aws::S3::Client.new
-        Async do
-          bench = Async::Clock.measure do
-            result = s3.list_buckets
-            expect(result.is_a?(Seahorse::Client::Response)).to be(true)
-          end
-        end
-      end
-
-      tasks.each(&:wait)
-    end
-  end
-
-  it 'should work with DynamoDB' do
-    Async::Reactor.run do |reactor|
-      task = Async do
-        dynamo = Aws::DynamoDB::Client.new
-        dynamo.get_item(
-          table_name: 'async-aws-rspec',
-          key: { pk: 'test' }
-        )
-        dynamo.get_item(
-          table_name: 'async-aws-rspec',
-          key: { pk: 'test' }
-        )
-      end
-
-      task.wait
-    end
-  end
 end

spec/async/dynamodb_spec.rb

@@ -0,0 +1,20 @@
+require 'async/aws/all'
+
+Async::Aws.configure(connection_limit: 4)
+
+RSpec.describe Async::Aws do
+  it 'should execute dynamodb:GetItem action' do
+    Async::Reactor.run do |reactor|
+      task = Async do
+        dynamo = Aws::DynamoDB::Client.new
+        result = dynamo.get_item(
+          table_name: 'async-aws-rspec',
+          key: { pk: 'test' }
+        )
+        expect(result.data).to be_kind_of(Aws::DynamoDB::Types::GetItemOutput)
+      end
+
+      task.wait
+    end
+  end
+end

spec/async/s3_spec.rb

@@ -0,0 +1,18 @@
+require 'async/aws/all'
+
+Async::Aws.configure(connection_limit: 4)
+
+RSpec.describe Async::Aws do
+  it 'should execute s3:ListBuckets action' do
+    Async::Reactor.run do
+      s3 = Aws::S3::Client.new
+
+      task = Async do
+        result = s3.list_buckets
+        expect(result.data).to be_kind_of(Aws::S3::Types::ListBucketsOutput)
+      end
+
+      task.wait
+    end
+  end
+end

spec/async/sqs_spec.rb

@@ -0,0 +1,17 @@
+require 'async/aws/all'
+
+Async::Aws.configure(connection_limit: 4)
+
+RSpec.describe Async::Aws do
+  it 'should execute sqs:ListQueues action' do
+    Async::Reactor.run do
+      task = Async do
+        sqs = Aws::SQS::Client.new
+        result = sqs.list_queues
+        expect(result.data).to be_kind_of(Aws::SQS::Types::ListQueuesResult)
+      end
+
+      task.wait
+    end
+  end
+end

spec/spec_helper.rb

@@ -1,6 +1,7 @@
 require "bundler/setup"
 require 'aws-sdk-s3'
 require 'aws-sdk-dynamodb'
+require 'aws-sdk-sqs'
 require 'async'
 require 'async/clock'
 require 'async/http'