feat(bun): Instrument http module on bun

Author: mydea

packages/bun/src/sdk.ts

@@ -26,6 +26,7 @@ import { channelIntegrations, isOrchestrionInjected } from '@sentry/server-utils
 import { bunServerIntegration } from './integrations/bunserver';
 import { makeFetchTransport } from './transports';
 import type { BunOptions } from './types';
+import { bunHttpServerIntegration } from './integrations/bunHttpServer';
 
 /**
  * The orchestrion channel-subscriber integrations, listening on the diagnostics
@@ -88,6 +89,7 @@ export function getDefaultIntegrationsWithoutPerformance(): Integration[] {
     processSessionIntegration(),
     // Bun Specific
     bunServerIntegration(),
+    bunHttpServerIntegration(),
   ];
 }
 

packages/bun/test/integrations/bunHttpServer.test.ts

@@ -1,8 +1,7 @@
 import http from 'node:http';
-import { getCurrentScope } from '@sentry/core';
+import { getTraceData } from '@sentry/core';
 import { beforeAll, describe, expect, test } from 'bun:test';
-import { init } from '../../src';
-import { instrumentBunHttpServer } from '../../src/integrations/bunHttpServer';
+import { bunHttpServerIntegration, init } from '../../src';
 
 async function startServer(handler: http.RequestListener): Promise<{ port: number; close: () => Promise<void> }> {
   const server = http.createServer(handler);
@@ -15,23 +14,27 @@ async function startServer(handler: http.RequestListener): Promise<{ port: numbe
   };
 }
 
+/** Read the trace id the SDK would propagate for the current request. Works in both OTel and non-OTel modes. */
+function currentTraceId(): string | undefined {
+  return getTraceData()['sentry-trace']?.split('-')[0];
+}
+
 describe('Bun HTTP Server Integration', () => {
   beforeAll(() => {
     init({
       dsn: 'https://public@dsn.ingest.sentry.io/1337',
       tracesSampleRate: 0,
       // Avoid sending anything to Sentry
       transport: () => ({ send: async () => ({}), flush: async () => true }),
+      integrations: [bunHttpServerIntegration({ spans: false })],
     });
-    // Only performs isolation + trace reset, no span creation (Next.js emits its own spans).
-    instrumentBunHttpServer({ spans: false });
   });
 
   test('isolates each incoming request with a distinct trace id', async () => {
-    const traceIds: string[] = [];
+    const traceIds: Array<string | undefined> = [];
 
     const { port, close } = await startServer((_req, res) => {
-      traceIds.push(getCurrentScope().getPropagationContext().traceId);
+      traceIds.push(currentTraceId());
       res.end('ok');
     });
 
@@ -51,7 +54,7 @@ describe('Bun HTTP Server Integration', () => {
     let observedTraceId: string | undefined;
 
     const { port, close } = await startServer((_req, res) => {
-      observedTraceId = getCurrentScope().getPropagationContext().traceId;
+      observedTraceId = currentTraceId();
       res.end('ok');
     });