Sha256: 99b7cb475ae906047a0750a325fd5f8819b12c939e4e34282af299cf6db723c8
Contents?: true
Size: 1.15 KB
Versions: 20
Compression:
Stored size: 1.15 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 (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
20 entries across 20 versions & 1 rubygems