const form = new FormData();
form.append('file', blob, 'audio.wav');
const res = await fetch(
  'http://localhost:8124/transcribe',
  { method: 'POST', body: form }
);
const data = await res.json();

{
  "filename": "audio.wav",
  "text": "Xin chào, tôi cần hỗ trợ.",
  "segments": [{
    "id": 0, "start": 0.0, "end": 3.5,
    "text": "Xin chào, tôi cần hỗ trợ.",
    "avg_logprob": -0.15,
    "no_speech_prob": 0.001
  }],
  "duration": 3.84,
  "processing_time": 0.62
}

{
  "dialogues": [
    {
      "speaker": "SPEAKER_00",
      "start": 0.0, "end": 4.2,
      "text": "Xin chào bạn.",
      "words": [
        {"word": "Xin",   "start": 0.05, "end": 0.25},
        {"word": "chào",  "start": 0.28, "end": 0.55},
        {"word": "bạn.",  "start": 0.60, "end": 0.90}
      ]
    },
    {
      "speaker": "SPEAKER_01",
      "start": 4.5, "end": 7.1,
      "text": "Vâng, tôi nghe rồi.",
      "words": [...]
    }
  ],
  "processing_time": 12.5
}

const ws = new WebSocket(
  'ws://localhost:8124/ws/transcribe/vad'
);

// Float32 mic → Int16 → base64
function toBase64(f32) {
  const i16 = new Int16Array(f32.length);
  for (let i = 0; i < f32.length; i++)
    i16[i] = Math.round(f32[i] * 32767);
  const u8 = new Uint8Array(i16.buffer);
  let s = '';
  u8.forEach(b => s += String.fromCharCode(b));
  return btoa(s);
}

ws.send(JSON.stringify({
  audio_event: { audio_base_64: toBase64(chunk) }
}));
ws.send(JSON.stringify({ type: 'end' }));

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

  if (msg.type === 'ssap') {
    updateProfile(msg.properties); return;
  }
  if (msg.type === 'error') {
    console.error(msg.message); return;
  }
  if (msg.is_final) sendToLLM(msg.text);
  else              showPartial(msg.text);
};

{ "type": "transcript",
  "text": "Xin chào bạn",
  "is_final": false }

{ "type": "transcript",
  "text": "Xin chào bạn ơi.",
  "is_final": true }

{ "type": "ssap",
  "properties": {
    "gender":  {"female": 0.92, "male": 0.08},
    "age":     {"adult": 0.75, "young": 0.2},
    "emotion": {"neutral": 0.6, "happy": 0.3}
  }
}

const ws = new WebSocket(
  'ws://localhost:8124/ws/voice-chat'
);

ws.onopen = () => {
  ws.send(JSON.stringify({
    type: 'config',
    speaker_id: 'uuid-...',
    collection_id: 'uuid-...',
    language: 'vi',
    llm_model: 'gpt-4o-mini',
    ssap: true
  }));
};

ws.onmessage = ({ data }) => {
  // Binary = TTS PCM audio
  if (data instanceof ArrayBuffer) {
    playPcm(data, 24000); return;
  }
  const msg = JSON.parse(data);
  switch (msg.type) {
    case 'ready':      onReady(); break;
    case 'transcript': onTranscript(msg); break;
    case 'thinking':   showSpinner(); break;
    case 'agent_text': appendText(msg.text); break;
    case 'agent_end':  onResponseEnd(); break;
    case 'ssap':       updateProfile(msg); break;
    case 'latency':    logLatency(msg); break;
    case 'error':      onError(msg); break;
  }
};

// Server detects lang from ASR output prefix:
// [vi] → Vietnamese TTS speaker
// [en] → English TTS speaker
// [fr] → French TTS speaker
// [ja] → Japanese TTS speaker
// [ko] → Korean TTS speaker
// [zh] → Chinese TTS speaker
// [ru] → Russian TTS speaker
// Uses collection_id to pick correct speaker

const form = new FormData();
form.append('file', audioBlob, 'ref.wav');
form.append('name', 'Nguyen Van A');
form.append('description', 'Customer support');
const res = await fetch(
  'http://localhost:8124/voice/register',
  { method: 'POST', body: form }
);

{
  "status": "success",
  "speaker_id": "a1b2c3d4-...",
  "file_path": "speakers/a1b2c3d4-....wav"
}

{
  "speaker_id": "a1b2c3d4-...",
  "reference": "speakers/a1b2.wav",
  "results": [
    {
      "file": "test1.wav",
      "score": 4.21,
      "verdict": "ACCEPT",
      "path": "tmp/test1.wav"
    },
    {
      "file": "test2.wav",
      "score": 1.03,
      "verdict": "REJECT",
      "path": "tmp/test2.wav"
    }
  ]
}

const form = new FormData();
form.append('reference', refBlob, 'ref.wav');
form.append('files',     t1Blob,  'test1.wav');
form.append('files',     t2Blob,  'test2.wav');
const res = await fetch(
  '.../voice/verify_with_reference',
  { method: 'POST', body: form }
);

{
  "reference_file": "ref.wav",
  "results": [
    {"file":"test1.wav","score":3.9,"verdict":"ACCEPT"},
    {"file":"test2.wav","score":0.8,"verdict":"REJECT"}
  ]
}

{
  "results": [
    {
      "file": "sample.wav",
      "result": "real",
      "is_real": true,
      "score": 0.89,
      "threshold": 0.5,
      "confidence": 0.94,
      "qa_passed": true
    },
    {
      "file": "fake.wav",
      "result": "fake",
      "is_real": false,
      "score": 0.12,
      "threshold": 0.5,
      "confidence": 0.97,
      "qa_passed": true
    }
  ]
}

