import asyncio, json, websockets

async def transcribe(frames):
    url = "wss://app.voho.ai/v1/transcribe/ws"
    headers = {"Authorization": f"Bearer {API_KEY}"}

    async with websockets.connect(url, additional_headers=headers) as ws:
        await ws.recv()                                   # ready
        await ws.send(json.dumps({"type": "start", "language": "ar-SA", "sample_rate": 16000}))
        await ws.recv()                                   # started

        async def send():
            async for frame in frames:                    # 16-bit PCM at 16 kHz
                await ws.send(frame)
            await ws.send(json.dumps({"type": "stop"}))

        sender = asyncio.create_task(send())
        async for raw in ws:
            msg = json.loads(raw)
            if msg["type"] == "transcript":
                print("final  " if msg["final"] else "interim", msg["text"])
            elif msg["type"] == "done":
                print(msg["seconds"], "s,", msg["cost_cents"], "cents")
                break
        await sender

{ "type": "transcript", "text": "السلام عليكم", "final": false }
{ "type": "transcript", "text": "السلام عليكم أبغى أغير", "final": false }
{ "type": "transcript", "text": "السلام عليكم، أبغى أغيّر الموعد.", "final": true, "confidence": 0.91 }
{ "type": "done", "seconds": 4.2, "cost_cents": 3 }