Function main

sdk/node/examples/streaming/test_fix_verification.ts:16–124

()

import { Agent } from '../../index.js';

async function main(): Promise<void> {
  const configPath = process.env.A3S_CONFIG_PATH
    || '/Users/roylin/Desktop/code/a3s/crates/code/sdk/node/examples/streaming/test_minimax.acl';

  console.log(`Using config: ${configPath}\n`);

  const agent = await Agent.create(configPath);
  const session = agent.session('.', {
    permissionPolicy: { defaultDecision: 'allow' }, maxToolRounds: 0,
  });

  const prompt = 'Say hello in exactly 5 Chinese characters.';
  console.log(`Streaming with prompt: "${prompt}"\n`);

  const stream = await session.stream(prompt);

  const textDeltas: string[] = [];
  const reasoningDeltas: string[] = [];
  const allEvents: Array<{ type: string; text?: string }> = [];
  let eventCount = 0;

  while (true) {
    const result = await stream.next();
    if (!result.value || result.done) break;

    const event = result.value;
    eventCount++;
    const type = event.type || 'unknown';

    if (type === 'text_delta' && event.text) {
      textDeltas.push(event.text);
      allEvents.push({ type, text: event.text });
    } else if (type === 'reasoning_delta' && event.text) {
      reasoningDeltas.push(event.text);
      allEvents.push({ type, text: event.text });
    }

    // Log first 15 events for debugging
    if (eventCount <= 15) {
      console.log(`[${eventCount}] type="${type}"` +
        (event.text ? ` text="${event.text.slice(0, 50)}"` : '') +
        (event.data ? ` data="${event.data?.slice(0, 60)}"` : '')
      );
    }
  }

  console.log('\n' + '='.repeat(80));
  console.log('Summary:');
  console.log(`Total events: ${eventCount}`);
  console.log(`TextDelta events: ${textDeltas.length}`);
  console.log(`ReasoningDelta events: ${reasoningDeltas.length}`);

  const combinedText = textDeltas.join('');
  console.log(`\nCombined text: "${combinedText}"`);
  console.log(`Text length: ${combinedText.length}`);

  // Verify no duplicates
  let hasDuplicate = false;