const pc = new RTCPeerConnection({
  iceServers: [
    { urls: 'stun:webrtc.svisor.vn:3478' },
    { urls: 'turns:webrtc.svisor.vn:3478',
      username: 'coturnuser',
      credential: 'coturnpass@spX2025' },
    { urls: 'turn:webrtc.svisor.vn:3478',
      username: 'coturnuser',
      credential: 'coturnpass@spX2025' }
  ],
  bundlePolicy: 'max-bundle',
  rtcpMuxPolicy: 'require'
});

// Add audio transceiver (send + receive)
pc.addTransceiver('audio', { direction: 'sendrecv' });

// Create data channel for text events
const dc = pc.createDataChannel('chat');

// Add local mic track
const stream = await navigator.mediaDevices
  .getUserMedia({ audio: true });
stream.getTracks().forEach(t => pc.addTrack(t, stream));

// Create & send offer
const offer = await pc.createOffer();
await pc.setLocalDescription(offer);

const BASE = '{WEBRTC_API_URL}';
const res = await fetch(BASE + '/offer', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({
    sdp: offer.sdp, type: offer.type,
    speaker_id: 'uuid-...',
    user_system_prompt: 'You are a helpful assistant.'
  })
});
const answer = await res.json();
const pcId = answer.pc_id;
await pc.setRemoteDescription(answer);

{
  "pc_id": "abc123-...",
  "sdp":  "v=0\r\no=- ...",
  "type": "answer"
}

const BASE = '{WEBRTC_API_URL}';

pc.onicecandidate = async ({ candidate }) => {
  await fetch(BASE + '/ice', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      pc_id: pcId,
      candidate: candidate
        ? {
            candidate:     candidate.candidate,
            sdpMid:        candidate.sdpMid,
            sdpMLineIndex: candidate.sdpMLineIndex
          }
        : null   // null = end of gathering
    })
  });
};

dc.onopen = () => console.log('Connected');

dc.onmessage = ({ data }) => {
  const msg = JSON.parse(data);
  if (msg.type === 'transcription') {
    showUserText(msg.text);
  } else if (msg.type === 'agent_text') {
    appendAgentText(msg.text);
  }
};

// Send text input (bypasses ASR)
dc.send('What is the weather today?');

const audio = document.createElement('audio');
audio.autoplay = true;

pc.ontrack = ({ streams }) => {
  audio.srcObject = streams[0];
  audio.play();
};

// User speech → ASR result
{ "type": "transcription",
  "text": "Xin chào bạn." }

// Agent LLM response (streamed)
{ "type": "agent_text",
  "text": "Chào bạn! Tôi có thể" }
{ "type": "agent_text",
  "text": " giúp gì cho bạn?" }

const ws = new WebSocket(
  'ws://localhost:8005/ws/tts'
);

const chunks = [];
ws.onmessage = ({ data }) => {
  if (data instanceof ArrayBuffer) {
    chunks.push(data);
  } else {
    const msg = JSON.parse(data);
    if (msg.type === 'end') playAll(chunks);
  }
};

ws.send(JSON.stringify({
  target_text:   "Xin chào, tôi là Alard.",
  speaker_id:    "uuid-speaker",
  collection_id: "uuid-collection",
  language:      "vi"
}));

{
  "speakers": [
    {
      "id": "de315d3d-bb11-...",
      "name": "Giọng Google Nữ",
      "reference_audio": "vi.wav",
      "language": "vi",
      "user_id": "default"
    },
    {
      "id": "ca8df695-175d-...",
      "name": "F5TTS English 2",
      "reference_audio": "en.wav",
      "language": "en",
      "user_id": "default"
    }
  ]
}

{
  "collections": [
    {
      "id": "637b6576-a49b-...",
      "name": "Bộ Sưu Tập 1",
      "description": "BST1",
      "user_id": "long",
      "langs": {
        "vi": {"id": "de315d3d-...", "name": "Giọng Google"},
        "en": {"id": "ca8df695-...", "name": "F5TTS English 2"},
        "fr": {"id": "fd8d4043-...", "name": "F5TTS French"},
        "ru": {"id": "f58f853b-...", "name": "F5TTS Russian"}
      }
    }
  ]
}

await fetch('http://localhost:8005/api/collections', {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({
    name: "My Collection",
    user_id: "default",
    description: "Multilang bot voice",
    langs: {
      "vi": "de315d3d-bb11-...",
      "en": "ca8df695-175d-...",
      "fr": "fd8d4043-665a-..."
    }
  })
});

{
  "id": "637b6576-a49b-40f2-9172-...",
  "name": "My Collection",
  "user_id": "default"
}

await fetch(
  'http://localhost:8005/api/collections/637b...',
  {
    method: 'PUT',
    headers: {'Content-Type':'application/json'},
    body: JSON.stringify({
      name: "Updated Name",
      langs: { "vi": "uuid-vi", "en": "uuid-en" }
    })
  }
);

await fetch(
  'http://localhost:8005/api/collections/637b...',
  { method: 'DELETE' }
);

{ "status": "deleted" }

const ws = new WebSocket(
  'ws://localhost:8125/ws/voice-chat'
);
ws.onopen = () => {
  ws.send(JSON.stringify({
    type: 'config',
    asr_ws_url:
      'ws://localhost:8124/ws/transcribe/vad',
    tts_ws_url:
      'ws://localhost:8005/ws/tts',
    speaker_id:    'uuid-speaker',
    collection_id: 'uuid-collection',
    language:      'vi',
    llm_model:     'gpt-4o-mini'
  }));
};