Stream Audio (WebSocket)

import asyncio
import websockets
import json

API_KEY = "YOUR_API_KEY"
WS_URL = "wss://api-web.eigenai.com/api/v1/generate/ws"

async def stream_audio():
    async with websockets.connect(WS_URL) as ws:
        # Step 1: Authenticate
        await ws.send(json.dumps({"token": API_KEY, "model": "higgs2p5"}))

        # Step 2: Send TTS request
        await ws.send(json.dumps({"text": "Hello, streaming audio world!", "voice": "Linda"}))

        # Step 3: Receive audio chunks
        with open("output.pcm", "wb") as f:
            async for message in ws:
                if isinstance(message, bytes):
                    f.write(message)
                else:
                    data = json.loads(message)
                    if data.get("type") == "complete":
                        print("Stream complete")
                        break

asyncio.run(stream_audio())

const WebSocket = require("ws");
const fs = require("node:fs");

const API_KEY = "YOUR_API_KEY";
const ws = new WebSocket("wss://api-web.eigenai.com/api/v1/generate/ws");
const output = fs.createWriteStream("output.pcm");

ws.on("open", () => {
  // Step 1: Authenticate
  ws.send(JSON.stringify({ token: API_KEY, model: "higgs2p5" }));

  // Step 2: Send TTS request
  ws.send(JSON.stringify({ text: "Hello, streaming audio world!", voice: "Linda" }));
});

ws.on("message", (data) => {
  if (Buffer.isBuffer(data)) {
    // Binary PCM chunk
    output.write(data);
  } else {
    const msg = JSON.parse(data.toString());
    if (msg.type === "complete") {
      console.log("Stream complete");
      output.end();
      ws.close();
    }
  }
});