Contents

# frozen_string_literal: true

require "opentracing"
require "active_support/all"
require "action_dispatch"

module Labkit
  module Tracing
    # RackMiddleware is a rack middleware component for
    # instrumenting incoming http requests into a Rails/Rack
    # server
    class RackMiddleware
      include Common

      REQUEST_METHOD = "REQUEST_METHOD"

      def initialize(app)
        @app = app
      end

      def call(env)
        method = env[REQUEST_METHOD]

        context = tracer.extract(OpenTracing::FORMAT_RACK, env)
        tags = { "component" => "rack", "span.kind" => "server", "http.method" => method, "http.url" => self.class.build_sanitized_url_from_env(env) }

        in_tracing_span(operation_name: "http:#{method}", child_of: context, tags: tags) do |span|
          @app.call(env).tap { |status_code, _headers, _body| span.set_tag("http.status_code", status_code) }
        end
      end

      # Generate a sanitized (safe) request URL from the rack environment
      def self.build_sanitized_url_from_env(env)
        request = ::ActionDispatch::Request.new(env)

        original_url = request.original_url
        uri = URI.parse(original_url)
        uri.query = request.filtered_parameters.to_query if uri.query.present?

        uri.to_s
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
gitlab-labkit-0.1.2	lib/labkit/tracing/rack_middleware.rb
gitlab-labkit-0.1.0.pre.1.pre.gcb57c95	lib/labkit/tracing/rack_middleware.rb
gitlab-labkit-0.1.0	lib/labkit/tracing/rack_middleware.rb