fix: appease rubocop whitespace error

Author: hannahramadan

instrumentation/httpx/lib/opentelemetry/instrumentation/httpx/dup/plugin.rb

@@ -13,11 +13,11 @@ module Plugin
           # an OTEL trace.
           module RequestTracer
             module_function
-  
+
             # initializes tracing on the +request+.
             def call(request)
               span = nil
-  
+
               # request objects are reused, when already buffered requests get rerouted to a different
               # connection due to connection issues, or when they already got a response, but need to
               # be retried. In such situations, the original span needs to be extended for the former,
@@ -29,51 +29,51 @@ def call(request)
               # one gets to actually sending the request.
               request.on(:headers) do
                 next if span
-  
+
                 span = initialize_span(request)
               end
-  
+
               request.on(:response) do |response|
                 unless span
                   next unless response.is_a?(::HTTPX::ErrorResponse) && response.error.respond_to?(:connection)
-  
+
                   # handles the case when the +error+ happened during name resolution, which means
                   # that the tracing start point hasn't been triggered yet; in such cases, the approximate
                   # initial resolving time is collected from the connection, and used as span start time,
                   # and the tracing object in inserted before the on response callback is called.
                   span = initialize_span(request, response.error.connection.init_time)
-  
+
                 end
-  
+
                 finish(response, span)
               end
             end
-  
+
             def finish(response, span)
               if response.is_a?(::HTTPX::ErrorResponse)
                 span.record_exception(response.error)
                 span.status = Trace::Status.error(response.error.to_s)
               else
                 span.set_attribute(OpenTelemetry::SemanticConventions::Trace::HTTP_STATUS_CODE, response.status)
                 span.set_attribute('http.response.status_code', response.status)
-  
+
                 if response.status.between?(400, 599)
                   err = ::HTTPX::HTTPError.new(response)
                   span.record_exception(err)
                   span.status = Trace::Status.error(err.to_s)
                 end
               end
-  
+
               span.finish
             end
-  
+
             # return a span initialized with the +@request+ state.
             def initialize_span(request, start_time = ::Time.now)
               verb = request.verb
               uri = request.uri
-  
+
               config = HTTPX::Instrumentation.instance.config
-  
+
               attributes = {
                 OpenTelemetry::SemanticConventions::Trace::HTTP_HOST => uri.host,
                 OpenTelemetry::SemanticConventions::Trace::HTTP_METHOD => verb,
@@ -89,43 +89,43 @@ def initialize_span(request, start_time = ::Time.now)
                 'server.address' => uri.host,
                 'server.port' => uri.port
               }
-  
+
               attributes['url.query'] = uri.query unless uri.query.nil?
               attributes[OpenTelemetry::SemanticConventions::Trace::PEER_SERVICE] = config[:peer_service] if config[:peer_service]
               attributes.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
-  
+
               span = tracer.start_span(verb.to_s, attributes: attributes, kind: :client, start_timestamp: start_time)
-  
+
               OpenTelemetry::Trace.with_span(span) do
                 OpenTelemetry.propagation.inject(request.headers)
               end
-  
+
               span
             rescue StandardError => e
               OpenTelemetry.handle_error(exception: e)
             end
-  
+
             def tracer
               HTTPX::Instrumentation.instance.tracer
             end
           end
-  
+
           # Request patch to initiate the trace on initialization.
           module RequestMethods
             def initialize(*)
               super
-  
+
               RequestTracer.call(self)
             end
           end
-  
+
           # Connection patch to start monitoring on initialization.
           module ConnectionMethods
             attr_reader :init_time
-  
+
             def initialize(*)
               super
-  
+
               @init_time = ::Time.now
             end
           end

instrumentation/httpx/lib/opentelemetry/instrumentation/httpx/old/plugin.rb

@@ -13,11 +13,11 @@ module Plugin
           # an OTEL trace.
           module RequestTracer
             module_function
-  
+
             # initializes tracing on the +request+.
             def call(request)
               span = nil
-  
+
               # request objects are reused, when already buffered requests get rerouted to a different
               # connection due to connection issues, or when they already got a response, but need to
               # be retried. In such situations, the original span needs to be extended for the former,
@@ -29,50 +29,50 @@ def call(request)
               # one gets to actually sending the request.
               request.on(:headers) do
                 next if span
-  
+
                 span = initialize_span(request)
               end
-  
+
               request.on(:response) do |response|
                 unless span
                   next unless response.is_a?(::HTTPX::ErrorResponse) && response.error.respond_to?(:connection)
-  
+
                   # handles the case when the +error+ happened during name resolution, which means
                   # that the tracing start point hasn't been triggered yet; in such cases, the approximate
                   # initial resolving time is collected from the connection, and used as span start time,
                   # and the tracing object in inserted before the on response callback is called.
                   span = initialize_span(request, response.error.connection.init_time)
-  
+
                 end
-  
+
                 finish(response, span)
               end
             end
-  
+
             def finish(response, span)
               if response.is_a?(::HTTPX::ErrorResponse)
                 span.record_exception(response.error)
                 span.status = Trace::Status.error(response.error.to_s)
               else
                 span.set_attribute(OpenTelemetry::SemanticConventions::Trace::HTTP_STATUS_CODE, response.status)
