Pick serializer based on the request content type.

Author: Manfred

lib/reynard/context.rb

@@ -31,17 +31,7 @@ def params(params)
     end
 
     def body(data)
-      return unless @request_context.operation
-
-      serialized_body = @specification.build_body(@request_context.operation.node, data)
-      return unless serialized_body
-
-      copy(
-        request: {
-          headers: @request_context.headers.merge(serialized_body.headers),
-          body: serialized_body.to_s
-        }
-      )
+      copy(request: { body: self.class.merge_body(@request_context.body, data) })
     end
 
     def headers(headers)
@@ -55,14 +45,41 @@ def logger(logger)
       )
     end
 
+    def serializer(content_type, serializer)
+      copy(
+        request: {
+          serializers: @request_context.serializers.merge({ content_type => serializer }).compact
+        }
+      )
+    end
+
     def execute
       build_response(build_request.perform)
     end
 
+    def self.merge_body(current, data)
+      case current
+      when NilClass
+        data
+      when Hash
+        current.merge(data)
+      else
+        raise(
+          ArgumentError,
+          "Please assign the request body once, we can't merge #{data.inspect} into " \
+          "#{current.inspect}."
+        )
+      end
+    end
+
     private
 
     def build_request_context
-      RequestContext.new(base_url: @specification.default_base_url, headers: {})
+      RequestContext.new(
+        base_url: @specification.default_base_url,
+        headers: {},
+        serializers: Reynard.serializers.dup
+      )
     end
 
     def build_response_context
@@ -79,7 +96,16 @@ def copy(request: {}, response: {})
     end
 
     def build_request
-      Reynard::Http::Request.new(request_context: @request_context)
+      Reynard::Http::Request.new(
+        request_context: @request_context,
+        serializer_selection: serializer_selection
+      )
+    end
+
+    def serializer_selection
+      @specification
+        .content(@request_context.operation.node)
+        .pick_serializer(@request_context.serializers)
     end
 
     def build_response(http_response)

lib/reynard/http/request.rb

@@ -9,8 +9,9 @@ class Http
     class Request
       attr_reader :uri
 
-      def initialize(request_context:)
+      def initialize(request_context:, serializer_selection:)
         @request_context = request_context
+        @serializer_selection = serializer_selection
         @uri = URI(@request_context.url)
       end
 
@@ -26,17 +27,44 @@ def request_class
       end
 
       def request_headers
-        { 'User-Agent' => Reynard.user_agent }.merge(@request_context.headers || {})
+        {
+          'User-Agent' => Reynard.user_agent
+        }
+          .merge(serializer&.headers || {})
+          .merge(@request_context.headers || {})
       end
 
       def build_request
         request = request_class.new(uri, request_headers)
-        if @request_context.body
-          @request_context.logger&.debug { @request_context.body }
-          request.body = @request_context.body
+        if serializer
+          write_serializer_body(request)
+        elsif @request_context.body
+          write_serializer_params(request)
         end
         request
       end
+
+      def write_serializer_body(request)
+        @request_context.logger&.debug { @request_context.body }
+        request.body = serializer.body
+      end
+
+      def write_serializer_params(request)
+        @request_context.logger&.debug { @request_context.body }
+        request.body = @request_context.body
+      end
+
+      def serializer
+        return @serializer if defined?(@serializer)
+
+        @serializer = build_serializer
+      end
+
+      def build_serializer
+        return nil unless @serializer_selection&.serializer_class
+
+        @serializer_selection.serializer_class.new(data: @request_context.body)
+      end
     end
   end
 end

test/reynard/context_test.rb

@@ -6,7 +6,11 @@ class Reynard
   class ContextTest < Reynard::Test
     def setup
       @specification = Specification.new(filename: fixture_file('openapi/simple.yml'))
-      @request_context = RequestContext.new(base_url: @specification.default_base_url, headers: {})
+      @request_context = RequestContext.new(
+        base_url: @specification.default_base_url,
+        headers: {},
+        serializers: Reynard.serializers.dup
+      )
       @inflector = Inflector.new
       @context = Context.new(
         specification: @specification, inflector: @inflector, request_context: @request_context
@@ -199,12 +203,58 @@ def setup
       assert_equal '200', response.code
       assert_equal [1, 2, 3], response.object.map(&:id)
     end
+
+    test 'uses the first available serializer' do
+      @request_body = nil
+      stub_request(:post, 'http://example.com/v1/books').with do |request|
+        @request_body = request.body
+      end
+      data = { 'name' => 'Parcival' }
+      @context
+        .operation('createBook')
+        .body(data)
+        .execute
+      assert_equal('{"name":"Parcival"}', @request_body)
+    end
+
+    test 'allows users to post as multipart form data' do
+      @request_body = nil
+      stub_request(:post, 'http://example.com/v1/books').with do |request|
+        @request_body = request.body
+      end
+      data = { 'name' => 'Parcival' }
+      @context
+        .serializer('application/json', nil)
+        .operation('createBook')
+        .body(data)
+        .execute
+      assert_includes(@request_body, 'Content-Disposition: form-data')
+    end
+
+    test 'allows users to post as plain text' do
+      @request_body = nil
+      stub_request(:post, 'http://example.com/v1/books').with do |request|
+        @request_body = request.body
+      end
+      data = 'Name: Parcival'
+      @context
+        .serializer('application/json', nil)
+        .serializer('multipart/form-data', nil)
+        .operation('createBook')
+        .body(data)
+        .execute
+      assert_equal(data, @request_body)
+    end
   end
 
   class BareContextTest < Reynard::Test
     def setup
       @specification = Specification.new(filename: fixture_file('openapi/bare.yml'))
-      @request_context = RequestContext.new(base_url: @specification.default_base_url, headers: {})
+      @request_context = RequestContext.new(
+        base_url: @specification.default_base_url,
+        headers: {},
+        serializers: {}
+      )
       @inflector = Inflector.new
       @context = Context.new(
         specification: @specification, inflector: @inflector, request_context: @request_context