feat: implement client trace initialization with runtime configuration

Author: nicosammito

src/packages/core/src/util/open-telemetry-traces.ts

@@ -2,53 +2,67 @@ import {OTLPTraceExporter} from '@opentelemetry/exporter-trace-otlp-http'
 import {WebTracerProvider} from '@opentelemetry/sdk-trace-web'
 import {BatchSpanProcessor} from '@opentelemetry/sdk-trace-base'
 import {XMLHttpRequestInstrumentation} from '@opentelemetry/instrumentation-xml-http-request'
-import {resource, serverResource} from "@core/util/open-telemetry"
+import {buildClientResource, ClientOtelConfig, serverResource} from "@core/util/open-telemetry"
 import {registerInstrumentations} from '@opentelemetry/instrumentation'
 import {FetchInstrumentation} from '@opentelemetry/instrumentation-fetch'
 import {ZoneContextManager} from '@opentelemetry/context-zone'
+import {trace} from "@opentelemetry/api"
 import {parseHeaders} from "@core/util/headers";
 
 export const openTelemetryServerTracesReader = process.env.OTEL_TRACES_ENDPOINT ? new OTLPTraceExporter({
     url: process.env.OTEL_TRACES_ENDPOINT,
     headers: parseHeaders(process.env.OTEL_HEADER),
 }) : undefined
 
-export const openTelemetryClientTracesReader = process.env.NEXT_PUBLIC_OTEL_TRACES_ENDPOINT ? new OTLPTraceExporter({
-    url: process.env.NEXT_PUBLIC_OTEL_TRACES_ENDPOINT || "",
-    headers: parseHeaders(process.env.NEXT_PUBLIC_OTEL_HEADER),
-}) : undefined
-
 export const openTelemetryServerTracesProvider = openTelemetryServerTracesReader ? new WebTracerProvider({
     resource: serverResource,
     spanProcessors: [new BatchSpanProcessor(openTelemetryServerTracesReader)],
 }) : undefined
 
-export const openTelemetryClientTracesProvider = openTelemetryClientTracesReader ? new WebTracerProvider({
-    resource: resource,
-    spanProcessors: [new BatchSpanProcessor(openTelemetryClientTracesReader)],
-}) : undefined
-
-export default (level: 'server' | "client" = "server") => {
+export default () => {
 
-    if (level === 'server' && openTelemetryServerTracesProvider) {
+    if (openTelemetryServerTracesProvider) {
         openTelemetryServerTracesProvider.register({
             contextManager: new ZoneContextManager(),
         })
-    } else if (level === 'client' && openTelemetryClientTracesProvider) {
-        openTelemetryClientTracesProvider.register({
-            contextManager: new ZoneContextManager(),
-        })
-
-        registerInstrumentations({
-            instrumentations: [
-                new FetchInstrumentation({
-                    propagateTraceHeaderCorsUrls: /.*/,
-                }),
-                new XMLHttpRequestInstrumentation({
-                    propagateTraceHeaderCorsUrls: /.*/,
-                }),
-            ],
-        })
     }
+}
+
+/**
+ * Builds and registers the browser trace provider from runtime configuration.
+ * Returns the provider so the caller can install it as the global tracer
+ * provider, or undefined when tracing is not configured.
+ */
+export const initializeClientTraces = (config: ClientOtelConfig) => {
+
+    if (!config.tracesEndpoint) return undefined
+
+    const exporter = new OTLPTraceExporter({
+        url: config.tracesEndpoint,
+        headers: parseHeaders(config.header ?? undefined),
+    })
+
+    const provider = new WebTracerProvider({
+        resource: buildClientResource(config),
+        spanProcessors: [new BatchSpanProcessor(exporter)],
+    })
+
+    provider.register({
+        contextManager: new ZoneContextManager(),
+    })
+
+    registerInstrumentations({
+        instrumentations: [
+            new FetchInstrumentation({
+                propagateTraceHeaderCorsUrls: /.*/,
+            }),
+            new XMLHttpRequestInstrumentation({
+                propagateTraceHeaderCorsUrls: /.*/,
+            }),
+        ],
+    })
+
+    trace.setGlobalTracerProvider(provider)
 
-}
+    return provider
+}