GPT Live 1 VoiceBeta

// Run only after the user explicitly clicks Start.
// Your server must proxy this connection and keep TOKENREX_API_KEY private.
// Upstream: wss://tokenrex.ai/api/public/v1/live?model=gpt-live-1-voice
const ws = new WebSocket("wss://YOUR_APP_HOST/live?model=gpt-live-1-voice");
const pc = new RTCPeerConnection();
pc.createDataChannel("oai-events");
// Receive audio only: do not capture a microphone for text reading.
pc.addTransceiver("audio", { direction: "recvonly" });
const audio = new Audio();
audio.autoplay = true;
pc.ontrack = (event) => {
  audio.srcObject = event.streams[0];
  audio.play().catch(() => showEnableAudio(() => audio.play()));
}; // showEnableAudio renders your explicit playback-unlock button.
await pc.setLocalDescription(await pc.createOffer());
await new Promise(resolve => pc.iceGatheringState === "complete" ? resolve() :
  pc.addEventListener("icegatheringstatechange", () => {
    if (pc.iceGatheringState === "complete") resolve();
  }));
await new Promise((resolve, reject) => {
  if (ws.readyState === WebSocket.OPEN) resolve();
  else { ws.onopen = resolve; ws.onerror = reject; }
});
let heartbeat;
ws.onmessage = async ({ data }) => {
  const event = JSON.parse(data);
  if (event.type === "gateway.session.created") {
    await pc.setRemoteDescription({ type: "answer", sdp: event.transport.sdp });
    heartbeat = setInterval(() => ws.send(JSON.stringify({ type: "gateway.heartbeat" })), 1000);
  }
  // Call speakText from your Send button after session.started.
  if (event.type === "session.output_transcript.delta") console.log(event.delta);
  if (event.type === "session.usage.updated") console.log("Billed seconds", event.usage.seconds);
  if (event.type === "tokenrex.error") console.error(event.error.message);
};
ws.send(JSON.stringify({
  type: "session.start",
  session: { audio: { output: { voice: "marin" } } },
  tools: [], transport: { type: "webrtc", sdp: pc.localDescription.sdp },
}));
function speakText(text) {
  // 1–1,500 characters; send only on explicit action, not automatic retries.
  ws.send(JSON.stringify({ type: "tokenrex.speak", text }));
}
function stop() {
  clearInterval(heartbeat);
  ws.send(JSON.stringify({ type: "session.close" }));
  audio.pause();
  pc.close();
  // Keep the socket until the final usage event; never reconnect automatically.
}