fix preloading

fix test

Author: mydea

packages/node/src/integrations/tracing/fastify/index.ts

@@ -90,10 +90,11 @@ interface FastifyHandlerOptions {
 }
 
 const INTEGRATION_NAME = 'Fastify';
-const INTEGRATION_NAME_V5 = 'Fastify-V5';
-const INTEGRATION_NAME_V3 = 'Fastify-V3';
 
-export const instrumentFastifyV3 = generateInstrumentOnce(INTEGRATION_NAME_V3, () => new FastifyInstrumentationV3());
+export const instrumentFastifyV3 = generateInstrumentOnce(
+  `${INTEGRATION_NAME}.v3`,
+  () => new FastifyInstrumentationV3(),
+);
 
 function getFastifyIntegration(): ReturnType<typeof _fastifyIntegration> | undefined {
   const client = getClient();
@@ -135,7 +136,7 @@ function handleFastifyError(
   }
 }
 
-export const instrumentFastify = generateInstrumentOnce(INTEGRATION_NAME_V5, () => {
+export const instrumentFastify = generateInstrumentOnce(`${INTEGRATION_NAME}.v5`, () => {
   const fastifyOtelInstrumentationInstance = new FastifyOtelInstrumentation();
   const plugin = fastifyOtelInstrumentationInstance.plugin();
 

packages/node/src/sdk/initOtel.ts

@@ -101,7 +101,11 @@ function getPreloadMethods(integrationNames?: string[]): ((() => void) & { id: s
     return instruments;
   }
 
-  return instruments.filter(instrumentation => integrationNames.includes(instrumentation.id));
+  // We match exact matches of instrumentation, but also match prefixes, e.g. "Fastify.v5" will match "Fastify"
+  return instruments.filter(instrumentation => {
+    const id = instrumentation.id;
+    return integrationNames.some(integrationName => id === integrationName || id.startsWith(`${integrationName}.`));
+  });
 }
 
 /** Just exported for tests. */

packages/node/test/sdk/preload.test.ts

@@ -1,10 +1,27 @@
 import { debug } from '@sentry/core';
-import { afterEach, describe, expect, it, vi } from 'vitest';
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
+import { resetGlobals } from '../helpers/mockSdkInit';
 
 describe('preload', () => {
+  beforeEach(() => {
+    // Mock this to prevent conflicts with other tests
+    vi.mock('../../src/integrations/tracing', async (importOriginal: () => Promise<Record<string, unknown>>) => {
+      const actual = await importOriginal();
+      return {
+        ...actual,
+        getOpenTelemetryInstrumentationToPreload: () => [
+          Object.assign(vi.fn(), { id: 'Http.sentry' }),
+          Object.assign(vi.fn(), { id: 'Http' }),
+          Object.assign(vi.fn(), { id: 'Express' }),
+          Object.assign(vi.fn(), { id: 'Graphql' }),
+        ],
+      };
+    });
+  });
+
   afterEach(() => {
-    vi.resetAllMocks();
     debug.disable();
+    resetGlobals();
 
     delete process.env.SENTRY_DEBUG;
     delete process.env.SENTRY_PRELOAD_INTEGRATIONS;
@@ -29,6 +46,7 @@ describe('preload', () => {
 
     await import('../../src/preload');
 
+    expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Http.sentry instrumentation');
     expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Http instrumentation');
     expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Express instrumentation');
     expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Graphql instrumentation');
@@ -44,6 +62,7 @@ describe('preload', () => {
 
     await import('../../src/preload');
 
+    expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Http.sentry instrumentation');
     expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Http instrumentation');
     expect(logSpy).toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Express instrumentation');
     expect(logSpy).not.toHaveBeenCalledWith('Sentry Logger [log]:', '[Sentry] Preloaded Graphql instrumentation');