Sha256: 024c1a262f90440ca0b8e6df774879f0ae2baed5a95a284920a62399c280ae6a
Contents?: true
Size: 1.42 KB
Versions: 12
Compression:
Stored size: 1.42 KB
Contents
require 'faraday'
module Ably
module Rest
module Middleware
class Logger < Faraday::Middleware
extend Forwardable
def initialize(app, logger = nil)
super(app)
@logger = logger || begin
require 'logger'
::Logger.new(STDOUT)
end
end
def_delegators :@logger, :debug, :info, :warn, :error, :fatal
def call(env)
debug { "=> URL: #{env.method} #{env.url}, Headers: #{dump_headers env.request_headers}" }
debug { "=> Body: #{body_for(env)}" }
super
end
def on_complete(env)
debug "<= Status: #{env.status}, Headers: #{dump_headers env.response_headers}"
debug "<= Body: #{body_for(env)}"
end
private
def dump_headers(headers)
headers.map { |k, v| "#{k}: #{v.inspect}" }.join(", ")
end
def body_for(env)
return '' if !env.body || env.body.empty?
if env.request_headers['Content-Type'] == 'application/x-msgpack'
MessagePack.unpack(env.body)
else
env.body
end
rescue StandardError
readable_body(env.body)
end
def readable_body(body)
if body.respond_to?(:encoding) && body.encoding == Encoding::ASCII_8BIT
body.unpack('H*')
else
body
end
end
end
end
end
end
Version data entries
12 entries across 12 versions & 2 rubygems