fix(bun): Keep diagnostics channel subscriptions alive

Bun garbage-collects a diagnostics channel that no code references, together
with its subscribers, so a subscription made at init() could stop receiving
messages after the next GC. Node and Deno keep a subscribed channel alive.
On Bun, the channel wrappers in @sentry/server-utils now keep a reference to
every channel they return, and the channel integrations and httpIntegration
use them. Other runtimes get the original node:diagnostics_channel functions.

graphql-tracing-channel, which the GC broke, now runs on Bun.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: JPeer264

dev-packages/bun-integration-tests/node-suites/excludes.ts

@@ -145,11 +145,6 @@ const NOT_TRIAGED = [
   'suites/tracing/tracer-start-active-span-error/test.ts',
 ];
 
-// Bun garbage-collects a diagnostics channel that no code references, and its subscribers with it.
-// `graphql` 17 publishes its own tracing channels, so the integration only subscribes to them, and
-// no spans arrive. See https://github.com/oven-sh/bun/issues/43086
-const CHANNEL_GARBAGE_COLLECTED = ['suites/tracing/graphql-tracing-channel/**'];
-
 export const NODE_SUITES_EXCLUDE = [
   '**/node_modules/**',
   ...NODE_ONLY,
@@ -158,5 +153,4 @@ export const NODE_SUITES_EXCLUDE = [
   ...NO_OUTGOING_HTTP_INSTRUMENTATION,
   ...NO_AUTO_INSTRUMENTATION,
   ...NOT_TRIAGED,
-  ...CHANNEL_GARBAGE_COLLECTED,
 ];

packages/bun/test/integrations/diagnosticsChannelGc.test.ts

@@ -0,0 +1,26 @@
+import { channel } from 'node:diagnostics_channel';
+import { describe, expect, test } from 'bun:test';
+import { init } from '../../src';
+
+const EXPRESS_HANDLE_START = 'tracing:orchestrion:express:handle:start';
+
+function nextTask(): Promise<void> {
+  return new Promise(resolve => setTimeout(resolve, 0));
+}
+
+describe('channel-based integrations', () => {
+  // Bun garbage-collects a diagnostics channel that no code references, together with its
+  // subscribers. A GC in the same task does not collect it, so the check runs in a later task.
+  // See https://github.com/oven-sh/bun/issues/43086
+  test('stay subscribed after a garbage collection', async () => {
+    init({ dsn: 'https://username@domain/123', tracesSampleRate: 1 });
+    await nextTask();
+
+    expect(channel(EXPRESS_HANDLE_START).hasSubscribers).toBe(true);
+
+    Bun.gc(true);
+    await nextTask();
+
+    expect(channel(EXPRESS_HANDLE_START).hasSubscribers).toBe(true);
+  });
+});

packages/node/src/integrations/http/SentryHttpInstrumentation.ts

@@ -1,4 +1,3 @@
-import { subscribe } from 'node:diagnostics_channel';
 import { context, trace } from '@opentelemetry/api';
 import type { ClientRequest, IncomingMessage } from 'node:http';
 import type { Span } from '@sentry/core';
@@ -10,6 +9,7 @@ import {
   HTTP_ON_CLIENT_REQUEST,
   patchHttpModuleClient,
 } from '@sentry/core/server';
+import { subscribeDiagnosticsChannel } from '@sentry/server-utils';
 import { NODE_VERSION } from '../../nodeVersion';
 import { errorMonitor } from 'node:events';
 import * as http from 'node:http';
@@ -125,7 +125,7 @@ export function instrumentHttpOutgoingRequests(
 
 function instrumentHttpOutgoingRequestsViaChannel(options: HttpInstrumentationOptions): void {
   const { [HTTP_ON_CLIENT_REQUEST]: onHttpClientRequestCreated } = getHttpClientSubscriptions(options);
-  subscribe(HTTP_ON_CLIENT_REQUEST, onHttpClientRequestCreated);
+  subscribeDiagnosticsChannel(HTTP_ON_CLIENT_REQUEST, onHttpClientRequestCreated);
 }
 
 /**

packages/node/src/integrations/http/httpServerIntegration.ts

@@ -1,10 +1,10 @@
-import { subscribe } from 'node:diagnostics_channel';
 import type { RequestOptions } from 'node:http';
 import { context, createContextKey, propagation } from '@opentelemetry/api';
 import type { Integration, IntegrationFn } from '@sentry/core';
 import { addNonEnumerableProperty, debug, getClient } from '@sentry/core';
 import type { HttpIncomingMessage, HttpServerResponse } from '@sentry/core/server';
 import { getHttpServerSubscriptions, HTTP_ON_SERVER_REQUEST, recordRequestSession } from '@sentry/core/server';
+import { subscribeDiagnosticsChannel } from '@sentry/server-utils';
 import type { RequestEventData } from '@sentry/core';
 import { DEBUG_BUILD } from '../../debug-build';
 
@@ -143,7 +143,7 @@ const _httpServerIntegration = ((options: HttpServerIntegrationOptions = {}) =>
     name: INTEGRATION_NAME,
     setupOnce() {
       const { [HTTP_ON_SERVER_REQUEST]: onHttpServerRequestStart } = getHttpServerSubscriptions(_options);
-      subscribe(HTTP_ON_SERVER_REQUEST, onHttpServerRequestStart);
+      subscribeDiagnosticsChannel(HTTP_ON_SERVER_REQUEST, onHttpServerRequestStart);
     },
     afterAllSetup(client) {
       if (DEBUG_BUILD && client.getIntegrationByName('Http')) {

packages/server-utils/src/index.ts

@@ -13,6 +13,7 @@ export type { InstrumentationConfig } from './orchestrion/apmTypes';
 // `orchestrion/bundler/moduleInjectedTransform.ts`); it is a plain runtime
 // helper with no orchestrion build-time dependency.
 export { orchestrionModuleInjected } from './utils/moduleInjected';
+export { subscribe as subscribeDiagnosticsChannel } from './utils/diagnosticsChannel';
 export { eveConversationHook, eveIntegration } from './eve';
 export { getInstrumentedModuleNames } from './orchestrion/config';
 export {

packages/server-utils/src/integrations/amqplib.ts

@@ -1,5 +1,5 @@
 /* eslint-disable max-lines */
-import * as diagnosticsChannel from 'node:diagnostics_channel';
+import * as diagnosticsChannel from '../utils/diagnosticsChannel';
 import type { IntegrationFn, Span, SpanAttributes } from '@sentry/core';
 import {
   continueTrace,

packages/server-utils/src/integrations/anthropic.ts

@@ -1,5 +1,5 @@
 import { GEN_AI_REQUEST_MODEL } from '@sentry/conventions/attributes';
-import * as diagnosticsChannel from 'node:diagnostics_channel';
+import * as diagnosticsChannel from '../utils/diagnosticsChannel';
 import type { IntegrationFn, Span, SpanAttributeValue } from '@sentry/core';
 import {
   _INTERNAL_shouldSkipAiProviderWrapping,

packages/server-utils/src/integrations/aws-sdk/index.ts

@@ -1,4 +1,4 @@
-import * as diagnosticsChannel from 'node:diagnostics_channel';
+import * as diagnosticsChannel from '../../utils/diagnosticsChannel';
 import type { IntegrationFn, Span } from '@sentry/core';
 import { defineIntegration, SEMANTIC_ATTRIBUTE_SENTRY_ORIGIN, startInactiveSpan } from '@sentry/core';
 import {

packages/server-utils/src/integrations/dataloader.ts

@@ -1,4 +1,4 @@
-import * as diagnosticsChannel from 'node:diagnostics_channel';
+import * as diagnosticsChannel from '../utils/diagnosticsChannel';
 import {
   CACHE_KEY,
   CACHE_OPERATION,

packages/server-utils/src/integrations/express/index.ts

@@ -1,4 +1,4 @@
-import * as diagnosticsChannel from 'node:diagnostics_channel';
+import * as diagnosticsChannel from '../../utils/diagnosticsChannel';
 import type { IntegrationFn } from '@sentry/core';
 import { defineIntegration } from '@sentry/core';
 import { expressModuleNames } from '../../orchestrion/config/express';