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
|
# frozen_string_literal: true
module HTTParty
module Logger
class CurlFormatter #:nodoc:
TAG_NAME = HTTParty.name
OUT = '>'
IN = '<'
attr_accessor :level, :logger
def initialize(logger, level)
@logger = logger
@level = level.to_sym
@messages = []
end
def format(request, response)
@request = request
@response = response
log_request
log_response
logger.public_send level, messages.join("\n")
end
private
attr_reader :request, :response
attr_accessor :messages
def log_request
log_url
log_headers
log_query
log OUT, request.raw_body if request.raw_body
log OUT
end
def log_response
log IN, "HTTP/#{response.http_version} #{response.code}"
log_response_headers
log IN, "\n#{response.body}"
log IN
end
def log_url
http_method = request.http_method.name.split('::').last.upcase
uri = if request.options[:base_uri]
request.options[:base_uri] + request.path.path
else
request.path.to_s
end
log OUT, "#{http_method} #{uri}"
end
def log_headers
return unless request.options[:headers] && request.options[:headers].size > 0
log OUT, 'Headers: '
log_hash request.options[:headers]
end
def log_query
return unless request.options[:query]
log OUT, 'Query: '
log_hash request.options[:query]
end
def log_response_headers
headers = response.respond_to?(:headers) ? response.headers : response
response.each_header do |response_header|
log IN, "#{response_header.capitalize}: #{headers[response_header]}"
end
end
def log_hash(hash)
hash.each { |k, v| log(OUT, "#{k}: #{v}") }
end
def log(direction, line = '')
messages << "[#{TAG_NAME}] [#{current_time}] #{direction} #{line}"
end
def current_time
Time.now.strftime("%Y-%m-%d %H:%M:%S %z")
end
end
end
end
|
