Quickstart

const response = await fetch("https://api.gladia.io/v2/live", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "x-gladia-key": "<YOUR_GLADIA_API_KEY>",
  },
  body: JSON.stringify({
    encoding: "wav/pcm",
    sample_rate: 16000,
    bit_depth: 16,
    channels: 1,
  }),
});
if (!response.ok) {
  // Look at the error message
  // It might be a configuration issue
  console.error(
    `${response.status}: ${(await response.text()) || response.statusText}`
  );
  process.exit(response.status);
}

const { id, url } = await response.json();

import WebSocket from "ws";

const socket = new WebSocket(url);

socket.addEventListener("open", function () {
  // Connection is opened. You can start sending audio chunks.
});

socket.addEventListener("error", function (error) {
  // An error occurred during the connection.
  // Check the error to understand why
});

socket.addEventListener("close", function ({ code, reason }) {
  // The connection has been closed
  // If the "code" is equal to 1000, it means we closed intentionally the connection (after the end of the session for example).
  // Otherwise, you can reconnect to the same url.
});

socket.addEventListener("message", function (event) {
  // All the messages we are sending are in JSON format
  const message = JSON.parse(event.data.toString());
  console.log(message);
});

// as binary
socket.send(buffer);

// as json
socket.send(
  JSON.stringify({
    type: "audio_chunk",
    data: {
      chunk: buffer.toString("base64"),
    },
  })
);

socket.addEventListener("message", function(event) {
  // All the messages we are sending are in JSON format
  const message = JSON.parse(event.data.toString());
  if (message.type === 'transcript' && message.data.is_final) {
    console.log(`${message.data.id}: ${message.data.utterance.text}`)
  }
});

export function interleaveAudio(channelsData: Buffer[], bitDepth = 16): Buffer {
  const nbChannels = channelsData.length;
  if (nbChannels === 1) {
    return channelsData[0];
  }

  const bytesPerSample = bitDepth / 8;
  const samplesPerChannel = channelsData[0].byteLength / bytesPerSample;
  const audio = Buffer.alloc(nbChannels * samplesPerChannel * bytesPerSample);

  for (let i = 0; i < samplesPerChannel; i++) {
    for (let j = 0; j < nbChannels; j++) {
      const sample = channelsData[j].subarray(
        i * bytesPerSample,
        (i + 1) * bytesPerSample
      );
      audio.set(sample, (i * nbChannels + j) * bytesPerSample);
    }
  }

  return audio;
}

// Collect audio buffers from each participant
const samiAudio = getSamiAudioBuffer();
const maximeAudio = getMaximeAudioBuffer();
const markAudio = getMarkAudioBuffer();

// Merge into a multi-channel audio
// Channel ordering: [0]=Sami, [1]=Maxime, [2]=Mark
const channelsData = [samiAudio, maximeAudio, markAudio];
const mergedAudio = interleaveAudio(channelsData, 16); // 16-bit depth

// Initialize a single WebSocket session with multi-channel config
const response = await fetch("https://api.gladia.io/v2/live", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "x-gladia-key": "<YOUR_GLADIA_API_KEY>",
  },
  body: JSON.stringify({
    encoding: "wav/pcm",
    sample_rate: 16000,
    bit_depth: 16,
    channels: 3, // Specify the number of channels
  }),
});

const { url } = await response.json();
const socket = new WebSocket(url);

// Send the merged audio over a single WebSocket
socket.addEventListener("open", function () {
  socket.send(mergedAudio);
});

socket.addEventListener("message", function (event) {
  // All the messages we are sending are in JSON format
  const message = JSON.parse(event.data.toString());
  if (message.type === "transcript" && message.data.is_final) {
    console.log(`${message.data.id}: ${message.data.utterance.text}`);
  }
});

socket.send(
  JSON.stringify({
    type: "stop_recording",
  })
);

const response = await fetch(`https://api.gladia.io/v2/live/${id}`, {
  method: "GET",
  headers: {
    "x-gladia-key": "<YOUR_GLADIA_API_KEY>",
  },
});
if (!response.ok) {
  // Look at the error message
  // It might be a configuration issue
  console.error(
    `${response.status}: ${(await response.text()) || response.statusText}`
  );
  return;
}

const result = await response.json();
console.log(result);