1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
# Licensed to Elasticsearch B.V. under one or more contributor
# license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright
# ownership. Elasticsearch B.V. licenses this file to you under
# the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
require 'test_helper'
class Elasticsearch::Transport::Transport::ClientIntegrationTest < Elasticsearch::Test::IntegrationTestCase
startup do
Elasticsearch::Extensions::Test::Cluster.start(number_of_nodes: 2) if ENV['SERVER'] and not Elasticsearch::Extensions::Test::Cluster.running?(number_of_nodes: 2)
end
shutdown do
Elasticsearch::Extensions::Test::Cluster.stop(number_of_nodes: 2) if ENV['SERVER'] and Elasticsearch::Extensions::Test::Cluster.running?(number_of_nodes: 2)
end
context "Transport" do
setup do
@host, @port = ELASTICSEARCH_HOSTS.first.split(':')
@hosts = { hosts: [ { host: @host, port: @port } ] }
end
should "use the default Faraday adapter" do
transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new(@hosts) do |f|
f.response :logger
end
client = Elasticsearch::Transport::Client.new transport: transport
assert_equal(client.transport.connections.first.connection.adapter, Faraday::Adapter::NetHttp)
client.perform_request 'GET', ''
end
unless jruby?
should "allow to customize the Faraday adapter to Typhoeus" do
if is_faraday_v2?
require 'faraday/typhoeus'
else
require '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
assert_equal(client.transport.connections.first.connection.adapter, Faraday::Adapter::Typhoeus)
client.perform_request 'GET', ''
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
client = Elasticsearch::Transport::Client.new transport: transport
assert_equal(client.transport.class, Elasticsearch::Transport::Transport::HTTP::Curb)
client.perform_request 'GET', ''
end
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
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
should 'allow to customize the Faraday adapter to Patron' do
if is_faraday_v2?
require 'faraday/patron'
else
require 'patron'
end
transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new(@hosts) do |f|
f.response :logger
f.adapter :patron
end
client = Elasticsearch::Transport::Client.new(transport: transport)
assert_equal(client.transport.connections.first.connection.adapter, Faraday::Adapter::Patron)
client.perform_request 'GET', ''
end
should "allow to customize the Faraday adapter to NetHttpPersistent" do
require 'faraday/net_http_persistent'
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
assert_equal(client.transport.connections.first.connection.adapter, Faraday::Adapter::NetHttpPersistent)
client.perform_request 'GET', ''
end
should 'allow to customize the Faraday adapter to HTTPClient' do
require 'faraday/httpclient'
transport = Elasticsearch::Transport::Transport::HTTP::Faraday.new(@hosts) do |f|
f.response :logger
f.adapter :httpclient
end
client = Elasticsearch::Transport::Client.new(transport: transport)
assert_equal(client.transport.connections.first.connection.adapter, Faraday::Adapter::HTTPClient)
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' } } }
)
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
end
end
end
|
