mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
010e246756
Some methods were added to public API in
5b14129d8d and they should be not part of
the public API.
78 lines
2.3 KiB
Ruby
78 lines
2.3 KiB
Ruby
require "active_support/core_ext/time/conversions"
|
|
require "active_support/core_ext/object/blank"
|
|
require "active_support/log_subscriber"
|
|
require "action_dispatch/http/request"
|
|
require "rack/body_proxy"
|
|
|
|
module Rails
|
|
module Rack
|
|
# Sets log tags, logs the request, calls the app, and flushes the logs.
|
|
#
|
|
# Log tags (+taggers+) can be an Array containing: methods that the +request+
|
|
# object responds to, objects that respond to +to_s+ or Proc objects that accept
|
|
# an instance of the +request+ object.
|
|
class Logger < ActiveSupport::LogSubscriber
|
|
def initialize(app, taggers = nil)
|
|
@app = app
|
|
@taggers = taggers || []
|
|
end
|
|
|
|
def call(env)
|
|
request = ActionDispatch::Request.new(env)
|
|
|
|
if logger.respond_to?(:tagged)
|
|
logger.tagged(compute_tags(request)) { call_app(request, env) }
|
|
else
|
|
call_app(request, env)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def call_app(request, env) # :doc:
|
|
instrumenter = ActiveSupport::Notifications.instrumenter
|
|
instrumenter.start "request.action_dispatch", request: request
|
|
logger.info { started_request_message(request) }
|
|
resp = @app.call(env)
|
|
resp[2] = ::Rack::BodyProxy.new(resp[2]) { finish(request) }
|
|
resp
|
|
rescue Exception
|
|
finish(request)
|
|
raise
|
|
ensure
|
|
ActiveSupport::LogSubscriber.flush_all!
|
|
end
|
|
|
|
# Started GET "/session/new" for 127.0.0.1 at 2012-09-26 14:51:42 -0700
|
|
def started_request_message(request) # :doc:
|
|
'Started %s "%s" for %s at %s' % [
|
|
request.request_method,
|
|
request.filtered_path,
|
|
request.ip,
|
|
Time.now.to_default_s ]
|
|
end
|
|
|
|
def compute_tags(request) # :doc:
|
|
@taggers.collect do |tag|
|
|
case tag
|
|
when Proc
|
|
tag.call(request)
|
|
when Symbol
|
|
request.send(tag)
|
|
else
|
|
tag
|
|
end
|
|
end
|
|
end
|
|
|
|
def finish(request)
|
|
instrumenter = ActiveSupport::Notifications.instrumenter
|
|
instrumenter.finish "request.action_dispatch", request: request
|
|
end
|
|
|
|
def logger
|
|
Rails.logger
|
|
end
|
|
end
|
|
end
|
|
end
|