Function main

sdk/node/examples/streaming/test_fix_verification_kimi.ts:13–116

()

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

async function main(): Promise<void> {
  const apiKey = process.env.A3S_API_KEY;
  const baseUrl = process.env.A3S_BASE_URL || 'https://api.moonshot.cn/v1';

  if (!apiKey) {
    console.error('❌ Missing A3S_API_KEY environment variable');
    console.log('\nUsage:');
    console.log('  A3S_API_KEY=your_key A3S_BASE_URL=https://api.moonshot.cn/v1 \\');
    console.log('  npx tsx sdk/node/examples/streaming/test_fix_verification_kimi.ts');
    process.exit(1);
  }

  console.log(`Using API: ${baseUrl}\n`);

  // Create config inline with env vars.
  const agent = await Agent.create(`
default_model = "openai/kimi-k2.5"

providers "openai" {
  apiKey = "${apiKey}"
  baseUrl = "${baseUrl}"

  models "kimi-k2.5" {
    name = "kimi"
    reasoning = true
  }
}
`);

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

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

  const stream = await session.stream(prompt);

  const textDeltas: string[] = [];
  const reasoningDeltas: 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);
      console.log(`[${eventCount}] text_delta: "${event.text}"`);
    } else if (type === 'reasoning_delta' && event.text) {
      reasoningDeltas.push(event.text);
      if (eventCount <= 5) {
        console.log(`[${eventCount}] reasoning_delta: "${event.text.slice(0, 40)}..."`);
      }