Add stable and dupe patch files

Author: hannahramadan

instrumentation/http/lib/opentelemetry/instrumentation/http/instrumentation.rb

@@ -21,13 +21,38 @@ class Instrumentation < OpenTelemetry::Instrumentation::Base
         option :span_name_formatter, default: nil, validate: :callable
 
         def patch
-          ::HTTP::Client.prepend(Patches::Client)
-          ::HTTP::Connection.prepend(Patches::Connection)
+          case ENV['OTEL_SEMCONV_STABILITY_OPT_IN']
+          when 'http'
+            patch_stable_semconv
+          when 'http/dup'
+            patch_dupe_semconv
+          else
+            patch_old_semconv
+          end
+        end
+
+        def patch_old_semconv
+          ::HTTP::Client.prepend(Patches::Client::Old)
+          ::HTTP::Connection.prepend(Patches::Connection::Old)
+        end
+
+        def patch_dupe_semconv
+          ::HTTP::Client.prepend(Patches::Client::Dupe)
+          ::HTTP::Connection.prepend(Patches::Connection::Dupe)
+        end
+
+        def patch_stable_semconv
+          ::HTTP::Client.prepend(Patches::Client::Stable)
+          ::HTTP::Connection.prepend(Patches::Connection::Stable)
         end
 
         def require_dependencies
-          require_relative 'patches/client'
-          require_relative 'patches/connection'
+          require_relative 'patches/dupe_semconv_client'
+          require_relative 'patches/dupe_semconv_connection'
+          require_relative 'patches/old_semconv_client'
+          require_relative 'patches/old_semconv_connection'
+          require_relative 'patches/stable_semconv_client'
+          require_relative 'patches/stable_semconv_connection'
         end
       end
     end

instrumentation/http/lib/opentelemetry/instrumentation/http/patches/client.rb

@@ -0,0 +1,80 @@
+# frozen_string_literal: true
+
+# Copyright The OpenTelemetry Authors
+#
+# SPDX-License-Identifier: Apache-2.0
+
+module OpenTelemetry
+  module Instrumentation
+    module HTTP
+      module Patches
+        # Module to prepend to HTTP::Client for instrumentation
+        module Client
+          module Dupe
+            # Constant for the HTTP status range
+            HTTP_STATUS_SUCCESS_RANGE = (100..399)
+
+            def perform(req, options)
+              uri = req.uri
+              request_method = req.verb.to_s.upcase
+              span_name = create_request_span_name(request_method, uri.path)
+
+              attributes = {
+                'http.method' => request_method,
+                'http.request.method' => request_method,
+                'http.scheme' => uri.scheme,
+                'url.scheme' => uri.scheme,
+                'http.target' => uri.path,
+                'url.path' => uri.path,
+                'url.query' => uri.query,
+                'http.url' => "#{uri.scheme}://#{uri.host}",
+                'url.full' => "#{uri.scheme}://#{uri.host}",
+                'net.peer.name' => uri.host,
+                'server.address' => uri.host,
+                'net.peer.port' => uri.port,
+                'server.port' => uri.port
+              }.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
+
+              tracer.in_span(span_name, attributes: attributes, kind: :client) do |span|
+                OpenTelemetry.propagation.inject(req.headers)
+                super.tap do |response|
+                  annotate_span_with_response!(span, response)
+                end
+              end
+            end
+
+            private
+
+            def config
+              OpenTelemetry::Instrumentation::HTTP::Instrumentation.instance.config
+            end
+
+            def annotate_span_with_response!(span, response)
+              return unless response&.status
+
+              status_code = response.status.to_i
+              span.set_attribute('http.status_code', status_code)
+              span.set_attribute('http.response.status_code', status_code)
+              span.status = OpenTelemetry::Trace::Status.error unless HTTP_STATUS_SUCCESS_RANGE.cover?(status_code)
+            end
+
+            def create_request_span_name(request_method, request_path)
+              if (implementation = config[:span_name_formatter])
+                updated_span_name = implementation.call(request_method, request_path)
+                updated_span_name.is_a?(String) ? updated_span_name : "HTTP #{request_method}"
+              else
+                "HTTP #{request_method}"
+              end
+            rescue StandardError
+              "HTTP #{request_method}"
+            end
+
+            def tracer
+              HTTP::Instrumentation.instance.tracer
+            end
+          end
+        end
+      end
+    end
+  end
+end

