add swappable uri normalizer feature

#533

.rubocop.yml

@@ -31,10 +31,10 @@ Metrics/ClassLength:
 
 # TODO: Lower to 6
 Metrics/CyclomaticComplexity:
-  Max: 8
+  Max: 9
 
 Metrics/PerceivedComplexity:
-  Max: 8
+  Max: 9
 
 # TODO: Lower to 80
 Metrics/LineLength:

lib/http/client.rb

@@ -43,13 +43,15 @@ def build_request(verb, uri, opts = {}) # rubocop:disable Style/OptionHash
       headers = make_request_headers(opts)
       body    = make_request_body(opts, headers)
       proxy   = opts.proxy
+      normalize_uri = opts.features[:normalize_uri]&.method(:normalize_uri)
 
       req = HTTP::Request.new(
         :verb         => verb,
         :uri          => uri,
         :headers      => headers,
         :proxy        => proxy,
-        :body         => body
+        :body         => body,
+        :normalize_uri => normalize_uri
       )
 
       opts.features.inject(req) do |request, (_name, feature)|

lib/http/feature.rb

@@ -20,3 +20,4 @@ def wrap_response(response)
 require "http/features/auto_deflate"
 require "http/features/logging"
 require "http/features/instrumentation"
+require "http/features/normalize_uri"

lib/http/features/auto_deflate.rb

@@ -32,7 +32,8 @@ def wrap_request(request)
           :uri => request.uri,
           :headers => request.headers,
           :proxy => request.proxy,
-          :body => deflated_body(request.body)
+          :body => deflated_body(request.body),
+          :normalize_uri => request.normalize_uri
         )
       end
 

lib/http/features/normalize_uri.rb

@@ -0,0 +1,25 @@
+# frozen_string_literal: true
+
+module HTTP
+  module Features
+    class NormalizeUri < Feature
+      attr_reader :normalizer
+
+      def initialize(normalizer: Normalizer)
+        @normalizer = normalizer
+      end
+
+      def normalize_uri(uri)
+        normalizer.call(uri)
+      end
+
+      module Normalizer
+        def self.call(uri)
+          HTTP::URI::NORMALIZER.call(uri)
+        end
+      end
+
+      HTTP::Options.register_feature(:normalize_uri, self)
+    end
+  end
+end

lib/http/request.rb

@@ -66,20 +66,24 @@ class UnsupportedSchemeError < RequestError; end
     # Scheme is normalized to be a lowercase symbol e.g. :http, :https
     attr_reader :scheme
 
+    attr_reader :normalize_uri
+
     # "Request URI" as per RFC 2616
     # http://www.w3.org/Protocols/rfc2616/rfc2616-sec5.html
     attr_reader :uri
     attr_reader :proxy, :body, :version
 
     # @option opts [String] :version
     # @option opts [#to_s] :verb HTTP request method
+    # @option opts [#to_s] :normalize_uri
     # @option opts [HTTP::URI, #to_s] :uri
     # @option opts [Hash] :headers
     # @option opts [Hash] :proxy
     # @option opts [String, Enumerable, IO, nil] :body
     def initialize(opts)
       @verb   = opts.fetch(:verb).to_s.downcase.to_sym
-      @uri    = normalize_uri(opts.fetch(:uri))
+      normalizer = opts.fetch(:normalize_uri, nil) || HTTP::URI::NORMALIZER
+      @uri = normalizer.call(opts.fetch(:uri))
       @scheme = @uri.scheme.to_s.downcase.to_sym if @uri.scheme
 
       raise(UnsupportedMethodError, "unknown method: #{verb}") unless METHODS.include?(@verb)
@@ -212,18 +216,5 @@ def port
     def default_host_header_value
       PORTS[@scheme] != port ? "#{host}:#{port}" : host
     end
-
-    # @return [HTTP::URI] URI with all componentes but query being normalized.
-    def normalize_uri(uri)
-      uri = HTTP::URI.parse uri
-
-      HTTP::URI.new(
-        :scheme     => uri.normalized_scheme,
-        :authority  => uri.normalized_authority,
-        :path       => uri.normalized_path,
-        :query      => uri.query,
-        :fragment   => uri.normalized_fragment
-      )
-    end
   end
 end

lib/http/uri.rb

@@ -26,6 +26,17 @@ class URI
     # @private
     HTTPS_SCHEME = "https"
 
+    NORMALIZER = lambda do |uri|
+      uri = HTTP::URI.parse uri
+      HTTP::URI.new(
+        :scheme     => uri.normalized_scheme,
+        :authority  => uri.normalized_authority,
+        :path       => uri.normalized_path,
+        :query      => uri.query,
+        :fragment   => uri.normalized_fragment
+      )
+    end
+
     # Parse the given URI string, returning an HTTP::URI object
     #
     # @param [HTTP::URI, String, #to_str] uri to parse

spec/lib/http_spec.rb

@@ -430,6 +430,26 @@ def setsockopt(*args)
         expect(response.to_s).to eq("#{body}-deflated")
       end
     end
+
+    context "with :normalize_uri" do
+      it "normalizes URI" do
+        response = HTTP.get "#{dummy.endpoint}/hello world"
+        expect(response.to_s).to eq("hello world")
+      end
+
+      it "uses the custom URI Normalizer method" do
+        client = HTTP.use(:normalize_uri => {:normalizer => :itself.to_proc})
+        response = client.get("#{dummy.endpoint}/hello world")
+        expect(response.status).to eq(400)
+      end
+
+      it "uses the default URI normalizer" do
+        client = HTTP.use :normalize_uri
+        expect(HTTP::URI::NORMALIZER).to receive(:call).and_call_original
+        response = client.get("#{dummy.endpoint}/hello world")
+        expect(response.to_s).to eq("hello world")
+      end
+    end
   end
 
   it "unifies socket errors into HTTP::ConnectionError" do

spec/support/dummy_server/servlet.rb

@@ -148,6 +148,11 @@ def do_#{method.upcase}(req, res)
       res.body   = req.body
     end
 
+    get "/hello world" do |_req, res|
+      res.status = 200
+      res.body   = "hello world"
+    end
+
     post "/encoded-body" do |req, res|
       res.status = 200