Streaming audio

import asyncio
import json
import os

import websockets


async def main():
    url = (
        "wss://api.typelessapi.com/v1/transcribe/stream"
        f"?token={os.environ['TYPELESS_API_KEY']}"
        "&model=typeless-1.0-pro"
        "&sample_rate=16000&channels=1&encoding=pcm16"
    )
    async with websockets.connect(url) as ws:
        # meeting.pcm: raw 16 kHz mono little-endian pcm16
        with open("meeting.pcm", "rb") as f:
            while chunk := f.read(3200):  # 100 ms per frame
                await ws.send(chunk)
                await asyncio.sleep(0.1)
        await ws.send(json.dumps({"type": "close_stream"}))
        async for message in ws:
            event = json.loads(message)
            if event["type"] == "result":
                print(event["result"]["transcript"])
                break


asyncio.run(main())

import fs from "node:fs";
import WebSocket from "ws";

const url =
  "wss://api.typelessapi.com/v1/transcribe/stream" +
  `?token=${process.env.TYPELESS_API_KEY}` +
  "&model=typeless-1.0-pro" +
  "&sample_rate=16000&channels=1&encoding=pcm16";

const ws = new WebSocket(url);

ws.on("open", () => {
  const pcm = fs.readFileSync("meeting.pcm"); // raw 16 kHz mono pcm16
  const frame = 3200; // 100 ms per frame
  let offset = 0;
  const timer = setInterval(() => {
    if (offset >= pcm.length) {
      clearInterval(timer);
      ws.send(JSON.stringify({ type: "close_stream" }));
      return;
    }
    // production code should check ws.bufferedAmount before sending
    ws.send(pcm.subarray(offset, offset + frame));
    offset += frame;
  }, 100);
});

ws.on("message", (data) => {
  const event = JSON.parse(data.toString());
  if (event.type === "result") {
    console.log(event.result.transcript);
    ws.close();
  }
});