instrumentation/http/lib/opentelemetry/instrumentation/http/patches/connection.rb

@@ -0,0 +1,37 @@
+# frozen_string_literal: true
+
+# Copyright The OpenTelemetry Authors
+#
+# SPDX-License-Identifier: Apache-2.0
+
+module OpenTelemetry
+  module Instrumentation
+    module HTTP
+      module Patches
+        # Module to prepend to HTTP::Connection for instrumentation
+        module Connection
+          module Dupe
+            def initialize(req, options)
+              attributes = {
+                'net.peer.name' => req.uri.host,
+                'server.address' => req.uri.host,
+                'net.peer.port' => req.uri.port,
+                'server.port' => req.uri.port
+              }.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
+
+              tracer.in_span('HTTP CONNECT', attributes: attributes) do
+                super
+              end
+            end
+
+            private
+
+            def tracer
+              HTTP::Instrumentation.instance.tracer
+            end
+          end
+        end
+      end
+    end
+  end
+end

instrumentation/http/lib/opentelemetry/instrumentation/http/patches/dupe_semconv_client.rb

@@ -0,0 +1,72 @@
+# frozen_string_literal: true
+
+# Copyright The OpenTelemetry Authors
+#
+# SPDX-License-Identifier: Apache-2.0
+
+module OpenTelemetry
+  module Instrumentation
+    module HTTP
+      module Patches
+        # Module to prepend to HTTP::Client for instrumentation
+        module Client
+          module Old
+            # Constant for the HTTP status range
+            HTTP_STATUS_SUCCESS_RANGE = (100..399)
+
+            def perform(req, options)
+              uri = req.uri
+              request_method = req.verb.to_s.upcase
+              span_name = create_request_span_name(request_method, uri.path)
+
+              attributes = {
+                'http.method' => request_method,
+                'http.scheme' => uri.scheme,
+                'http.target' => uri.path,
+                'http.url' => "#{uri.scheme}://#{uri.host}",
+                'net.peer.name' => uri.host,
+                'net.peer.port' => uri.port
+              }.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
+
+              tracer.in_span(span_name, attributes: attributes, kind: :client) do |span|
+                OpenTelemetry.propagation.inject(req.headers)
+                super.tap do |response|
+                  annotate_span_with_response!(span, response)
+                end
+              end
+            end
+
+            private
+
+            def config
+              OpenTelemetry::Instrumentation::HTTP::Instrumentation.instance.config
+            end
+
+            def annotate_span_with_response!(span, response)
+              return unless response&.status
+
+              status_code = response.status.to_i
+              span.set_attribute('http.status_code', status_code)
+              span.status = OpenTelemetry::Trace::Status.error unless HTTP_STATUS_SUCCESS_RANGE.cover?(status_code)
+            end
+
+            def create_request_span_name(request_method, request_path)
+              if (implementation = config[:span_name_formatter])
+                updated_span_name = implementation.call(request_method, request_path)
+                updated_span_name.is_a?(String) ? updated_span_name : "HTTP #{request_method}"
+              else
+                "HTTP #{request_method}"
+              end
+            rescue StandardError
+              "HTTP #{request_method}"
+            end
+
+            def tracer
+              HTTP::Instrumentation.instance.tracer
+            end
+          end
+        end
+      end
+    end
+  end
+end

instrumentation/http/lib/opentelemetry/instrumentation/http/patches/dupe_semconv_connection.rb

@@ -0,0 +1,35 @@
+# frozen_string_literal: true
+
+# Copyright The OpenTelemetry Authors
+#
+# SPDX-License-Identifier: Apache-2.0
+
+module OpenTelemetry
+  module Instrumentation
+    module HTTP
+      module Patches
+        # Module to prepend to HTTP::Connection for instrumentation
+        module Connection
+          module Old
+            def initialize(req, options)
+              attributes = {
+                'net.peer.name' => req.uri.host,
+                'net.peer.port' => req.uri.port
+              }.merge!(OpenTelemetry::Common::HTTP::ClientContext.attributes)
+
+              tracer.in_span('HTTP CONNECT', attributes: attributes) do
+                super
+              end
+            end
+
+            private
+
+            def tracer
+              HTTP::Instrumentation.instance.tracer
+            end
+          end
+        end
+      end
+    end
+  end
+end