// Server: the STT model decides when the turn ends
transcriber = new WorkersAIFluxSTT(this.env.AI, {
  eotThreshold: 0.8,
});

// Client: how loud before the caller interrupts playback?
useVoiceAgent({ agent: "FrontDesk",
  interruptThreshold: 0.05, interruptChunks: 2 });

transcriber = new WorkersAIFluxSTT(this.env.AI, {
  keyterms: ["Okafor", "cleaning", "Maple Street"],
});

afterTranscribe(text) {            // clean up or drop noise
  return text.length < 3 ? null : text;
}
beforeSynthesize(text) {           // say it the right way
  return text.replace(/\bDr\. /g, "Doctor ");
}

async onTurn(transcript, { messages, signal }) {
  const result = streamText({
    model, tools,
    messages: [...messages, { role: "user", content: transcript }],
    abortSignal: signal,   // aborts on interrupt or hang-up
  });
  return result.textStream;
}
// Stops the model and the speech. Not a request already sent.

beforeCallStart(connection) {
  return isAuthorized(connection);   // your check; false rejects
}

streamText({ model, messages, tools,
  activeTools: this.state.verified
    ? ["findSlots", "bookSlot", "cancelSlot"]
    : ["verifyCaller", "findSlots"],
});

// Hand the write to a Workflow: it outlives the call
await this.env.BOOKING.create({
  id: `booking-${callId}-${slotId}`,   // same id, no duplicate
  params: { patientId, slotId },
});

// History survives restarts; the agent can pick the call back up
const history = this.getConversationHistory(20);

// Every turn reports its own timing
const { metrics, sendText } = useVoiceAgent({ agent: "FrontDesk" });
// { llm_ms, tts_ms, first_audio_ms, total_ms }

// Same pipeline, no microphone: script your test callers
sendText("Move my cleaning to Thursday.");