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 })
+        }
+      )
+    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: pick_serializer
+      )
+    end
+
+    def pick_serializer
+      @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:)
         @request_context = request_context
+        @serializer = serializer
         @uri = URI(@request_context.url)
       end
 
@@ -26,12 +27,18 @@ def request_class
       end
 
       def request_headers
-        { 'User-Agent' => Reynard.user_agent }.merge(@request_context.headers || {})
+        {
+          'User-Agent' => Reynard.user_agent,
+          'Content-Type' => @serializer&.content_type
+        }.compact.merge(@request_context.headers || {})
       end
 
       def build_request
         request = request_class.new(uri, request_headers)
-        if @request_context.body
+        if @serializer
+          @request_context.logger&.debug { @request_context.body }
+          request.body = @serializer.dump(@request_context.body)
+        elsif @request_context.body
           @request_context.logger&.debug { @request_context.body }
           request.body = @request_context.body
         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,28 @@ def setup
       assert_equal '200', response.code
       assert_equal [1, 2, 3], response.object.map(&:id)
     end
+
+    test 'allows users to override built-in serializers' do
+      stub_request(:post, 'http://example.com/v1/books').and_return(body: '{}')
+      serializer = Mocks::Serializer.new
+      data = { 'name' => 'Parcival' }
+      @context
+        .serializer('application/json', serializer)
+        .operation('createBook')
+        .body(data)
+        .execute
+      assert_equal([data], serializer.data)
+    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