test(node): Restore span-streaming coverage for AI integrations

The deleted truncation tests were the only ones exercising
`traceLifecycle: 'stream'` for openai/anthropic/google-genai/langchain/
langgraph gen_ai spans. Re-point the (otherwise orphaned)
scenario-span-streaming.mjs + instrument-streaming.mjs at a new
non-truncation test per provider that asserts full gen_ai input messages
are recorded under span streaming.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: nicohrubec

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

@@ -19,7 +19,7 @@ import {
   GEN_AI_USAGE_OUTPUT_TOKENS_ATTRIBUTE,
   GEN_AI_USAGE_TOTAL_TOKENS_ATTRIBUTE,
 } from '../../../../../packages/core/src/tracing/ai/gen-ai-attributes';
-import { isOrchestrionEnabled } from '../../../utils';
+import { getStringAttributeValue, isOrchestrionEnabled } from '../../../utils';
 import { cleanupChildProcesses, createEsmAndCjsTests } from '../../../utils/runner';
 
 describe('Anthropic integration', () => {
@@ -678,4 +678,21 @@ describe('Anthropic integration', () => {
       });
     },
   );
+
+  createEsmAndCjsTests(__dirname, 'scenario-span-streaming.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('records full gen_ai input messages when span streaming is enabled', async () => {
+      const longContent = 'A'.repeat(50_000);
+      await createRunner()
+        .expect({
+          span: container => {
+            const chatSpan = container.items.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longContent),
+            );
+            expect(chatSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
 });

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

@@ -21,7 +21,7 @@ import {
   GEN_AI_USAGE_TOTAL_TOKENS_ATTRIBUTE,
 } from '../../../../../packages/core/src/tracing/ai/gen-ai-attributes';
 import { cleanupChildProcesses, createEsmAndCjsTests } from '../../../utils/runner';
-import { isOrchestrionEnabled } from '../../../utils';
+import { getStringAttributeValue, isOrchestrionEnabled } from '../../../utils';
 
 const EXPECTED_ORIGIN = isOrchestrionEnabled() ? 'auto.ai.orchestrion.google_genai' : 'auto.ai.google_genai';
 
@@ -459,4 +459,21 @@ describe('Google GenAI integration', () => {
         .completed();
     });
   });
+
+  createEsmAndCjsTests(__dirname, 'scenario-span-streaming.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('records full gen_ai input messages when span streaming is enabled', async () => {
+      const longContent = 'A'.repeat(50_000);
+      await createRunner()
+        .expect({
+          span: container => {
+            const generateContentSpan = container.items.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longContent),
+            );
+            expect(generateContentSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
 });

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

@@ -20,7 +20,7 @@ import {
   GEN_AI_USAGE_OUTPUT_TOKENS_ATTRIBUTE,
   GEN_AI_USAGE_TOTAL_TOKENS_ATTRIBUTE,
 } from '../../../../../packages/core/src/tracing/ai/gen-ai-attributes';
-import { isOrchestrionEnabled } from '../../../utils';
+import { getStringAttributeValue, isOrchestrionEnabled } from '../../../utils';
 import { cleanupChildProcesses, createEsmAndCjsTests } from '../../../utils/runner';
 import { createEsmTests } from '../../../utils/runner/createEsmAndCjsTests';
 
@@ -400,4 +400,21 @@ describe('LangChain integration', () => {
         .completed();
     });
   });
+
+  createEsmAndCjsTests(__dirname, 'scenario-span-streaming.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('records full gen_ai input messages when span streaming is enabled', async () => {
+      const longContent = 'A'.repeat(50_000);
+      await createRunner()
+        .expect({
+          span: container => {
+            const chatSpan = container.items.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longContent),
+            );
+            expect(chatSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
 });

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

@@ -405,4 +405,21 @@ describe('LangGraph integration', () => {
         .completed();
     });
   });
+
+  createEsmAndCjsTests(__dirname, 'scenario-span-streaming.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('records full gen_ai input messages when span streaming is enabled', async () => {
+      const longContent = 'A'.repeat(50_000);
+      await createRunner()
+        .expect({
+          span: container => {
+            const chatSpan = container.items.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longContent),
+            );
+            expect(chatSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
 });

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

@@ -1421,4 +1421,29 @@ describe('OpenAI integration', () => {
         .completed();
     });
   });
+
+  createEsmAndCjsTests(__dirname, 'scenario-span-streaming.mjs', 'instrument-streaming.mjs', (createRunner, test) => {
+    test('records full gen_ai input messages when span streaming is enabled', async () => {
+      const longContent = 'A'.repeat(50_000);
+      const longStringInput = 'B'.repeat(50_000);
+      await createRunner()
+        .expect({
+          span: container => {
+            const spans = container.items;
+
+            const chatSpan = spans.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longContent),
+            );
+            expect(chatSpan).toBeDefined();
+
+            const responsesSpan = spans.find(s =>
+              getStringAttributeValue(s.attributes[GEN_AI_INPUT_MESSAGES_ATTRIBUTE]?.value)?.includes(longStringInput),
+            );
+            expect(responsesSpan).toBeDefined();
+          },
+        })
+        .start()
+        .completed();
+    });
+  });
 });