feat(core): Automatically disable truncation when span streaming is enabled in OpenAI

integration

When span streaming is enabled, the `enableTruncation` option now defaults
to `false` unless the user has explicitly set it.

Closes: #20221

Author: andreiborza

dev-packages/node-integration-tests/suites/tracing/openai/instrument-streaming-with-truncation.mjs

@@ -0,0 +1,16 @@
+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,
+  sendDefaultPii: true,
+  transport: loggingTransport,
+  traceLifecycle: 'stream',
+  integrations: [
+    Sentry.openAIIntegration({
+      enableTruncation: true,
+    }),
+  ],
+});

dev-packages/node-integration-tests/suites/tracing/openai/instrument-streaming.mjs

@@ -0,0 +1,11 @@
+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,
+  sendDefaultPii: true,
+  transport: loggingTransport,
+  traceLifecycle: 'stream',
+});

dev-packages/node-integration-tests/suites/tracing/openai/scenario-no-truncation.mjs

@@ -75,6 +75,8 @@ async function run() {
     });
   });
 
+  // Flush is required when span streaming is enabled to ensure streamed spans are sent before the process exits
+  await Sentry.flush();
   server.close();
 }
 

dev-packages/node-integration-tests/suites/tracing/openai/test.ts

@@ -1019,4 +1019,59 @@ describe('OpenAI integration', () => {
         .completed();
     });
   });
+
+  const streamingLongContent = 'A'.repeat(50_000);
+  const streamingLongString = 'B'.repeat(50_000);
+
+  createEsmAndCjsTests(__dirname, 'scenario-no-truncation.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('automatically disables truncation when span streaming is enabled', async () => {
+      await createRunner()
+        .expect({
+          span: container => {
+            const spans = container.items;
+
+            const expectedChatMessages = JSON.stringify([{ role: 'user', content: streamingLongContent }]);
+            const chatSpan = spans.find(
+              s => s.attributes?.[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value === expectedChatMessages,
+            );
+            expect(chatSpan).toBeDefined();
+
+            const responsesSpan = spans.find(
+              s => s.attributes?.[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value === streamingLongString,
+            );
+            expect(responsesSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
+
+  createEsmAndCjsTests(
+    __dirname,
+    'scenario-no-truncation.mjs',
+    'instrument-streaming-with-truncation.mjs',
+    (createRunner, test) => {
+      test('respects explicit enableTruncation: true even when span streaming is enabled', async () => {
+        await createRunner()
+          .expect({
+            span: container => {
+              const spans = container.items;
+
+              // With explicit enableTruncation: true, content should be truncated despite streaming.
+              // Find the chat span by matching the start of the truncated content (the 'A' repeated messages).
+              const chatSpan = spans.find(s =>
+                s.attributes?.[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value?.startsWith('[{"role":"user","content":"AAAA'),
+              );
+              expect(chatSpan).toBeDefined();
+              expect(chatSpan!.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE].value.length).toBeLessThan(
+                streamingLongContent.length,
+              );
+            },
+          })
+          .start()
+          .completed();
+      });
+    },
+  );
 });

packages/core/src/tracing/openai/index.ts

@@ -1,3 +1,4 @@
+import { getClient } from '../../currentScopes';
 import { DEBUG_BUILD } from '../../debug-build';
 import { captureException } from '../../exports';
 import { SEMANTIC_ATTRIBUTE_SENTRY_ORIGIN } from '../../semanticAttributes';
@@ -24,6 +25,7 @@ import {
   resolveAIRecordingOptions,
   wrapPromiseWithMethods,
 } from '../ai/utils';
+import { hasSpanStreamingEnabled } from '../spans/hasSpanStreamingEnabled';
 import { OPENAI_METHOD_REGISTRY } from './constants';
 import { instrumentStream } from './streaming';
 import type { ChatCompletionChunk, OpenAiOptions, OpenAIStream, ResponseStreamingEvent } from './types';
@@ -170,7 +172,9 @@ function instrumentMethod<T extends unknown[], R>(
         originalResult = originalMethod.apply(context, args);
 
         if (options.recordInputs && params) {
-          addRequestAttributes(span, params, operationName, options.enableTruncation ?? true);
+          const client = getClient();
+          const enableTruncation = options.enableTruncation ?? !(client && hasSpanStreamingEnabled(client));
+          addRequestAttributes(span, params, operationName, enableTruncation);
         }
 
         // Return async processing
@@ -208,7 +212,9 @@ function instrumentMethod<T extends unknown[], R>(
       originalResult = originalMethod.apply(context, args);
 
       if (options.recordInputs && params) {
-        addRequestAttributes(span, params, operationName, options.enableTruncation ?? true);
+        const client = getClient();
+        const enableTruncation = options.enableTruncation ?? !(client && hasSpanStreamingEnabled(client));
+        addRequestAttributes(span, params, operationName, enableTruncation);
       }
 
       return originalResult.then(