Function main

sdk/node/examples/streaming/hitl_confirmation_loop.ts:70–128

()

}

async function main(): Promise<void> {
  const configPath = process.env.A3S_CONFIG_FILE ?? process.argv[2];
  if (!configPath) {
    throw new Error('Set A3S_CONFIG_FILE or pass an agent.acl path as the first argument.');
  }

  const workspace = process.env.A3S_CODE_WORKSPACE ?? process.cwd();
  const prompt = process.env.A3S_CODE_HITL_PROMPT
    ?? 'Use the bash tool to run: echo A3S_CODE_HITL_OK. Then summarize the result.';

  const options: SessionOptions = {
    planningMode: 'disabled',
    permissionPolicy: {
      ask: ['bash*'],
      defaultDecision: 'allow',
    },
    confirmationPolicy: {
      enabled: true,
      defaultTimeoutMs: 120000,
      timeoutAction: 'reject',
      yoloLanes: ['query'],
    },
  };

  const agent = await Agent.create(configPath);
  const session = agent.session(workspace, options);
  const rl = createInterface({ input, output });

  try {
    const stream = await session.stream(prompt);

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

      const event = next.value;
      if (event.type === 'text_delta' && event.text) {
        process.stdout.write(event.text);
      } else if (event.type === 'tool_start') {
        console.log(`\n[tool:start] ${event.toolName ?? 'unknown'}`);
      } else if (event.type === 'tool_end') {
        console.log(`\n[tool:end] ${event.toolName ?? 'unknown'} exit=${event.exitCode ?? 0}`);
      } else if (event.type === 'confirmation_required') {
        await confirmFromCli(session, event, question => rl.question(question));
      } else if (event.type === 'confirmation_received') {
        console.log(`\n[hitl] confirmation_received ${event.toolId ?? ''}`);
      } else if (event.type === 'confirmation_timeout') {
        console.log(`\n[hitl] confirmation_timeout ${event.toolId ?? ''}`);
      } else if (event.type === 'error') {
        throw new Error(event.error ?? 'stream error');
      }
    }

    console.log('\n[hitl] stream complete');
  } finally {
    rl.close();
    await session.cancelConfirmations();
  }