Gemfile

@@ -16,7 +16,7 @@ group :test do
   gem "minitest"
   gem "minitest-proveit"
   gem "ruby-ntlm"
-  gem "sentry-ruby" if RUBY_VERSION >= "2.4.0"
+  gem "sentry-ruby" if RUBY_VERSION >= "2.4"
   gem "spy"
   if RUBY_VERSION < "2.3.0"
     gem "webmock", "< 3.15.0"
@@ -25,16 +25,16 @@ group :test do
   end
   gem "websocket-driver"
 
-  gem "net-ssh", "~> 4.2.0" if RUBY_VERSION < "2.2.0"
+  gem "net-ssh", "~> 4.2.0" if RUBY_VERSION < "2.2"
 
-  if RUBY_VERSION >= "2.3.0"
+  if RUBY_VERSION >= "2.3"
     gem "ddtrace"
   else
-    gem "ddtrace", "< 1.0.0"
+    gem "ddtrace", "< 1.0"
   end
 
   platform :mri do
-    if RUBY_VERSION >= "2.3.0"
+    if RUBY_VERSION >= "2.3"
       gem "google-protobuf", "< 3.19.2" if RUBY_VERSION < "2.5.0"
       gem "grpc"
       gem "logging"
@@ -42,12 +42,6 @@ group :test do
       gem "mimemagic", require: false
       gem "ruby-filemagic", require: false
     end
-
-    if RUBY_VERSION >= "3.0.0"
-      gem "multi_json", require: false
-      gem "oj", require: false
-      gem "yajl-ruby", require: false
-    end
   end
 
   platform :mri, :truffleruby do
@@ -63,7 +57,7 @@ group :test do
   end
 
   platform :mri_23 do
-    if RUBY_VERSION >= "2.3.0"
+    if RUBY_VERSION >= "2.3"
       gem "openssl", "< 2.0.6" # force usage of openssl version we patch against
     end
     gem "msgpack", "<= 1.3.3"
@@ -89,7 +83,7 @@ group :test do
 end
 
 group :coverage do
-  if RUBY_VERSION < "2.2.0"
+  if RUBY_VERSION < "2.2"
     gem "simplecov", "< 0.11.0"
   elsif RUBY_VERSION < "2.3"
     gem "simplecov", "< 0.11.0"
@@ -115,14 +109,14 @@ group :website do
 end if RUBY_VERSION > "2.4"
 
 group :assorted do
-  if RUBY_VERSION < "2.2.0"
+  if RUBY_VERSION < "2.2"
     gem "pry", "~> 0.12.2"
   else
     gem "pry"
   end
 
   platform :mri do
-    if RUBY_VERSION < "2.2.0"
+    if RUBY_VERSION < "2.2"
       gem "pry-byebug", "~> 3.4.3"
     else
       gem "debug" if RUBY_VERSION >= "3.1.0"

lib/httpx/plugins/multipart/decoder.rb

@@ -61,7 +61,7 @@ module HTTPX::Plugins
         @state = :idle
       end
 
-      def call(response, *)
+      def call(response, _)
         response.body.each do |chunk|
           @buffer << chunk
 

lib/httpx/resolver/https.rb

@@ -102,7 +102,7 @@ module HTTPX
         @requests[request] = hostname
         resolver_connection.send(request)
         @connections << connection
-      rescue ResolveError, Resolv::DNS::EncodeError => e
+      rescue ResolveError, Resolv::DNS::EncodeError, JSON::JSONError => e
         @queries.delete(hostname)
         emit_resolve_error(connection, connection.origin.host, e)
       end
@@ -129,7 +129,7 @@ module HTTPX
     def parse(request, response)
       begin
         answers = decode_response_body(response)
-      rescue Resolv::DNS::DecodeError => e
+      rescue Resolv::DNS::DecodeError, JSON::JSONError => e
         host, connection = @queries.first
         @queries.delete(host)
         emit_resolve_error(connection, connection.origin.host, e)
@@ -203,6 +203,11 @@ module HTTPX
 
     def decode_response_body(response)
       case response.headers["content-type"]
+      when "application/dns-json",
+           "application/json",
+           %r{^application/x-javascript} # because google...
+        payload = JSON.parse(response.to_s)
+        payload["Answer"]
       when "application/dns-udpwireformat",
            "application/dns-message"
         Resolver.decode_dns_answer(response.to_s)

lib/httpx/response.rb

@@ -76,8 +76,8 @@ module HTTPX
       raise err
     end
 
-    def json(*args)
+    def json(options = nil)
-      decode("json", *args)
+      decode("json", options)
     end
 
     def form
@@ -86,7 +86,7 @@ module HTTPX
 
     private
 
-    def decode(format, *args)
+    def decode(format, options = nil)
       # TODO: check if content-type is a valid format, i.e. "application/json" for json parsing
       transcoder = Transcoder.registry(format)
 
@@ -96,7 +96,7 @@ module HTTPX
 
       raise Error, "no decoder available for \"#{format}\"" unless decoder
 
-      decoder.call(self, *args)
+      decoder.call(self, options)
     rescue Registry::Error
       raise Error, "no decoder available for \"#{format}\""
     end

lib/httpx/transcoder/form.rb

@@ -36,7 +36,7 @@ module HTTPX::Transcoder
     module Decoder
       module_function
 