-  
+
                 if response.status.between?(400, 599)
                   err = ::HTTPX::HTTPError.new(response)
                   span.record_exception(err)
                   span.status = Trace::Status.error(err.to_s)
                 end
               end
-  
+
               span.finish
             end
-  
+
             # return a span initialized with the +@request+ state.
             def initialize_span(request, start_time = ::Time.now)
               verb = request.verb
               uri = request.uri
-  
+
               config = HTTPX::Instrumentation.instance.config
-  
+
               attributes = {
                 OpenTelemetry::SemanticConventions::Trace::HTTP_HOST => uri.host,
                 OpenTelemetry::SemanticConventions::Trace::HTTP_METHOD => verb,
@@ -82,42 +82,42 @@ def initialize_span(request, start_time = ::Time.now)
                 OpenTelemetry::SemanticConventions::Trace::NET_PEER_NAME => uri.host,
                 OpenTelemetry::SemanticConventions::Trace::NET_PEER_PORT => uri.port
               }
-  
+
               attributes[OpenTelemetry::SemanticConventions::Trace::PEER_SERVICE] = config[:peer_service] if config[:peer_service]
               attributes.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
-  
+
               span = tracer.start_span("HTTP #{verb}", attributes: attributes, kind: :client, start_timestamp: start_time)
-  
+
               OpenTelemetry::Trace.with_span(span) do
                 OpenTelemetry.propagation.inject(request.headers)
               end
-  
+
               span
             rescue StandardError => e
               OpenTelemetry.handle_error(exception: e)
             end
-  
+
             def tracer
               HTTPX::Instrumentation.instance.tracer
             end
           end
-  
+
           # Request patch to initiate the trace on initialization.
           module RequestMethods
             def initialize(*)
               super
-  
+
               RequestTracer.call(self)
             end
           end
-  
+
           # Connection patch to start monitoring on initialization.
           module ConnectionMethods
             attr_reader :init_time
-  
+
             def initialize(*)
               super
-  
+
               @init_time = ::Time.now
             end
           end

instrumentation/httpx/lib/opentelemetry/instrumentation/httpx/stable/plugin.rb

@@ -13,11 +13,11 @@ module Plugin
           # an OTEL trace.
           module RequestTracer
             module_function
-  
+
             # initializes tracing on the +request+.
             def call(request)
               span = nil
-  
+
               # request objects are reused, when already buffered requests get rerouted to a different
               # connection due to connection issues, or when they already got a response, but need to
               # be retried. In such situations, the original span needs to be extended for the former,
@@ -29,50 +29,50 @@ def call(request)
               # one gets to actually sending the request.
               request.on(:headers) do
                 next if span
-  
+
                 span = initialize_span(request)
               end
-  
+
               request.on(:response) do |response|
                 unless span
                   next unless response.is_a?(::HTTPX::ErrorResponse) && response.error.respond_to?(:connection)
-  
+
                   # handles the case when the +error+ happened during name resolution, which means
                   # that the tracing start point hasn't been triggered yet; in such cases, the approximate
                   # initial resolving time is collected from the connection, and used as span start time,
                   # and the tracing object in inserted before the on response callback is called.
                   span = initialize_span(request, response.error.connection.init_time)
-  
+
                 end
-  
+
                 finish(response, span)
               end
             end
-  
+
             def finish(response, span)
               if response.is_a?(::HTTPX::ErrorResponse)
                 span.record_exception(response.error)
                 span.status = Trace::Status.error(response.error.to_s)
               else
                 span.set_attribute('http.response.status_code', response.status)
-  
+
                 if response.status.between?(400, 599)
                   err = ::HTTPX::HTTPError.new(response)
                   span.record_exception(err)
                   span.status = Trace::Status.error(err.to_s)
                 end
               end
-  
+
               span.finish
             end
-  
+
             # return a span initialized with the +@request+ state.
             def initialize_span(request, start_time = ::Time.now)
               verb = request.verb
               uri = request.uri
-  
+
               config = HTTPX::Instrumentation.instance.config
-  
+
               attributes = {
                 OpenTelemetry::SemanticConventions::Trace::HTTP_HOST => uri.host,
                 'http.request.method' => verb,
@@ -85,39 +85,39 @@ def initialize_span(request, start_time = ::Time.now)
               attributes['url.query'] = uri.query unless uri.query.nil?
               attributes[OpenTelemetry::SemanticConventions::Trace::PEER_SERVICE] = config[:peer_service] if config[:peer_service]
               attributes.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
-  
+
               span = tracer.start_span(verb.to_s, attributes: attributes, kind: :client, start_timestamp: start_time)
-  
+
               OpenTelemetry::Trace.with_span(span) do
                 OpenTelemetry.propagation.inject(request.headers)
               end
-  
+
               span
             rescue StandardError => e
               OpenTelemetry.handle_error(exception: e)
             end
-  
+
             def tracer
               HTTPX::Instrumentation.instance.tracer
             end
           end
-  
+
           # Request patch to initiate the trace on initialization.
           module RequestMethods
             def initialize(*)
               super
-  
+
               RequestTracer.call(self)
             end
           end
-  
+
           # Connection patch to start monitoring on initialization.
           module ConnectionMethods
             attr_reader :init_time
-  
+
             def initialize(*)
               super
-  
+
               @init_time = ::Time.now
             end
           end