Voice Stream Websocket

const ws = new WebSocket("wss://api.soca.ai/voice-ws");
ws.binaryType = "arraybuffer";

ws.onopen = () => {
  // Send start message
  ws.send(JSON.stringify({
    type: "start",
    private_key: "<private_key>",
    session_id: "<session_id>",
    agent_id: "<agent_id>",
    lang: "id",
    sr: 16000
  }));
};

ws.onmessage = (e) => {
  const msg = JSON.parse(e.data);
  
  // Handle different message types
  switch(msg.type) {
    case "stt.partial":
      console.log("Partial:", msg.text);
      break;
      
    case "stt.final":
      console.log("Final:", msg.text);
      break;
      
    case "barge":
      handleBarge(msg.seq);
      break;
  }
  
  // Handle audio chunks
  if (msg.stepType === "sentence") {
    handleAudioChunk(msg);
  }
};

// Capture microphone
const stream = await navigator.mediaDevices.getUserMedia({
  audio: {
    sampleRate: 16000,
    channelCount: 1,
    echoCancellation: true,
    noiseSuppression: true
  }
});

const audioContext = new AudioContext({ sampleRate: 16000 });
const source = audioContext.createMediaStreamSource(stream);
const processor = audioContext.createScriptProcessor(4096, 1, 1);

processor.onaudioprocess = (e) => {
  const float32 = e.inputBuffer.getChannelData(0);
  const int16 = convertFloat32ToInt16(float32);
  
  if (ws.readyState === WebSocket.OPEN) {
    ws.send(int16.buffer);
  }
};

source.connect(processor);
processor.connect(audioContext.destination);

function convertFloat32ToInt16(float32Array) {
  const int16Array = new Int16Array(float32Array.length);
  
  for (let i = 0; i < float32Array.length; i++) {
    const s = Math.max(-1, Math.min(1, float32Array[i]));
    int16Array[i] = s < 0 ? s * 0x8000 : s * 0x7FFF;
  }
  
  return int16Array;
}

function handleAudioChunk(msg) {
  const key = `${msg.seq}_${msg.sentenceId}`;
  
  // Collect chunks
  if (!pendingChunks.has(key)) {
    pendingChunks.set(key, []);
  }
  
  if (msg.audioBase64) {
    pendingChunks.get(key).push(msg.audioBase64);
  }
  
  // Play when complete
  if (msg.isLastChunk) {
    const chunks = pendingChunks.get(key);
    const fullBase64 = chunks.join('');
    
    // Decode and play
    const audioData = atob(fullBase64);
    const buffer = new ArrayBuffer(audioData.length);
    const view = new Uint8Array(buffer);
    
    for (let i = 0; i < audioData.length; i++) {
      view[i] = audioData.charCodeAt(i);
    }
    
    const blob = new Blob([buffer], { type: 'audio/mp3' });
    const url = URL.createObjectURL(blob);
    const audio = new Audio(url);
    
    audio.play();
    audio.onended = () => URL.revokeObjectURL(url);
    
    pendingChunks.delete(key);
  }
}