1
{
2
  "type": "KeepAlive" 
3
}

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

1
const WebSocket = require("ws");
2
3
const authToken = "DEEPGRAM_API_KEY"; // Replace 'DEEPGRAM_API_KEY' with your actual authorization token
4
const headers = {
5
  Authorization: `Token ${authToken}`,
6
};
7
8
// Initialize WebSocket connection
9
const ws = new WebSocket("wss://api.deepgram.com/v1/listen", { headers });
10
11
// Handle WebSocket connection open event
12
ws.on("open", function open() {
13
  console.log("WebSocket connection established.");
14
15
  // Send audio data (replace this with your audio streaming logic)
16
  // Example: Read audio from a microphone and send it over the WebSocket
17
  // For demonstration purposes, we're just sending a KeepAlive message
18
19
  setInterval(() => {
20
    const keepAliveMsg = JSON.stringify({ type: "KeepAlive" });
21
    ws.send(keepAliveMsg);
22
    console.log("Sent KeepAlive message");
23
  }, 3000); // Sending KeepAlive messages every 3 seconds
24
});
25
26
// Handle WebSocket message event
27
ws.on("message", function incoming(data) {
28
  console.log("Received:", data);
29
  // Handle received data (transcription results, errors, etc.)
30
});
31
32
// Handle WebSocket close event
33
ws.on("close", function close() {
34
  console.log("WebSocket connection closed.");
35
});
36
37
// Handle WebSocket error event
38
ws.on("error", function error(err) {
39
  console.error("WebSocket error:", err.message);
40
});
41
42
// Gracefully close the WebSocket connection when done
43
function closeWebSocket() {
44
  const closeMsg = JSON.stringify({ type: "CloseStream" });
45
  ws.send(closeMsg);
46
}
47
48
// Call closeWebSocket function when you're finished streaming audio
49
// For example, when user stops recording or when the application exits
50
// closeWebSocket();

1
const { createClient, LiveTranscriptionEvents } = require("@deepgram/sdk");
2
3
const live = async () => {
4
  const deepgram = createClient("DEEPGRAM_API_KEY");
5
  let connection;
6
  let keepAlive;
7
8
  const setupDeepgram = () => {
9
    connection = deepgram.listen.live({
10
      model: "nova-3",
11
      utterance_end_ms: 1500,
12
      interim_results: true,
13
    });
14
15
    if (keepAlive) clearInterval(keepAlive);
16
    keepAlive = setInterval(() => {
17
      console.log("KeepAlive sent.");
18
      connection.keepAlive();
19
    }, 3000); // Sending KeepAlive messages every 3 seconds
20
21
    connection.on(LiveTranscriptionEvents.Open, () => {
22
      console.log("Connection opened.");
23
    });
24
25
    connection.on(LiveTranscriptionEvents.Close, () => {
26
      console.log("Connection closed.");
27
      clearInterval(keepAlive);
28
    });
29
30
    connection.on(LiveTranscriptionEvents.Metadata, (data) => {
31
      console.log(data);
32
    });
33
34
    connection.on(LiveTranscriptionEvents.Transcript, (data) => {
35
      console.log(data.channel);
36
    });
37
38
    connection.on(LiveTranscriptionEvents.UtteranceEnd, (data) => {
39
      console.log(data);
40
    });
41
42
    connection.on(LiveTranscriptionEvents.SpeechStarted, (data) => {
43
      console.log(data);
44
    });
45
46
    connection.on(LiveTranscriptionEvents.Error, (err) => {
47
      console.error(err);
48
    });
49
  };
50
51
  setupDeepgram();
52
};
53
54
live();