A5S Streaming

import asyncio, json, os, websockets

async def main():
    headers = {"Authorization": f"Bearer {os.environ['AIRCAPS_API_KEY']}"}
    async with websockets.connect("wss://api.aircaps.com/v1/realtime",
                                  additional_headers=headers) as ws:
        await ws.send(json.dumps({
            "type": "start", "providers": ["a5sv2"],
            "encoding": "pcm_s16le", "sample_rate": 16000, "channels": 1,
            "language": "en", "diarization": True,
        }))
        # send 20 ms PCM frames, then {"type": "finish"}
        async for message in ws:
            event = json.loads(message)
            if event["type"] == "transcript" and event["is_final"]:
                print(event["text"])

asyncio.run(main())

# the first message on wss://api.aircaps.com/v1/realtime
{
  "type": "start",
  "providers": ["a5sv2"],
  "encoding": "pcm_s16le",
  "sample_rate": 16000,
  "channels": 1,
  "language": "en",
  "diarization": true,
  "custom_vocabulary": [{"text": "AirCaps", "strength": 6}]
}

# then binary audio frames; "ready" arrives before the first one is read