Skip to content

Instantly share code, notes, and snippets.

@danielricecodes
Forked from teamon/instrumentation.rb
Created September 8, 2021 03:45

Revisions

  1. @teamon teamon revised this gist Jun 25, 2014. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion instrumentation.rb
    Original file line number Diff line number Diff line change
    @@ -1,4 +1,4 @@
    # config/instrumentation.rb
    # config/initializers/instrumentation.rb

    # Subscribe to grape request and log with Rails.logger
    ActiveSupport::Notifications.subscribe('grape.request') do |name, starts, ends, notification_id, payload|
  2. @teamon teamon revised this gist Jun 25, 2014. 1 changed file with 26 additions and 0 deletions.
    26 changes: 26 additions & 0 deletions logger.rb
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,26 @@
    # app/controllers/api/logger.rb

    class API::Logger
    def initialize(app)
    @app = app
    end

    def call(env)
    payload = {
    remote_addr: env['REMOTE_ADDR'],
    request_method: env['REQUEST_METHOD'],
    request_path: env['PATH_INFO'],
    request_query: env['QUERY_STRING'],
    x_organization: env['HTTP_X_ORGANIZATION']
    }

    ActiveSupport::Notifications.instrument "grape.request", payload do
    @app.call(env).tap do |response|
    payload[:params] = env["api.endpoint"].params.to_hash
    payload[:params].delete("route_info")
    payload[:params].delete("format")
    payload[:response_status] = response[0]
    end
    end
    end
    end
  3. @teamon teamon created this gist Jun 25, 2014.
    13 changes: 13 additions & 0 deletions instrumentation.rb
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,13 @@
    # config/instrumentation.rb

    # Subscribe to grape request and log with Rails.logger
    ActiveSupport::Notifications.subscribe('grape.request') do |name, starts, ends, notification_id, payload|
    Rails.logger.info '[API] %s %s (%.3f ms) -> %s %s%s' % [
    payload[:request_method],
    payload[:request_path],
    (ends-starts)*1000,
    (payload[:response_status] || "error"),
    payload[:x_organization] ? "| X-Org: #{payload[:x_organization]}" : "",
    payload[:params] ? "| #{payload[:params].inspect}" : ""
    ]
    end