sharpetronics/httpx
1
0
Fork 0
mirror of https://github.com/HoneyryderChuck/httpx.git synced 2025-10-05 00:02:38 -04:00
Code Issues Projects Releases Wiki Activity

improve HTTP/1 log messages

Browse Source
This commit is contained in:
HoneyryderChuck 2017-12-18 13:43:09 +02:00
parent 37f97005fb
commit eccea7c443
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/httpx/channel/http1.rb
View File

@ -73,8 +73,8 @@ module HTTPX
log { "headers received" } log { "headers received" }
headers = @options.headers_class.new(h) headers = @options.headers_class.new(h)
response = @options.response_class.new(@requests.last, @parser.status_code, headers, @options) response = @options.response_class.new(@requests.last, @parser.status_code, headers, @options)
log { "#{response.status} HTTP/#{@parser.http_version.join(".")}" } log { "-> HEADLINE: #{response.status} HTTP/#{@parser.http_version.join(".")}" }
log { response.headers.each.map { |f, v| "-> #{f}: #{v}" }.join("\n") } log { response.headers.each.map { |f, v| "-> HEADER: #{f}: #{v}" }.join("\n") }
request.response = response request.response = response
# parser can't say if it's parsing GET or HEAD, # parser can't say if it's parsing GET or HEAD,
@ -83,7 +83,7 @@ module HTTPX
end end
def on_body(chunk) def on_body(chunk)
log { "-> #{chunk.inspect}" } log { "-> DATA: #{chunk.bytesize} bytes..." }
@requests.last.response << chunk @requests.last.response << chunk
end end
@ -128,12 +128,12 @@ module HTTPX
request.headers["host"] ||= request.authority request.headers["host"] ||= request.authority
buffer = +"" buffer = +""
buffer << "#{request.verb.to_s.upcase} #{request.path} HTTP/#{@version.join(".")}" << CRLF buffer << "#{request.verb.to_s.upcase} #{request.path} HTTP/#{@version.join(".")}" << CRLF
log { "<- #{buffer.chomp.inspect}" } log { "<- HEADLINE: #{buffer.chomp.inspect}" }
@buffer << buffer @buffer << buffer
buffer.clear buffer.clear
request.headers.each do |field, value| request.headers.each do |field, value|
buffer << "#{capitalized(field)}: #{value}" << CRLF buffer << "#{capitalized(field)}: #{value}" << CRLF
log { "<- #{buffer.chomp.inspect}" } log { "<- HEADER: #{buffer.chomp.inspect}" }
@buffer << buffer @buffer << buffer
buffer.clear buffer.clear
end end
@ -144,7 +144,7 @@ module HTTPX
def join_body(request) def join_body(request)
return if request.empty? return if request.empty?
while chunk = request.drain_body while chunk = request.drain_body
log { "<- #{chunk.inspect}" } log { "<- DATA: #{chunk.bytesize} bytes..." }
@buffer << chunk @buffer << chunk
throw(:buffer_full, request) if @buffer.full? throw(:buffer_full, request) if @buffer.full?
end end