WebSocket Transport

1
const socket = new WebSocket("wss://api.vapi.ai/7420f27a-30fd-4f49-a995-5549ae7cc00d/transport");
2
3
socket.onopen = () => console.log("WebSocket connection opened.");
4
socket.onclose = () => console.log("WebSocket connection closed.");
5
socket.onerror = (error) => console.error("WebSocket error:", error);

1
function sendAudioChunk(audioBuffer) {
2
  if (socket.readyState === WebSocket.OPEN) {
3
    socket.send(audioBuffer);
4
  }
5
}
6
7
navigator.mediaDevices.getUserMedia({ audio: true }).then(stream => {
8
  const audioContext = new AudioContext();
9
  const source = audioContext.createMediaStreamSource(stream);
10
  const processor = audioContext.createScriptProcessor(1024, 1, 1);
11
12
  processor.onaudioprocess = (event) => {
13
    const pcmData = event.inputBuffer.getChannelData(0);
14
    const int16Data = new Int16Array(pcmData.length);
15
16
    for (let i = 0; i < pcmData.length; i++) {
17
      int16Data[i] = Math.max(-32768, Math.min(32767, pcmData[i] * 32768));
18
    }
19
20
    sendAudioChunk(int16Data.buffer);
21
  };
22
23
  source.connect(processor);
24
  processor.connect(audioContext.destination);
25
});

1
socket.onmessage = (event) => {
2
  if (event.data instanceof Blob) {
3
    event.data.arrayBuffer().then(buffer => {
4
      const audioData = new Int16Array(buffer);
5
      playAudio(audioData);
6
    });
7
  } else {
8
    try {
9
      const message = JSON.parse(event.data);
10
      handleControlMessage(message);
11
    } catch (error) {
12
      console.error("Failed to parse message:", error);
13
    }
14
  }
15
};

1
function sendControlMessage(messageObj) {
2
  if (socket.readyState === WebSocket.OPEN) {
3
    socket.send(JSON.stringify(messageObj));
4
  }
5
}
6
7
// Example: hangup call
8
function hangupCall() {
9
  sendControlMessage({ type: "hangup" });
10
}

1
sendControlMessage({ type: "hangup" });
2
socket.close();