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
|
# File 'lib/kontena/debug_instrumentor.rb', line 4
def self.instrument(name, params = {}, &block)
result = []
params = params.dup
direction = name.split('.').last.capitalize
if direction == 'Request'
uri = URI.parse("#{params[:scheme]}://#{params[:host]}:#{params[:port]}")
uri.path = params[:path].nil? ? '/' : params[:path].split('?', 2).first
uri.query = URI.encode_www_form(params[:query]) if params[:query] && !params[:query].empty?
str = "#{params[:method].to_s.upcase} #{uri}"
str << " (ssl_verify: #{params[:ssl_verify_peer]}) " if params[:scheme] == 'https'
result << str
end
if params[:headers]
str = "Headers: {"
heads = []
heads << "Accept: #{params[:headers]['Accept']}" if params[:headers]['Accept']
heads << "Accept-Encoding: #{params[:headers]['Accept-Encoding']}" if params[:headers]['Accept-Encoding']
heads << "Content-Type: #{params[:headers]['Content-Type']}" if params[:headers]['Content-Type']
heads << "Content-Encoding: #{params[:headers]['Content-Encoding']}" if params[:headers]['Content-Encoding']
heads << "Authorization: #{params[:headers]['Authorization'].split(' ', 2).first}" if params[:headers]['Authorization']
heads << "X-Kontena-Version: #{params[:headers]['X-Kontena-Version']}" if params[:headers]['X-Kontena-Version']
str << heads.join(', ')
str << "} "
result << str
end
if params[:status]
str = "Status: "
if params[:status] < 299
str << Kontena.pastel.green(params[:status])
else
str << Kontena.pastel.red(params[:status])
end
result << str
end
if params[:body] && !params[:body].empty?
if params[:headers]['Content-Encoding'].to_s =~ /gzip/
body_content = Zlib::GzipReader.new(StringIO.new(params[:body])).read
body = "(GZIPPED 1:%d) %s" % [body_content.bytesize / params[:body].bytesize, body_content]
else
body = params[:body]
end
str = "Body: "
if ENV["DEBUG"] == "api"
str << "\n"
str << body
else
body = body.inspect.strip
str << body[0,80]
if body.length > 80
str << "...\""
end
end
result << str
elsif params[:error]
result << params[:error]
end
color = case direction
when 'Request' then :blue
when 'Response' then :magenta
else :red
end
Kontena.logger.debug("CLIENT") { Kontena.pastel.send(color, "[#{direction}]: #{result.join(" | ")}") }
if block_given?
yield
end
end
|