6. Stream and inspect a run

import { Agent, defineTool, openai } from "@agentium/core";
import { z } from "zod";

const orders = new Map([
  ["ORD-1042", { status: "shipped", delivery: "Friday", refundable: true }],
]);
const lookupOrder = defineTool({
  name: "lookup_order",
  description: "Look up an order's status and expected delivery by its ID.",
  parameters: z.object({ orderId: z.string() }),
  execute: async ({ orderId }) => JSON.stringify(orders.get(orderId) ?? { error: "Order not found" }),
});
const agent = new Agent({
  name: "support",
  model: openai(process.env.OPENAI_MODEL ?? "gpt-6.1-sol"),
  instructions: "Use lookup_order for order details. If the order is missing, say so.",
  tools: [lookupOrder],
  maxToolRoundtrips: 3,
});

agent.eventBus.on("tool.call", ({ toolName }) => {
  console.error(`[tool] ${toolName}`);
});

try {
  for await (const chunk of agent.stream("When will ORD-1042 arrive?")) {
    if (chunk.type === "text") process.stdout.write(chunk.text);
  }
  process.stdout.write("\n");
} finally {
  await agent.close();
}