Audio Keep Alive

const WebSocket = require("ws");
// Assuming 'headers' is already defined for authorization
const ws = new WebSocket("wss://api.deepgram.com/v1/listen", { headers });
// Assuming 'ws' is the WebSocket connection object
const keepAliveMsg = JSON.stringify({ type: "KeepAlive" });
ws.send(keepAliveMsg);

const WebSocket = require("ws");
const authToken = "DEEPGRAM_API_KEY"; // Replace 'DEEPGRAM_API_KEY' with your actual authorization token
const headers = {
  Authorization: `Token ${authToken}`,
};
// Initialize WebSocket connection
const ws = new WebSocket("wss://api.deepgram.com/v1/listen", { headers });
// Handle WebSocket connection open event
ws.on("open", function open() {
  console.log("WebSocket connection established.");
  // Send audio data (replace this with your audio streaming logic)
  // Example: Read audio from a microphone and send it over the WebSocket
  // For demonstration purposes, we're just sending a KeepAlive message
  setInterval(() => {
    const keepAliveMsg = JSON.stringify({ type: "KeepAlive" });
    ws.send(keepAliveMsg);
    console.log("Sent KeepAlive message");
  }, 3000); // Sending KeepAlive messages every 3 seconds
});
// Handle WebSocket message event
ws.on("message", function incoming(data) {
  console.log("Received:", data);
  // Handle received data (transcription results, errors, etc.)
});
// Handle WebSocket close event
ws.on("close", function close() {
  console.log("WebSocket connection closed.");
});
// Handle WebSocket error event
ws.on("error", function error(err) {
  console.error("WebSocket error:", err.message);
});
// Gracefully close the WebSocket connection when done
function closeWebSocket() {
  const closeMsg = JSON.stringify({ type: "CloseStream" });
  ws.send(closeMsg);
}
// Call closeWebSocket function when you're finished streaming audio
// For example, when user stops recording or when the application exits
// closeWebSocket();

const { DeepgramClient } = require("@deepgram/sdk");
const live = async () => {
  const deepgram = new DeepgramClient({ apiKey: "DEEPGRAM_API_KEY" });
  let connection;
  let keepAlive;
  const setupDeepgram = async () => {
    connection = await deepgram.listen.v1.connect({
      model: "nova-3",
      utterance_end_ms: "1500",
      interim_results: "true",
    });
    if (keepAlive) clearInterval(keepAlive);
    keepAlive = setInterval(() => {
      console.log("KeepAlive sent.");
      connection.sendKeepAlive({ type: "KeepAlive" });
    }, 3000); // Sending KeepAlive messages every 3 seconds
    connection.on("open", () => {
      console.log("Connection opened.");
    });
    connection.on("close", () => {
      console.log("Connection closed.");
      clearInterval(keepAlive);
    });
    connection.on("message", (data) => {
      if (data.type === "Metadata") {
        console.log(data);
      } else if (data.type === "Results") {
        console.log(data.channel);
      } else if (data.type === "UtteranceEnd") {
        console.log(data);
      } else if (data.type === "SpeechStarted") {
        console.log(data);
      }
    });
    connection.on("error", (err) => {
      console.error(err);
    });
    connection.connect();
    await connection.waitForOpen();
  };
  setupDeepgram();
};
live();