add node integration test

Author: nicohrubec

dev-packages/node-integration-tests/suites/tracing/ignoreSpans-streamed/attributes/instrument.mjs

@@ -0,0 +1,12 @@
+import * as Sentry from '@sentry/node';
+import { loggingTransport } from '@sentry-internal/node-integration-tests';
+
+Sentry.init({
+  dsn: 'https://public@dsn.ingest.sentry.io/1337',
+  release: '1.0',
+  tracesSampleRate: 1.0,
+  transport: loggingTransport,
+  traceLifecycle: 'stream',
+  ignoreSpans: [{ attributes: { 'http.method': 'POST' } }],
+  clientReportFlushInterval: 1_000,
+});

dev-packages/node-integration-tests/suites/tracing/ignoreSpans-streamed/attributes/server.mjs

@@ -0,0 +1,25 @@
+import express from 'express';
+import cors from 'cors';
+import * as Sentry from '@sentry/node';
+import { startExpressServerAndSendPortToRunner } from '@sentry-internal/node-integration-tests';
+
+const app = express();
+
+app.use(cors());
+
+app.get('/keep', (_req, res) => {
+  res.send({ status: 'kept' });
+  setTimeout(() => {
+    // flush to avoid waiting for the span buffer timeout to send spans
+    // but defer it to the next tick to let the SDK finish the http.server span first.
+    Sentry.flush();
+  });
+});
+
+app.post('/drop', (_req, res) => {
+  res.send({ status: 'dropped' });
+});
+
+Sentry.setupExpressErrorHandler(app);
+
+startExpressServerAndSendPortToRunner(app);

dev-packages/node-integration-tests/suites/tracing/ignoreSpans-streamed/attributes/test.ts

@@ -0,0 +1,44 @@
+import { afterAll, describe, expect } from 'vitest';
+import { cleanupChildProcesses, createEsmAndCjsTests } from '../../../../utils/runner';
+
+describe('filtering segment spans by attribute with ignoreSpans (streaming)', () => {
+  afterAll(() => {
+    cleanupChildProcesses();
+  });
+
+  createEsmAndCjsTests(__dirname, 'server.mjs', 'instrument.mjs', (createRunner, test) => {
+    test('segment spans matching an attribute filter are dropped including all children', async () => {
+      const runner = createRunner()
+        .unignore('client_report')
+        .expect({
+          client_report: {
+            discarded_events: [
+              {
+                category: 'span',
+                quantity: 5, // 1 segment ignored + 4 child spans (implicitly ignored)
+                reason: 'ignored',
+              },
+            ],
+          },
+        })
+        .expect({
+          span: container => {
+            expect(container.items).toHaveLength(5);
+            const segmentSpan = container.items.find(s => s.name === 'GET /keep' && !!s.is_segment);
+
+            expect(segmentSpan).toBeDefined();
+            expect(container.items.every(s => s.trace_id === segmentSpan!.trace_id)).toBe(true);
+          },
+        })
+        .start();
+
+      const dropRes = await runner.makeRequest('post', '/drop');
+      expect((dropRes as { status: string }).status).toBe('dropped');
+
+      const keepRes = await runner.makeRequest('get', '/keep');
+      expect((keepRes as { status: string }).status).toBe('kept');
+
+      await runner.completed();
+    });
+  });
+});