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
|
require 'uri'
require 'openssl'
require 'flipper/version'
module Flipper
module Adapters
class Http
class Client
DEFAULT_HEADERS = {
'Content-Type' => 'application/json',
'Accept' => 'application/json',
'User-Agent' => "Flipper HTTP Adapter v#{VERSION}",
}.freeze
HTTPS_SCHEME = "https".freeze
def initialize(options = {})
@uri = URI(options.fetch(:url))
@headers = DEFAULT_HEADERS.merge(options[:headers] || {})
@basic_auth_username = options[:basic_auth_username]
@basic_auth_password = options[:basic_auth_password]
@read_timeout = options[:read_timeout]
@open_timeout = options[:open_timeout]
@write_timeout = options[:write_timeout]
@debug_output = options[:debug_output]
end
def get(path)
perform Net::HTTP::Get, path, @headers
end
def post(path, body = nil)
perform Net::HTTP::Post, path, @headers, body: body
end
def delete(path, body = nil)
perform Net::HTTP::Delete, path, @headers, body: body
end
private
def perform(http_method, path, headers = {}, options = {})
uri = uri_for_path(path)
http = build_http(uri)
request = build_request(http_method, uri, headers, options)
http.request(request)
end
def uri_for_path(path)
uri = @uri.dup
path_uri = URI(path)
uri.path += path_uri.path
uri.query = "#{uri.query}&#{path_uri.query}" if path_uri.query
uri
end
def build_http(uri)
http = Net::HTTP.new(uri.host, uri.port)
http.read_timeout = @read_timeout if @read_timeout
http.open_timeout = @open_timeout if @open_timeout
apply_write_timeout(http)
http.set_debug_output(@debug_output) if @debug_output
if uri.scheme == HTTPS_SCHEME
http.use_ssl = true
http.verify_mode = OpenSSL::SSL::VERIFY_PEER
end
http
end
def build_request(http_method, uri, headers, options)
body = options[:body]
request = http_method.new(uri.request_uri)
request.initialize_http_header(headers) if headers
request.body = body if body
if @basic_auth_username && @basic_auth_password
request.basic_auth(@basic_auth_username, @basic_auth_password)
end
request
end
def apply_write_timeout(http)
if @write_timeout
if RUBY_VERSION >= '2.6.0'
http.write_timeout = @write_timeout
else
Kernel.warn("Warning: option :write_timeout requires Ruby version 2.6.0 or later")
end
end
end
end
end
end
end
|
