WIP

Author: solnic

test_integrations/phoenix_app/lib/phoenix_app/application.ex

@@ -14,6 +14,11 @@ defmodule PhoenixApp.Application do
     })
 
     OpentelemetryBandit.setup()
+
+    # Set up Sentry's LiveView context propagation BEFORE OpentelemetryPhoenix
+    # This enables distributed tracing context to flow from HTTP requests to LiveView WebSocket processes
+    Sentry.OpenTelemetry.LiveViewPropagator.setup()
+
     OpentelemetryPhoenix.setup(adapter: :bandit)
     OpentelemetryOban.setup()
     OpentelemetryEcto.setup([:phoenix_app, :repo], db_statement: :enabled)

test_integrations/phoenix_app/lib/phoenix_app_web/router.ex

@@ -8,6 +8,7 @@ defmodule PhoenixAppWeb.Router do
     plug :put_root_layout, html: {PhoenixAppWeb.Layouts, :root}
     plug :protect_from_forgery
     plug :put_secure_browser_headers
+    plug Sentry.Plug.LiveViewContext
   end
 
   pipeline :api do

test_integrations/tracing/tests/tracing.spec.ts

@@ -490,7 +490,7 @@ test.describe("Tracing", () => {
         (event) =>
           event.contexts?.trace?.op === "http.server" &&
           ((event.contexts?.trace?.data as any)?.["http.route"] === "/users" ||
-           event.transaction?.includes("/users"))
+            event.transaction?.includes("/users"))
       );
       expect(liveViewHttpTransaction).toBeDefined();
 
@@ -502,19 +502,26 @@ test.describe("Tracing", () => {
           event.transaction?.includes("UserLive.Index.mount") ||
           event.transaction?.includes(".mount")
       );
-      
+
       // Find mount transaction that has spans (prefer one with DB spans)
-      const liveViewMountTransaction = liveViewMountTransactions.find(tx => {
-        const spans = (tx as any).spans || [];
-        return spans.length > 0;
-      }) || liveViewMountTransactions[0];
-      
+      const liveViewMountTransaction =
+        liveViewMountTransactions.find((tx) => {
+          const spans = (tx as any).spans || [];
+          return spans.length > 0;
+        }) || liveViewMountTransactions[0];
+
       expect(liveViewMountTransaction).toBeDefined();
 
       // All should have valid trace IDs
-      expect(apiTransaction?.contexts?.trace?.trace_id).toMatch(/^[a-f0-9]{32}$/);
-      expect(liveViewHttpTransaction?.contexts?.trace?.trace_id).toMatch(/^[a-f0-9]{32}$/);
-      expect(liveViewMountTransaction?.contexts?.trace?.trace_id).toMatch(/^[a-f0-9]{32}$/);
+      expect(apiTransaction?.contexts?.trace?.trace_id).toMatch(
+        /^[a-f0-9]{32}$/
+      );
+      expect(liveViewHttpTransaction?.contexts?.trace?.trace_id).toMatch(
+        /^[a-f0-9]{32}$/
+      );
+      expect(liveViewMountTransaction?.contexts?.trace?.trace_id).toMatch(
+        /^[a-f0-9]{32}$/
+      );
 
       // Verify the API transaction has database spans
       const apiSpans = (apiTransaction as any)?.spans || [];