Sha256: aacdf8b9232023c8d09782b2698c8cec2c81a740c81adfcecf2eec63230bf831
Contents?: true
Size: 2 KB
Versions: 6
Compression:
Stored size: 2 KB
Contents
require 'faraday'
# @private
module FaradayMiddleware
# @private
class LoudLogger < 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($stdout)
}
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 filter(output)
if ENV['INSTAGRAM_GEM_REDACT']
output = output.to_s.gsub(/client_id=[a-zA-Z0-9]*/,'client_id=[CLIENT-ID]')
output = output.to_s.gsub(/access_token=[a-zA-Z0-9]*/,'access_token=[ACCESS-TOKEN]')
else
output
end
end
def request_info(env)
"Started %s request to: %s" % [ env[:method].to_s.upcase, filter(env[:url]) ]
end
def response_info(env, response_time)
"Response from %s; Status: %d; Time: %.1fms" % [ filter(env[:url]), env[:status], (response_time * 1_000.0) ]
end
def request_debug(env)
debug_message("Request", env[:request_headers], env[:body])
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:
-------------
#{filter(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)} : #{filter(value)}" }.join("\n")
end
end
end
Version data entries
6 entries across 6 versions & 3 rubygems