Add span and trace origins (#2319)

* Add :origin attribute to span and use in trace context and span hash
* Add origin to Rack::CaptureExceptions
* Add origin to Net::HTTP
* Add origin to Redis
* Add origin to Metrics
* Add origin to DelayedJob
* Add origin to OpenTelemetry
* Add origin to Resque
* Add origin to Sidekiq
* Add origin to Rails

Author: sl0thentr0py

CHANGELOG.md

@@ -31,6 +31,10 @@
   - Fixes [#2297](https://github.com/getsentry/sentry-ruby/issues/2297)
 - Don't mutate `enabled_environments` when using `Sentry::TestHelper` ([#2317](https://github.com/getsentry/sentry-ruby/pull/2317))
 
+### Internal
+
+- Add `origin` to spans and transactions to track integration sources for instrumentation ([#2319](https://github.com/getsentry/sentry-ruby/pull/2319))
+
 ## 5.17.3
 
 ### Internal

sentry-delayed_job/lib/sentry/delayed_job/plugin.rb

@@ -8,7 +8,8 @@ class Plugin < ::Delayed::Plugin
       # need to symbolize strings as keyword arguments in Ruby 2.4~2.6
       DELAYED_JOB_CONTEXT_KEY = :"Delayed-Job"
       ACTIVE_JOB_CONTEXT_KEY = :"Active-Job"
-      OP_NAME = "queue.delayed_job".freeze
+      OP_NAME = "queue.delayed_job"
+      SPAN_ORIGIN = "auto.queue.delayed_job"
 
       callbacks do |lifecycle|
         lifecycle.before(:enqueue) do |job, *args, &block|
@@ -93,7 +94,13 @@ def self.report?(job)
       end
 
       def self.start_transaction(scope, env, contexts)
-        options = { name: scope.transaction_name, source: scope.transaction_source, op: OP_NAME }
+        options = {
+          name: scope.transaction_name,
+          source: scope.transaction_source,
+          op: OP_NAME,
+          origin: SPAN_ORIGIN
+        }
+
         transaction = Sentry.continue_trace(env, **options)
         Sentry.start_transaction(transaction: transaction, custom_sampling_context: contexts, **options)
       end

sentry-delayed_job/spec/sentry/delayed_job_spec.rb

@@ -383,6 +383,7 @@ def perform
       expect(transaction.contexts.dig(:trace, :span_id)).to be_a(String)
       expect(transaction.contexts.dig(:trace, :status)).to eq("ok")
       expect(transaction.contexts.dig(:trace, :op)).to eq("queue.delayed_job")
+      expect(transaction.contexts.dig(:trace, :origin)).to eq("auto.queue.delayed_job")
     end
 
     it "records transaction with exception" do

sentry-opentelemetry/lib/sentry/opentelemetry/span_processor.rb

@@ -11,6 +11,7 @@ class SpanProcessor < ::OpenTelemetry::SDK::Trace::SpanProcessor
 
       SEMANTIC_CONVENTIONS = ::OpenTelemetry::SemanticConventions::Trace
       INTERNAL_SPAN_KINDS = %i[client internal]
+      SPAN_ORIGIN = "auto.otel"
 
       # The mapping from otel span ids to sentry spans
       # @return [Hash]
@@ -34,7 +35,8 @@ def on_start(otel_span, parent_context)
           sentry_parent_span.start_child(
             span_id: trace_data.span_id,
             description: otel_span.name,
-            start_timestamp: otel_span.start_timestamp / 1e9
+            start_timestamp: otel_span.start_timestamp / 1e9,
+            origin: SPAN_ORIGIN
           )
         else
           options = {
@@ -45,7 +47,8 @@ def on_start(otel_span, parent_context)
             parent_span_id: trace_data.parent_span_id,
             parent_sampled: trace_data.parent_sampled,
             baggage: trace_data.baggage,
-            start_timestamp: otel_span.start_timestamp / 1e9
+            start_timestamp: otel_span.start_timestamp / 1e9,
+            origin: SPAN_ORIGIN
           }
 
           Sentry.start_transaction(**options)

sentry-opentelemetry/spec/sentry/opentelemetry/span_processor_spec.rb

@@ -92,6 +92,7 @@
           expect(event.contexts).to include(:trace)
           expect(event.contexts[:trace][:trace_id]).to eq(root_span.context.hex_trace_id)
           expect(event.contexts[:trace][:span_id]).to eq(root_span.context.hex_span_id)
+          expect(event.contexts[:trace][:origin]).to eq('auto.otel')
         end
       end
     end
@@ -134,6 +135,7 @@
       expect(transaction.span_id).to eq(span_id)
       expect(transaction.trace_id).to eq(trace_id)
       expect(transaction.start_timestamp).to eq(root_span.start_timestamp / 1e9)
+      expect(transaction.origin).to eq('auto.otel')
 
       expect(transaction.parent_span_id).to eq(nil)
       expect(transaction.parent_sampled).to eq(nil)
@@ -168,6 +170,7 @@
         expect(sentry_span.trace_id).to eq(trace_id)
         expect(sentry_span.description).to eq(child_db_span.name)
         expect(sentry_span.start_timestamp).to eq(child_db_span.start_timestamp / 1e9)
+        expect(sentry_span.origin).to eq('auto.otel')
       end
     end
   end
@@ -215,6 +218,7 @@
       subject.on_finish(finished_db_span)
 
       expect(sentry_span.op).to eq('db')
+      expect(sentry_span.origin).to eq('auto.otel')
       expect(sentry_span.description).to eq(finished_db_span.attributes['db.statement'])
       expect(sentry_span.data).to include(finished_db_span.attributes)
       expect(sentry_span.data).to include({ 'otel.kind' => finished_db_span.kind })
@@ -235,6 +239,7 @@
       subject.on_finish(finished_http_span)
 
       expect(sentry_span.op).to eq('http.client')
+      expect(sentry_span.origin).to eq('auto.otel')
       expect(sentry_span.description).to eq('GET www.google.com/search')
       expect(sentry_span.data).to include(finished_http_span.attributes)
       expect(sentry_span.data).to include({ 'otel.kind' => finished_http_span.kind })
@@ -259,6 +264,7 @@
       subject.on_finish(finished_root_span)
 
       expect(transaction.op).to eq('http.server')
+      expect(transaction.origin).to eq('auto.otel')
       expect(transaction.name).to eq(finished_root_span.name)
       expect(transaction.status).to eq('ok')
       expect(transaction.contexts[:otel]).to eq({

sentry-rails/lib/sentry/rails/action_cable.rb

@@ -3,6 +3,7 @@ module Rails
     module ActionCableExtensions
       class ErrorHandler
         OP_NAME = "websocket.server".freeze
+        SPAN_ORIGIN = "auto.http.rails.actioncable"
 
         class << self
           def capture(connection, transaction_name:, extra_context: nil, &block)
@@ -33,7 +34,13 @@ def capture(connection, transaction_name:, extra_context: nil, &block)
           end
 
           def start_transaction(env, scope)
-            options = { name: scope.transaction_name, source: scope.transaction_source, op: OP_NAME }
+            options = {
+              name: scope.transaction_name,
+              source: scope.transaction_source,
+              op: OP_NAME,
+              origin: SPAN_ORIGIN
+            }
+
             transaction = Sentry.continue_trace(env, **options)
             Sentry.start_transaction(transaction: transaction, **options)
           end

sentry-rails/lib/sentry/rails/active_job.rb

@@ -17,6 +17,7 @@ def already_supported_by_sentry_integration?
 
       class SentryReporter
         OP_NAME = "queue.active_job".freeze
+        SPAN_ORIGIN = "auto.queue.active_job".freeze
 
         class << self
           def record(job, &block)
@@ -27,7 +28,12 @@ def record(job, &block)
                   if job.is_a?(::Sentry::SendEventJob)
                     nil
                   else
-                    Sentry.start_transaction(name: scope.transaction_name, source: scope.transaction_source, op: OP_NAME)
+                    Sentry.start_transaction(
+                      name: scope.transaction_name,
+                      source: scope.transaction_source,
+                      op: OP_NAME,
+                      origin: SPAN_ORIGIN
+                    )
                   end
 
                 scope.set_span(transaction) if transaction

sentry-rails/lib/sentry/rails/capture_exceptions.rb

@@ -2,6 +2,7 @@ module Sentry
   module Rails
     class CaptureExceptions < Sentry::Rack::CaptureExceptions
       RAILS_7_1 = Gem::Version.new(::Rails.version) >= Gem::Version.new("7.1.0.alpha")
+      SPAN_ORIGIN = 'auto.http.rails'.freeze
 
       def initialize(_)
         super
@@ -32,7 +33,12 @@ def capture_exception(exception, env)
       end
 
       def start_transaction(env, scope)
-        options = { name: scope.transaction_name, source: scope.transaction_source, op: transaction_op }
+        options = {
+          name: scope.transaction_name,
+          source: scope.transaction_source,
+          op: transaction_op,
+          origin: SPAN_ORIGIN
+        }
 
         if @assets_regexp && scope.transaction_name.match?(@assets_regexp)
           options.merge!(sampled: false)

sentry-rails/lib/sentry/rails/controller_transaction.rb

@@ -1,6 +1,8 @@
 module Sentry
   module Rails
     module ControllerTransaction
+      SPAN_ORIGIN = 'auto.view.rails'.freeze
+
       def self.included(base)
         base.prepend_around_action(:sentry_around_action)
       end
@@ -11,7 +13,7 @@ def sentry_around_action
         if Sentry.initialized?
           transaction_name = "#{self.class}##{action_name}"
           Sentry.get_current_scope.set_transaction_name(transaction_name, source: :view)
-          Sentry.with_child_span(op: "view.process_action.action_controller", description: transaction_name) do |child_span|
+          Sentry.with_child_span(op: "view.process_action.action_controller", description: transaction_name, origin: SPAN_ORIGIN) do |child_span|
             if child_span
               begin
                 result = yield

sentry-rails/lib/sentry/rails/tracing/action_controller_subscriber.rb

@@ -9,6 +9,7 @@ class ActionControllerSubscriber < AbstractSubscriber
 
         EVENT_NAMES = ["process_action.action_controller"].freeze
         OP_NAME = "view.process_action.action_controller".freeze
+        SPAN_ORIGIN = "auto.view.rails".freeze
 
         def self.subscribe!
           Sentry.logger.warn <<~MSG
@@ -22,6 +23,7 @@ def self.subscribe!
 
             record_on_current_span(
               op: OP_NAME,
+              origin: SPAN_ORIGIN,
               start_timestamp: payload[START_TIMESTAMP_NAME],
               description: "#{controller}##{action}",
               duration: duration