Transfer work to a specialist

import { Agent, EventBus, type AgentEventMap, type ModelProvider } from "@agentium/core";

export async function routeToBilling(model: ModelProvider, input: string) {
  const eventBus = new EventBus();
  const billing = new Agent({
    name: "billing", model, register: false, eventBus,
    instructions: "Help with invoices. Ask for an invoice ID when missing. Do not claim to issue refunds.",
  });
  const frontDesk = new Agent({
    name: "front-desk", model, register: false, eventBus,
    instructions: "Transfer billing questions to billing. Answer other questions briefly.",
    handoff: {
      targets: [{ agent: billing, description: "Billing and invoice questions" }],
      maxHandoffs: 2,
    },
  });
  const completed = ({ chain, finalAgent }: AgentEventMap["handoff.complete"]) => {
    console.log("handoff:", chain, "final agent:", finalAgent);
  };
  eventBus.on("handoff.complete", completed);
  try {
    const result = await frontDesk.run(input);
    console.log(result.text);
    return result;
  } finally {
    eventBus.off("handoff.complete", completed);
    try { await frontDesk.close(); } finally { await billing.close(); }
  }
}

import { Agent, type ModelProvider, type RunContext } from "@agentium/core";

export function createAuthorizedRouter(
  model: ModelProvider,
  specialist: Agent,
  authorize: (context: RunContext) => Promise<boolean>,
) {
  return new Agent({
    name: "authorized-router", model, register: false,
    instructions: "Transfer account questions to the configured specialist.",
    handoff: { targets: [{
      agent: specialist, description: "Account support",
      onHandoff: async (context) => {
        if (!await authorize(context)) throw new Error("Specialist access denied");
      },
    }] },
  });
}