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
|
require 'webrick'
begin
require "webrick/https"
rescue LoadError
# SSL features cannot be tested
end
require 'webrick/httpservlet/abstract'
module TestNetHTTPUtils
def start(&block)
new().start(&block)
end
def new
klass = Net::HTTP::Proxy(config('proxy_host'), config('proxy_port'))
http = klass.new(config('host'), config('port'))
http.set_debug_output logfile()
http
end
def config(key)
self.class::CONFIG[key]
end
def logfile
$DEBUG ? $stderr : NullWriter.new
end
def setup
spawn_server
end
def teardown
@server.shutdown
until @server.status == :Stop
sleep 0.1
end
# resume global state
Net::HTTP.version_1_2
end
def spawn_server
server_config = {
:BindAddress => config('host'),
:Port => config('port'),
:Logger => WEBrick::Log.new(NullWriter.new),
:AccessLog => [],
:ShutdownSocketWithoutClose => true,
:ServerType => Thread,
}
if defined?(OpenSSL) and config('ssl_enable')
server_config.update({
:SSLEnable => true,
:SSLCertificate => config('ssl_certificate'),
:SSLPrivateKey => config('ssl_private_key'),
})
end
@server = WEBrick::HTTPServer.new(server_config)
@server.mount('/', Servlet)
@server.start
n_try_max = 5
begin
TCPSocket.open(config('host'), config('port')).close
rescue Errno::ECONNREFUSED
sleep 0.2
n_try_max -= 1
raise 'cannot spawn server; give up' if n_try_max < 0
retry
end
end
$test_net_http = nil
$test_net_http_data = (0...256).to_a.map {|i| i.chr }.join('') * 64
$test_net_http_data_type = 'application/octet-stream'
class Servlet < WEBrick::HTTPServlet::AbstractServlet
def do_GET(req, res)
res['Content-Type'] = $test_net_http_data_type
res.body = $test_net_http_data
end
# echo server
def do_POST(req, res)
res['Content-Type'] = req['Content-Type']
res.body = req.body
end
end
class NullWriter
def <<(s) end
def puts(*args) end
def print(*args) end
def printf(*args) end
end
end
|
