perform_request

in lib/elastic_apm/spies/elasticsearch.rb [41:78]
32 lines of code
5 McCabe index (conditional complexity)

        def perform_request(method, path, *args, &block)
          unless ElasticAPM.current_transaction
            return super(method, path, *args, &block)
          end

          name = format(NAME_FORMAT, method, path)
          statement = []

          statement << { params: args&.[](0) }

          if ElasticAPM.agent.config.capture_elasticsearch_queries
            unless args[1].nil? || args[1].empty?
              body =
                ElasticAPM::Spies::ElasticsearchSpy
                .sanitizer.strip_from(args[1])
              statement << { body: body }
            end
          end

          context = Span::Context.new(
            db: { statement: statement.reduce({}, :merge).to_json },
            destination: {
              service: {
                name: SUBTYPE,
                resource: SUBTYPE,
                type: TYPE
              }
            }
          )

          ElasticAPM.with_span(
            name,
            TYPE,
            subtype: SUBTYPE,
            context: context
          ) { super(method, path, *args, &block) }
        end