-      def call(response, *)
+      def call(response, _)
         URI.decode_www_form(response.to_s).each_with_object({}) do |(field, value), params|
           HTTPX::Transcoder.normalize_query(params, field, value, PARAM_DEPTH_LIMIT)
         end

lib/httpx/transcoder/json.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 require "forwardable"
+require "json"
 
 module HTTPX::Transcoder
   module JSON
@@ -18,7 +19,7 @@ module HTTPX::Transcoder
       def_delegator :@raw, :bytesize
 
       def initialize(json)
-        @raw = JSON.json_dump(json)
+        @raw = ::JSON.dump(json)
         @charset = @raw.encoding.name.downcase
       end
 
@@ -36,25 +37,8 @@ module HTTPX::Transcoder
 
       raise HTTPX::Error, "invalid json mime type (#{content_type})" unless JSON_REGEX.match?(content_type)
 
-      method(:json_load)
+      ::JSON.method(:parse)
     end
-
-    # rubocop:disable Style/SingleLineMethods
-    if defined?(MultiJson)
-      def json_load(*args); MultiJson.load(*args); end
-      def json_dump(*args); MultiJson.dump(*args); end
-    elsif defined?(Oj)
-      def json_load(response, *args); Oj.load(response.to_s, *args); end
-      def json_dump(*args); Oj.dump(*args); end
-    elsif defined?(Yajl)
-      def json_load(response, *args); Yajl::Parser.new(*args).parse(response.to_s); end
-      def json_dump(*args); Yajl::Encoder.encode(*args); end
-    else
-      require "json"
-      def json_load(*args); ::JSON.parse(*args); end
-      def json_dump(*args); ::JSON.dump(*args); end
-    end
-    # rubocop:enable Style/SingleLineMethods
   end
   register "json", JSON
 end

sig/plugins/multipart.rbs

@@ -61,7 +61,7 @@ module HTTPX
         @boundary: String
         @intermediate_boundary: String
 
-        def call: (Response response, *untyped) -> Hash[String, untyped]
+        def call: (Response response, untyped) -> Hash[String, untyped]
 
         private
 

sig/transcoder.rbs

@@ -22,7 +22,7 @@ module HTTPX
     end
 
     interface _Decoder
-      def call: (Response response, *untyped) -> untyped
+      def call: (Response response, untyped options) -> untyped
     end
   end
 end

sig/transcoder/json.rbs

@@ -5,9 +5,6 @@ module HTTPX::Transcoder
     def self?.encode: (_ToJson json) -> Encoder
     def self?.decode: (HTTPX::Response response) -> _Decoder
 
-    def self?.json_load: (string source, ?json_options) -> untyped
-    def self?.json_dump: (_ToJson obj, *untyped) -> String
-
     class Encoder
       extend Forwardable
       include _Encoder

standalone_tests/response_json_multi_json_test.rb

@@ -1,27 +0,0 @@
-# frozen_string_literal: true
-
-require "multi_json"
-require "test_helper"
-
-class ResponseYajlTest < Minitest::Test
-  include HTTPX
-
-  def test_response_decoders
-    json_response = Response.new(request, 200, "2.0", { "content-type" => "application/json" })
-    json_response << %({"a": "b"})
-    assert json_response.json == { "a" => "b" }
-    assert json_response.json(symbolize_keys: true) == { :a => "b" }
-    json_response << "bogus"
-    assert_raises(MultiJson::ParseError) { json_response.json }
-  end
-
-  private
-
-  def request(verb = :get, uri = "http://google.com")
-    Request.new(verb, uri)
-  end
-
-  def response(*args)
-    Response.new(*args)
-  end
-end

standalone_tests/response_json_oj_test.rb

@@ -1,27 +0,0 @@
-# frozen_string_literal: true
-
-require "oj"
-require "test_helper"
-
-class ResponseOjTest < Minitest::Test
-  include HTTPX
-
-  def test_response_decoders
-    json_response = Response.new(request, 200, "2.0", { "content-type" => "application/json" })
-    json_response << %({"a": "b"})
-    assert json_response.json == { "a" => "b" }
-    assert json_response.json(symbol_keys: true) == { :a => "b" }
-    json_response << "bogus"
-    assert_raises(Oj::ParseError) { json_response.json }
-  end
-
-  private
-
-  def request(verb = :get, uri = "http://google.com")
-    Request.new(verb, uri)
-  end
-
-  def response(*args)
-    Response.new(*args)
-  end
-end

standalone_tests/response_json_yajl_test.rb

@@ -1,27 +0,0 @@
-# frozen_string_literal: true
-
-require "yajl"
-require "test_helper"
-
-class ResponseYajlTest < Minitest::Test
-  include HTTPX
-
-  def test_response_decoders
-    json_response = Response.new(request, 200, "2.0", { "content-type" => "application/json" })
-    json_response << %({"a": "b"})
-    assert json_response.json == { "a" => "b" }
-    assert json_response.json(symbolize_keys: true) == { :a => "b" }
-    json_response << "bogus"
-    assert_raises(Yajl::ParseError) { json_response.json }
-  end
-
-  private
-
-  def request(verb = :get, uri = "http://google.com")
-    Request.new(verb, uri)
-  end
-
-  def response(*args)
-    Response.new(*args)
-  end
-end