Sesame CSM-1B WebSocket TTS

Real-time TTS service exposing Sesame CSM-1B over a WebSocket protocol that mirrors the ElevenLabs stream-input API. Designed for phone-call scenarios: clients stream text in, get audio chunks back as they're generated.

Built on cartesia-one/csm.rs for the underlying Candle-based inference (CUDA / cuDNN / Metal / Accelerate / MKL).

Layout

csm-core/   vendored from cartesia-one/csm.rs (model + Mimi decoder)
csm-ws/     this project — axum WebSocket server
Dockerfile  CUDA + cuDNN runtime image for prod

Build

Dev (macOS, Apple Silicon GPU):

cargo build --release -p csm-ws --features metal

Prod (Linux + NVIDIA):

cargo build --release -p csm-ws --features cudnn
# or just CUDA without cuDNN:
cargo build --release -p csm-ws --features cuda

Run

./target/release/csm-ws \
    --model-id sesame/csm-1b \
    --port 8080 \
    --pool-size 1

Models are pulled from the Hugging Face Hub on first use and cached under ~/.cache/huggingface/. For a quantized GGUF model:

./target/release/csm-ws \
    --model-id cartesia/sesame-csm-1b-gguf \
    --model-file q8.gguf

Flags

Voice map file (--voices-file)

{
  "rachel": 0,
  "adam": 1,
  "sales-bot-en-us": 2
}

Without this flag, the defaults default, speaker_0..speaker_3 are recognized, plus any numeric voice_id ("0", "1", ...) passes through.

Output formats

All endpoints accept ?output_format=<fmt>:

Default if output_format is omitted: WebSocket → pcm_24000, REST → mp3_44100_128 (matches ElevenLabs).

WAV streams use a "streaming header" with 0xFFFFFFFF length fields — ffmpeg, ffplay, and browsers all play them; Windows Media Player may complain.

REST API

ElevenLabs-shaped HTTP endpoints, all POST with a JSON body and an output_format query param.

Common request body

{
  "text": "Hello world.",

  // Sesame-specific (optional):
  "speaker_id": 0,
  "temperature": 0.7,
  "top_k": 100,
  "max_audio_len_ms": 30000,

  // ElevenLabs-parity, accepted but ignored:
  "model_id": "eleven_turbo_v2",
  "voice_settings": { "stability": 0.5 }
}

Auth: pass xi-api-key: <key> header (or ?xi-api-key=<key>) if the server was started with --api-key.

POST /v1/text-to-speech/{voice_id} — full body

Generates the entire utterance, then sends the complete file. Use when you need a Content-Length header or you're saving to disk.

curl -X POST 'http://localhost:8080/v1/text-to-speech/default?output_format=mp3_44100_128' \
    -H 'Content-Type: application/json' \
    -d '{"text": "Hello from Sesame."}' \
    --output out.mp3

POST /v1/text-to-speech/{voice_id}/stream — chunked transfer

Streams audio bytes as they're generated. Same content type as the full-body variant; just chunked. Use this for low-latency playback.

curl -X POST 'http://localhost:8080/v1/text-to-speech/default/stream?output_format=wav_24000' \
    -H 'Content-Type: application/json' \
    -d '{"text": "Hello from Sesame."}' \
    | ffplay -nodisp -autoexit -

POST /v1/text-to-speech/{voice_id}/stream/with-timestamps — SSE

Server-Sent Events. Each data: line is a JSON object:

{"audio_base64": "<...>", "alignment": null, "normalized_alignment": null}

alignment is always null — CSM-1B doesn't expose forced-alignment data. The endpoint exists for ElevenLabs API parity. If you need timestamps, use the streaming endpoint above and timestamp on the client.

curl -N -X POST 'http://localhost:8080/v1/text-to-speech/default/stream/with-timestamps?output_format=mp3_44100_128' \
    -H 'Content-Type: application/json' \
    -d '{"text": "Hello from Sesame."}'

WebSocket protocol

Connect

ws://host:8080/v1/text-to-speech/{voice_id}/stream-input?output_format={format}

Query params:

• output_format — see Output formats. Default pcm_24000.
• xi-api-key — required if server was started with --api-key.
• speaker_id, temperature, top_k, max_audio_len_ms — optional generation overrides.

Client → server messages

// Append text. Server buffers until a sentence boundary, then generates.
{"text": "Hello there. "}

// Force the server to generate whatever's buffered now.
{"text": "more text ", "flush": true}

// Per-message overrides (Sesame extension, not in ElevenLabs API):
{"text": "...", "speaker_id": 2, "temperature": 0.6, "top_k": 50}

// End-of-stream — flushes any remaining text and closes.
{"text": ""}

Server → client messages

// Audio chunk in the requested output_format, base64 encoded.
{"audio": "<base64>", "isFinal": false}

// Sent once after the final chunk for a generation.
{"audio": null, "isFinal": true}

Phone-call setup (Twilio Media Streams)

Connect with output_format=ulaw_8000. The base64 audio field decodes directly to the bytes Twilio expects in its media.payload.

Concurrency model

CSM-1B is autoregressive and keeps a per-session KV cache. Each WebSocket holds one generator instance for its lifetime. --pool-size is therefore the max number of concurrent calls the server can handle.

For an L4 / A10G (24 GB) you can fit ~8 fp16 instances. For an L40 / H100, substantially more. Set --pool-size to match your VRAM budget.

Latency notes

• CSM-1B generates audio at ~12.5 frames/sec internally (80 ms per Mimi frame).
• The server buffers ~4 frames (≈320 ms) before decoding the first audio chunk. This is --buffer-size in csm-core terms; configurable per-session.
• First-byte latency on an RTX 4090: ~250 ms typical.
• On Metal (M-series Mac dev): faster than realtime for fp32 weights.

Docker

docker build -t sesame-csm-ws --build-arg CUDA_COMPUTE_CAP=89 .
docker run --gpus all -p 8080:8080 \
    -v $HOME/.cache/huggingface:/home/csm/.cache/huggingface \
    sesame-csm-ws --model-id sesame/csm-1b

CUDA_COMPUTE_CAP values: 80 (A100), 86 (RTX 30xx), 89 (RTX 40xx / L4 / L40), 90 (H100).

Quick client (Python)

import asyncio, json, base64, websockets

async def main():
    uri = "ws://localhost:8080/v1/text-to-speech/default/stream-input?output_format=pcm_24000"
    async with websockets.connect(uri) as ws:
        await ws.send(json.dumps({"text": "Hello from sesame. How are you today? "}))
        await ws.send(json.dumps({"text": ""}))  # EOS
        with open("out.pcm", "wb") as f:
            async for raw in ws:
                msg = json.loads(raw)
                if msg.get("audio"):
                    f.write(base64.b64decode(msg["audio"]))
                if msg.get("isFinal"):
                    break

asyncio.run(main())

Play with: ffplay -f s16le -ar 24000 -ac 1 out.pcm

License

AGPL-3.0, inherited from csm.rs.