Streaming voice with Agent

import { Agent, openai } from "@agentium/core";
import {
  AgentVoiceBrain,
  ElevenLabsSynthesizer,
  SarvamRecognizer,
  StreamingVoicePipeline,
  type VoiceTransport,
} from "@agentium/core/voice";

async function openVoice(transport: VoiceTransport, voiceId: string) {
  const agent = new Agent({ name: "support", model: openai(process.env.OPENAI_MODEL ?? "gpt-6.1-sol") });
  const pipeline = new StreamingVoicePipeline({
    recognizer: new SarvamRecognizer(),
    synthesizer: new ElevenLabsSynthesizer({ voiceId }),
    brain: new AgentVoiceBrain(agent, { tenantId: "local-demo", userId: "developer" }),
    transport,
    language: "hi-IN",
  });
  try {
    await pipeline.open();
  } catch (error) {
    await pipeline.close();
    await agent.close();
    throw error;
  }
  return { pipeline, agent }; // The host closes both when the call ends.
}