BizCrush API

import asyncio
import json
import websockets

async def live_stt(api_key: str):
    url = f"wss://extapi.bizcrush.ai/v1/stt/stream?api_key={api_key}&format=json"

    async with websockets.connect(url) as ws:
        await ws.send(json.dumps({"encoding": "pcm16"}))

        resp = json.loads(await ws.recv())
        assert resp["connected"], f"Connection failed: {resp}"

        async def send_audio():
            with open("audio.pcm", "rb") as f:
                while chunk := f.read(640):
                    await ws.send(chunk)
                    await asyncio.sleep(0.02)
            # End-of-audio marker. DO NOT close the WebSocket here — the
            # server needs the connection open to deliver trailing finals.
            # The server will close after finalize completes (~5 seconds).
            await ws.send(b'')

        async def receive_results():
            try:
                async for msg in ws:
                    data = json.loads(msg)
                    if "chunk" in data:
                        chunk = data["chunk"]
                        status = "FINAL" if chunk["is_final"] else "interim"
                        speaker = chunk.get("speaker", "?")
                        print(f"[{status}] (S{speaker}) {chunk['text']}")
            except websockets.exceptions.ConnectionClosed:
                pass

        await asyncio.gather(send_audio(), receive_results())

asyncio.run(live_stt("YOUR_API_KEY"))

const ws = new WebSocket(
  "wss://extapi.bizcrush.ai/v1/stt/stream?api_key=YOUR_API_KEY&format=json"
);

ws.onopen = () => {
  ws.send(JSON.stringify({ encoding: "pcm16" }));
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);

  if (data.connected) {
    console.log("Connected! Start sending audio...");
  }

  if (data.chunk) {
    const { id, text, is_final, speaker } = data.chunk;
    console.log(`[${is_final ? "FINAL" : "interim"}] (S${speaker ?? "?"}) ${text}`);
  }
};

// Server closes the WebSocket after delivering trailing finals.
ws.onclose = () => {
  console.log("Stream finalized by server");
};

function sendAudioChunk(pcmData) {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(pcmData);
  }
}

// Call this when you have no more audio to send.
// DO NOT call ws.close() — the server needs the socket open to deliver
// trailing finals, then closes it itself (~5 seconds).
function endStream() {
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(new ArrayBuffer(0));  // end-of-audio marker
  }
}