test/integration/transport_test.rb in elasticsearch-transport-7.14.1.pre vs test/integration/transport_test.rb in elasticsearch-transport-7.14.1

- old
+ new

@@ -27,81 +27,72 @@ end context "Transport" do setup do @host, @port = ELASTICSEARCH_HOSTS.first.split(':') + @hosts = { hosts: [ { host: @host, port: @port } ] } begin; Object.send(:remove_const, :Patron); rescue NameError; end end should "allow to customize the Faraday adapter to Typhoeus" do require 'typhoeus' require 'typhoeus/adapters/faraday' - transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new \ - :hosts => [ { host: @host, port: @port } ] do |f| - f.response :logger - f.adapter :typhoeus - end + transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new(@hosts) do |f| + f.response :logger + f.adapter :typhoeus + end client = Elasticsearch::Transport::Client.new transport: transport client.perform_request 'GET', '' end unless jruby? should "allow to customize the Faraday adapter to NetHttpPersistent" do require 'net/http/persistent' - transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new \ - :hosts => [ { host: @host, port: @port } ] do |f| + transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new(@hosts) do |f| f.response :logger f.adapter :net_http_persistent end client = Elasticsearch::Transport::Client.new transport: transport client.perform_request 'GET', '' end should "allow to define connection parameters and pass them" do - transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new \ - :hosts => [ { host: @host, port: @port } ], - :options => { :transport_options => { - :params => { :format => 'yaml' } - } - } - + transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new( + hosts: [ { host: @host, port: @port } ], + options: { transport_options: { params: { :format => 'yaml' } } } + ) client = Elasticsearch::Transport::Client.new transport: transport response = client.perform_request 'GET', '' assert response.body.start_with?("---\n"), "Response body should be YAML: #{response.body.inspect}" end should "use the Curb client" do require 'curb' require 'elasticsearch/transport/transport/http/curb' + transport = Elasticsearch::Transport::Transport::HTTP::Curb.new(@hosts) do |curl| + curl.verbose = true + end - transport = Elasticsearch::Transport::Transport::HTTP::Curb.new \ - :hosts => [ { host: @host, port: @port } ] do |curl| - curl.verbose = true - end - client = Elasticsearch::Transport::Client.new transport: transport client.perform_request 'GET', '' - end unless JRUBY + end unless jruby? should "deserialize JSON responses in the Curb client" do require 'curb' require 'elasticsearch/transport/transport/http/curb' + transport = Elasticsearch::Transport::Transport::HTTP::Curb.new(@hosts) do |curl| + curl.verbose = true + end - transport = Elasticsearch::Transport::Transport::HTTP::Curb.new \ - :hosts => [ { host: @host, port: @port } ] do |curl| - curl.verbose = true - end - client = Elasticsearch::Transport::Client.new transport: transport response = client.perform_request 'GET', '' assert_respond_to(response.body, :to_hash) assert_not_nil response.body['name'] assert_equal 'application/json', response.headers['content-type'] - end unless JRUBY + end unless jruby? end - end