Events & Callbacks

import { Voice } from "@clutchcall/sdk/voice";

const voice = new Voice({ baseUrl, apiKey, orgId });

// Server side: consume caller audio, publish agent audio back.
const bridge = await voice.audioBridge.attach(call.sid, {
  codec: "opus",
  onUplink(frame, tsUs) {
    // one encoded caller frame — feed it to your ASR / recorder
    asr.push(frame, tsUs);
  },
});

// Send audio the other way, frame by frame.
tts.onChunk((opus) => bridge.publishDownlink(opus));

// Browser-caller side is the mirror: subscribe downlink, publish mic uplink.
const caller = await voice.audioBridge.attachCaller(call.sid, {
  codec: "opus",
  onDownlink(frame, tsUs) {
    player.enqueue(frame, tsUs); // play cloud audio to the human
  },
});
mic.onEncodedFrame((opus) => caller.publishUplink(opus));

// Poll for the state you care about — there is no push event for this.
async function waitForAnswer(sid: string, timeoutMs = 30_000): Promise<Call> {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const call = await voice.calls.get({ sid });
    if (call.status === "in_progress") return call;
    if (["completed", "failed", "no_answer"].includes(call.status)) {
      throw new VoiceError(`call ended: ${call.status}`);
    }
    await new Promise((r) => setTimeout(r, 1000));
  }
  throw new VoiceError("timed out waiting for answer");
}