formatting

Author: spunkedy

lib/sentry/opentelemetry/span_processor.ex

@@ -15,20 +15,21 @@ if Code.ensure_loaded?(OpenTelemetry) do
     alias Sentry.{Transaction, OpenTelemetry.SpanStorage, OpenTelemetry.SpanRecord}
     alias Sentry.Interfaces.Span
 
-        # This can be a no-op since we can postpone inserting the span into storage until on_end
+    # This can be a no-op since we can postpone inserting the span into storage until on_end
     @impl :otel_span_processor
     def on_start(_ctx, otel_span, _config) do
       otel_span
     end
 
-        @impl :otel_span_processor
+    @impl :otel_span_processor
     def on_end(otel_span, _config) do
       span_record = SpanRecord.new(otel_span)
 
       SpanStorage.store_span(span_record)
 
       # Check if this is a root span (no parent) or a transaction root (HTTP request span)
-      is_transaction_root = span_record.parent_span_id == nil or is_http_request_span?(span_record)
+      is_transaction_root =
+        span_record.parent_span_id == nil or is_http_request_span?(span_record)
 
       if is_transaction_root do
         child_span_records = SpanStorage.get_child_spans(span_record.span_id)
@@ -71,12 +72,13 @@ if Code.ensure_loaded?(OpenTelemetry) do
       has_url_path = Map.has_key?(attributes, to_string(URLAttributes.url_path()))
 
       # Check if the name looks like an HTTP endpoint
-      name_looks_like_http = String.contains?(name, ["/", "POST", "GET", "PUT", "DELETE", "PATCH"])
+      name_looks_like_http =
+        String.contains?(name, ["/", "POST", "GET", "PUT", "DELETE", "PATCH"])
 
       (has_http_method and (has_http_route or has_url_path)) or name_looks_like_http
     end
 
-        defp build_transaction(root_span_record, child_span_records) do
+    defp build_transaction(root_span_record, child_span_records) do
       root_span = build_span(root_span_record)
       child_spans = Enum.map(child_span_records, &build_span(&1))
 
@@ -93,7 +95,7 @@ if Code.ensure_loaded?(OpenTelemetry) do
       })
     end
 
-        defp transaction_name(
+    defp transaction_name(
            %{attributes: %{unquote(to_string(MessagingAttributes.messaging_system())) => :oban}} =
              span_record
          ) do

test/sentry/opentelemetry/span_processor_test.exs

@@ -234,7 +234,7 @@ defmodule Sentry.Opentelemetry.SpanProcessorTest do
       assert length(transaction.spans) == 0
       assert transaction.transaction == "child_instrumented_function_standalone"
     end
-    
+
     @tag span_storage: true
     test "treats HTTP request spans as transaction roots even with external parents" do
       put_test_config(environment_name: "test", traces_sample_rate: 1.0)
@@ -248,7 +248,7 @@ defmodule Sentry.Opentelemetry.SpanProcessorTest do
 
       # Create a span with HTTP attributes and an external parent span ID
       external_parent_span_id = "b943d7459127970c"
-      
+
       # Start a span that simulates an HTTP request from an external trace
       Tracer.with_span "POST /api/v1alpha", %{
         attributes: %{
@@ -258,7 +258,9 @@ defmodule Sentry.Opentelemetry.SpanProcessorTest do
           "server.address" => "localhost",
           "server.port" => 4000
         },
-        parent: {:span_context, :undefined, external_parent_span_id, :undefined, :undefined, :undefined, :undefined, :undefined, :undefined, :undefined}
+        parent:
+          {:span_context, :undefined, external_parent_span_id, :undefined, :undefined, :undefined,
+           :undefined, :undefined, :undefined, :undefined}
       } do
         # Simulate child spans (database queries, etc.) with proper DB attributes
         Tracer.with_span "matrix_data.repo.query", %{
@@ -269,7 +271,7 @@ defmodule Sentry.Opentelemetry.SpanProcessorTest do
         } do
           Process.sleep(10)
         end
-        
+
         Tracer.with_span "matrix_data.repo.query:agents", %{
           attributes: %{
             "db.system" => :postgresql,
@@ -295,11 +297,11 @@ defmodule Sentry.Opentelemetry.SpanProcessorTest do
 
       # Verify all spans share the same trace ID
       trace_id = transaction.contexts.trace.trace_id
+
       Enum.each(transaction.spans, fn span ->
         assert span.trace_id == trace_id
       end)
     end
-    
 
     @tag span_storage: true
     test "concurrent traces maintain independent sampling decisions" do