Merge branch 'DEX-0000-put-query' into 'master'

[DEX-0000] feature: add put query support

Closes DEX-0000

See merge request nstmrt/rubygems/sbmt-strangler!22

CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/)
 and this project adheres to [Semantic Versioning](http://semver.org/).
 
+## [0.9.1] - 2024-07-02
+
+### Added
+- Add put request support
+
 ## [0.9.0] - 2024-06-06
 
 ### Added

lib/sbmt/strangler/http/client.rb

@@ -16,6 +16,9 @@ def call(url, http_verb, payload: {}, headers: {})
             transport.get_request(url, params: payload, headers: prepare_headers(headers))
           when :post
             transport.post_request(url, body: payload, headers: prepare_headers(headers))
+          when :put
+            transport.put_request(url, body: payload, headers: prepare_headers(headers))
+
           else
             raise "unsupported http verb - #{http_verb}"
           end

lib/sbmt/strangler/http/transport.rb

@@ -25,6 +25,13 @@ def post_request(url, body: {}, headers: {})
           end
         end
 
+        def put_request(url, body: {}, headers: {})
+          with_error_handling(url) do
+            response = connection.put(url, body, headers)
+            Success(body: response.body, status: response.status, headers: response.headers)
+          end
+        end
+
         private
 
         attr_reader :http_options
@@ -54,7 +61,7 @@ def with_error_handling(url)
           )
 
           retry if (retry_count += 1) && retry_count <= http_options.retries_count
-  
+
           Failure(status: :bad_gateway)
         rescue Faraday::UnprocessableEntityError, Faraday::ForbiddenError => error
           Failure(body: error.response_body, status: error.response_status, headers: error.response_headers)

lib/sbmt/strangler/version.rb

@@ -2,6 +2,6 @@
 
 module Sbmt
   module Strangler
-    VERSION = "0.9.0"
+    VERSION = "0.9.1"
   end
 end

spec/lib/sbmt/strangler/http/client_spec.rb

@@ -49,5 +49,25 @@
         end
       end
     end
+
+    context "with put request" do
+      let(:url) { "http://example.com/put_request" }
+
+      it "does put_request" do
+        expect(transport).to receive(:put_request).with(url, body: {}, headers: {})
+
+        client.call(url, :put, payload: {})
+      end
+
+      context "with http headers" do
+        let(:headers) { {"HTTP_AUTH_IDENTITY" => "uuid"} }
+
+        it "prepares headers" do
+          expect(transport).to receive(:put_request).with(url, body: {}, headers: {"AUTH-IDENTITY" => "uuid"})
+
+          client.call(url, :put, payload: {}, headers: headers)
+        end
+      end
+    end
   end
 end

spec/lib/sbmt/strangler/http/transport_spec.rb

@@ -41,6 +41,25 @@
     end
   end
 
+  describe "#put_request" do
+    let(:url) { "http://example.com/put_request" }
+    let(:response) { {"key" => "value"} }
+
+    around do |example|
+      VCR.use_cassette("transport_put_success") do
+        example.run
+      end
+    end
+
+    it "does put_request" do
+      result = transport.put_request(url)
+
+      expect(result).to be_success
+      expect(result.value![:body]).to eq(response.to_json)
+      expect(result.value![:status]).to eq(200)
+    end
+  end
+
   context "when TimeoutError" do
     let(:connection) { instance_double(Faraday::Connection) }
     let(:error_class) do