ElevenLabs SDK-compatible realtime STT (WebSocket)

import { readFile } from "node:fs/promises";import WebSocket from "ws";const audioChunk = await readFile("chunk.pcm");const ws = new WebSocket("wss://api.allmodels.io/el/v1/speech-to-text/realtime?model_id=deepgram/nova-3&audio_format=pcm_16000&sample_rate=16000", {  headers: { Authorization: `Bearer ${process.env.ALLMODELS_API_KEY}` }});ws.on("open", () => {  ws.send(JSON.stringify({ message_type: "input_audio_chunk", audio_base_64: audioChunk.toString("base64"), sample_rate: 16000, commit: true }));});ws.on("message", (data, isBinary) => {  if (isBinary) process.stdout.write(data);  else console.log(JSON.parse(data.toString()));});ws.on("error", console.error);

import asyncioimport base64import jsonimport osfrom pathlib import Pathimport websocketsasync def main():    async with websockets.connect(        "wss://api.allmodels.io/el/v1/speech-to-text/realtime?model_id=deepgram/nova-3&audio_format=pcm_16000&sample_rate=16000",        additional_headers={"Authorization": f"Bearer {os.environ['ALLMODELS_API_KEY']}"},    ) as socket:        audio = base64.b64encode(Path("chunk.pcm").read_bytes()).decode("ascii")        await socket.send(json.dumps({"message_type": "input_audio_chunk", "audio_base_64": audio, "sample_rate": 16000, "commit": True}))        async for message in socket:            print(message if isinstance(message, str) else f"{len(message)} audio bytes")asyncio.run(main())

curl --http1.1 -i "https://api.allmodels.io/el/v1/speech-to-text/realtime?model_id=deepgram/nova-3&audio_format=pcm_16000&sample_rate=16000" \  -H "Authorization: Bearer $ALLMODELS_API_KEY" \  -H "Connection: Upgrade" \  -H "Upgrade: websocket" \  -H "Sec-WebSocket-Version: 13" \  -H "Sec-WebSocket-Key: SGVsbG9BbGxNb2RlbHMhIQ=="

import { AudioFormat, CommitStrategy, ElevenLabsClient, RealtimeEvents } from "@elevenlabs/elevenlabs-js";import { readFile } from "node:fs/promises";const client = new ElevenLabsClient({  apiKey: process.env.ALLMODELS_API_KEY,  baseUrl: "https://api.allmodels.io/el"});const connection = await client.speechToText.realtime.connect({  modelId: "deepgram/nova-3",  audioFormat: AudioFormat.PCM_16000,  sampleRate: 16000,  languageCode: "en",  includeTimestamps: true,  commitStrategy: CommitStrategy.MANUAL});connection.on(RealtimeEvents.PARTIAL_TRANSCRIPT, ({ text }) => console.log("partial", text));connection.on(RealtimeEvents.COMMITTED_TRANSCRIPT, ({ text }) => console.log("final", text));connection.send({ audioBase64: (await readFile("chunk.pcm")).toString("base64") });connection.commit();

import asyncioimport osfrom pathlib import Pathfrom elevenlabs.realtime.scribe import AudioFormat, CommitStrategy, ScribeRealtime, websocket_connectasync def main():    client = ScribeRealtime(        api_key=os.environ["ALLMODELS_API_KEY"],        base_url="https://api.allmodels.io/el",    )    url = client._build_websocket_url(        model_id="deepgram/nova-3",        audio_format=AudioFormat.PCM_16000.value,        commit_strategy=CommitStrategy.MANUAL.value,        language_code="en",    )    socket = await websocket_connect(        url,        additional_headers={"Authorization": f"Bearer {os.environ['ALLMODELS_API_KEY']}"},    )    await socket.send(Path("chunk.pcm").read_bytes())    async for event in socket:        print(event)asyncio.run(main())