Sha256: 43b6175c8b2c24d9c910c861b25e0f867f2819a0fe9fbcd13dbdabc748508cd3
Contents?: true
Size: 1.28 KB
Versions: 18
Compression:
Stored size: 1.28 KB
Contents
module LogjamAgent
class Middleware
def initialize(app, options={})
@app = app
@options = options
end
def call(env)
request = start_request(env)
result = @app.call(env)
result[1] ||= {}
result
rescue Exception
result = [500, {'Content-Type' => 'text/html'}, ["<html><body><h1>500 Internal Server Error</h1>"]]
ensure
headers = result[1]
headers["X-Logjam-Request-Id"] = request.id
unless (request_action = request.fields[:action]).blank?
headers["X-Logjam-Request-Action"] = request_action
end
unless (caller_id = request.fields[:caller_id]).blank?
headers["X-Logjam-Caller-Id"] = caller_id
end
finish_request(env)
end
private
def start_request(env)
app_name = env["logjam_agent.application_name"] || LogjamAgent.application_name
env_name = env["logjam_agent.environment_name"] || LogjamAgent.environment_name
caller_id = env["HTTP_X_LOGJAM_CALLER_ID"] || ""
caller_action = env["HTTP_X_LOGJAM_ACTION"] || ""
LogjamAgent.start_request(app_name, env_name, :caller_id => caller_id, :caller_action => caller_action)
end
def finish_request(env)
LogjamAgent.finish_request(env["time_bandits.metrics"])
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems