Event Streaming (SSE)

for await (const event of client.chatStream({ ... })) {
  switch (event.type) {
    case "conversation.message.created":
      // Initial acknowledgment
      break;
    case "message.created":
      // User message saved
      break;
    case "agent.response.delta":
      // Incremental text chunks from the LLM
      process.stdout.write(event.data.delta);
      break;
    case "agent.response.completed":
      // Finalization of the agent's full response
      console.log("\nFinished text:", event.data.content);
      break;
  }
}

for await (const event of client.chatStream({ ... })) {
  switch (event.type) {
    case "tool.execution.started":
      // 1. The agent decides to call a tool
      console.log(`Running tool: ${event.data.name}`, event.data.arguments);
      break;
    case "tool.execution.completed":
      // 2. The backend executes the tool and streams back the result
      console.log(`Tool ${event.data.name} completed. OK: ${event.data.ok}`);
      console.log(`Result: ${event.data.result}`);
      break;
    case "agent.response.delta":
      // 3. The agent reasons about the tool response and streams text
      process.stdout.write(event.data.delta);
      break;
    case "agent.response.completed":
      // 4. Final completion payload with full metadata
      console.log("Response complete. Tools used:", event.data.tool_calls);
      break;
  }
}

for await (const event of client.chatStream({ ... })) {
  switch (event.type) {
    case "tool.execution.completed":
      if (!event.data.ok) {
        console.error(`Tool failed: ${event.data.result}`);
      }
      break;
    case "error":
      // If the LLM integration completely drops or a critical pipeline error occurs
      console.error(`Critical Error: ${event.data.message}`);
      break;
  }
}