Direct API integration

import WebSocket from 'ws';

const API = process.env.FACEMODE_API_URL ?? 'https://api.facemode.io/api';
const headers = {
  'x-api-key': process.env.FACEMODE_API_KEY,
  'Content-Type': 'application/json',
};

// 1. Create the session.
const created = await fetch(`${API}/sessions`, {
  method: 'POST',
  headers,
  body: JSON.stringify({
    avatarId: process.env.FACEMODE_AVATAR_ID,
    room: {
      type: 'livekit',
      url: process.env.LIVEKIT_URL,
      token: process.env.LIVEKIT_WORKER_TOKEN, // server-side only
      name: process.env.LIVEKIT_ROOM_NAME,
    },
  }),
}).then((r) => r.json());

let session = created;
while (!session.ingestion.ready) {
  if (session.workerStatus === 'FAILED' || session.workerStatus === 'ENDED') {
    throw new Error(`worker entered ${session.workerStatus} state`);
  }
  await new Promise((r) => setTimeout(r, 500));
  session = await fetch(`${API}/sessions/${session.sessionId}`, { headers })
    .then((r) => r.json());
}

// 2. Open the socket with the facemode.<wsToken> subprotocol.
const ws = new WebSocket(session.ingestion.url, [`facemode.${session.ingestion.wsToken}`], {
  perMessageDeflate: false,
});
await new Promise((resolve, reject) => {
  ws.once('open', resolve);
  ws.once('error', reject);
});

let seq = 0;
ws.on('message', (data, isBinary) => {
  if (isBinary) return;
  const msg = JSON.parse(data.toString());
  // started | audio_ready | utterance_ended | pong | session_ending | ended | error
});

// 3. start -> started, then stream ~100 ms binary PCM chunks.
ws.send(JSON.stringify({
  type: 'start',
  session_id: session.sessionId,
  audio_encoding: 'pcm_s16le',
  sample_rate: 24000,
  channels: 1,
  avatar_id: process.env.FACEMODE_AVATAR_ID ?? '',
}));

// inside your TTS/audio pipeline:
ws.send(JSON.stringify({ type: 'start_utterance', seq: seq++ }));
ws.send(pcmChunk, { binary: true });          // ~100 ms per binary frame
ws.send(JSON.stringify({ type: 'end_utterance', seq: seq++ }));

// heartbeat after started, roughly every 15s:
// ws.send(JSON.stringify({ type: 'ping', ts: Date.now() }));

// 4. Graceful close.
ws.send(JSON.stringify({ type: 'end_session', seq: seq++ }));