Sha256: 0ce73516ce946ffeeb145b14e3d7d3a1b7becaf9f51ae4e8b1cd14e67185e1ad
Contents?: true
Size: 1.99 KB
Versions: 18
Compression:
Stored size: 1.99 KB
Contents
require 'forwardable'
module Faraday
class Middleware
class DefaultLogger < Faraday::Middleware
extend Forwardable
def_delegators :@logger, :debug, :info, :warn, :error, :fatal
def initialize(app, options = {})
@app = app
@logger = options.fetch(:logger) {
require 'logger'
::Logger.new($stderr)
}
end
def call(env)
start_time = Time.now
info request_info(env)
debug request_debug(env)
@app.call(env).on_complete do
end_time = Time.now
response_time = end_time - start_time
info response_info(env, response_time)
debug response_debug(env)
end
end
private
def request_info(env)
" Started %s request to: %s" % [ env[:method].to_s.upcase, env[:url] ]
end
def response_info(env, response_time)
" Response from %s; Status: %d; Time: %.1fms" % [ env[:url], env[:status], (response_time * 1_000.0) ]
end
def request_debug(env)
request_headers = obfuscate_auth env[:request_headers]
debug_message("Request", request_headers, env[:body])
end
def obfuscate_auth(headers)
headers.dup.tap do |h|
if auth = h["Authorization"]
#display first few and last few characters
h["Authorization"] = "#{auth[0..10]}****#{auth[-4..-1]}"
end
end
end
def response_debug(env)
debug_message("Response", env[:response_headers], env[:body])
end
def debug_message(name, headers, body)
<<-MESSAGE.gsub(/^ +([^ ])/m, ' \\1')
#{name} Headers:
----------------
#{format_headers(headers)}
#{name} Body:
-------------
#{body}
MESSAGE
end
def format_headers(headers)
length = headers.map {|k,v| k.to_s.size }.max
headers.map { |name, value| " #{name.to_s.ljust(length)} : #{value}" }.join("\n")
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems