Build Streaming Specialists

import { AgentBuilder } from "@anvia/core";
import { model } from "./model";

export const supportAgent = new AgentBuilder("support", model)
  .name("Support Specialist")
  .description("Summarize customer impact and support next steps.")
  .instructions("Return compact support triage bullets using only the provided facts.")
  .build();

export const engineeringAgent = new AgentBuilder("engineering", model)
  .name("Engineering Specialist")
  .description("Summarize diagnostics and engineering next steps.")
  .instructions("Return compact engineering triage bullets without unverified root-cause claims.")
  .build();

export const commsAgent = new AgentBuilder("communications", model)
  .name("Communications Specialist")
  .description("Draft customer-facing incident communication guidance.")
  .instructions("Return concise customer-safe communication notes.")
  .build();

import { AgentBuilder } from "@anvia/core";
import { commsAgent, engineeringAgent, supportAgent } from "./specialists";
import { model } from "./model";

export const coordinator = new AgentBuilder("incident-coordinator", model)
  .name("Incident Coordinator")
  .instructions(
    [
      "Coordinate specialist agents through tools.",
      "Call specialists only when their expertise is useful.",
      "Combine specialist findings into one concise incident brief.",
      "Do not expose internal-only notes in the final customer-facing summary.",
    ].join("\n"),
  )
  .tools([
    supportAgent.asTool({ name: "ask_support_agent", stream: true }),
    engineeringAgent.asTool({ name: "ask_engineering_agent", stream: true }),
    commsAgent.asTool({ name: "ask_comms_agent", stream: true }),
  ])
  .defaultMaxTurns(4)
  .build();

const prompt = [
  "Acme Co. reports webhook retries fail for payloads larger than 512 KB.",
  "They have missed several order updates in the last hour.",
  "Prepare an incident brief for support, engineering, and communications.",
].join(" ");

for await (const event of coordinator
  .prompt(prompt)
  .withToolConcurrency(3)
  .withTrace({
    name: "incident-multi-agent-stream",
    metadata: {
      incidentId: "inc_123",
      tenantId: "tenant_123",
    },
  })
  .stream()) {
  renderEvent(event);
}