ws://api.60db.ai/ws/stt?apiKey=sk_live_your_api_key_here

const WebSocket = require('ws');

const API_KEY = 'sk_live_your_key';
const ws = new WebSocket(`wss://api.60db.ai/ws/stt?apiKey=${API_KEY}`);

ws.onopen = () => console.log('✅ Connected');

ws.onmessage = (data) => {
  const msg = JSON.parse(data);

  // STT tags this frame with `type` and keeps the fields top-level
  // (TTS nests them under `connection_established` — the shapes differ).
  if (msg.type === 'connection_established') {
    console.log('✅ Authenticated!');

    // Start session
    ws.send(JSON.stringify({
      type: 'start',
      languages: ['en'],
      config: {
        encoding: 'mulaw',
        sample_rate: 8000,
        continuous_mode: true
      }
    }));
  }

  // Wait for `session_started`, not `connected` — `connected` fires before
  // the session exists and arrives twice (proxy frame, then upstream frame).
  if (msg.type === 'session_started') {
    console.log('✅ Ready! Send audio now');

    // Send audio chunks
    const interval = setInterval(() => {
      ws.send(audioBuffer); // Your audio data
    }, 60);

    // Stop after 5 seconds
    setTimeout(() => {
      clearInterval(interval);
      ws.send(JSON.stringify({ type: 'stop' }));
    }, 5000);
  }

  if (msg.type === 'transcription') {
    console.log('📝 Text:', msg.text);
  }

  if (msg.type === 'session_stopped') {
    console.log('✅ Done! Cost:', msg.billing_summary.total_cost);
    ws.close();
  }
};

1. Connect → 2. Authenticate → 3. Start session → 4. Send audio → 5. Get text → 6. Stop

const WebSocket = require('ws');
const fs = require('fs');

const API_KEY = 'sk_live_your_key';
const ws = new WebSocket(`wss://api.60db.ai/ws/tts?apiKey=${API_KEY}`);
const contextId = 'my-session-' + Date.now();
const audioChunks = [];

ws.onopen = () => console.log('✅ Connected');

ws.onmessage = (data) => {
  const msg = JSON.parse(data);

  if (msg.connection_established) {
    console.log('✅ Authenticated!');

    // Create context
    ws.send(JSON.stringify({
      create_context: {
        context_id: contextId,
        voice_id: 'fbb75ed2-975a-40c7-9e06-38e30524a9a1',
        audio_config: {
          audio_encoding: 'LINEAR16',
          sample_rate_hertz: 16000
        }
      }
    }));
  }

  if (msg.context_created) {
    console.log('✅ Context created!');

    // Send text
    ws.send(JSON.stringify({
      send_text: {
        context_id: contextId,
        text: 'Hello, this is a test of the text to speech service.'
      }
    }));

    // Flush
    ws.send(JSON.stringify({
      flush_context: { context_id: contextId }
    }));
  }

  if (msg.audio_chunk) {
    const audioData = Buffer.from(msg.audio_chunk.audioContent, 'base64');
    audioChunks.push(audioData);
    console.log('🔊 Audio chunk received');
  }

  if (msg.flush_completed) {
    console.log('✅ All audio received!');

    // Close context
    ws.send(JSON.stringify({
      close_context: { context_id: contextId }
    }));
  }

  if (msg.context_closed) {
    console.log('✅ Done!');

    // Save audio
    const audio = Buffer.concat(audioChunks);
    fs.writeFileSync('output.pcm', audio);
    console.log('💾 Saved output.pcm');

    ws.close();
  }
};

1. Connect → 2. Authenticate → 3. Create context → 4. Send text → 5. Flush → 6. Get audio → 7. Close

// Start session
{ type: "start", languages: ["en"], config: {...} }

// Stop session
{ type: "stop" }

// Create context
{ create_context: { context_id, voice_id, audio_config } }

// Send text
{ send_text: { context_id, text: "..." } }

// Get audio
{ flush_context: { context_id } }

// Close session
{ close_context: { context_id } }