server.js

// const express = require("express");
// const http = require("http");
// const WebSocket = require("ws");
// const { createClient, LiveTranscriptionEvents } = require("@deepgram/sdk");
// const dotenv = require("dotenv");
// dotenv.config();

// const app = express();

// const startServer = () => {
//   const server = http.createServer(app);
//   const wss = new WebSocket.Server({ server });

//   const deepgramClient = createClient(process.env.DEEPGRAM_API_KEY);
//   let keepAlive;

//   const setupDeepgram = (ws) => {
//     const deepgram = deepgramClient.listen.live({
//       smart_format: true,
//       model: "nova-2",
//       language: "en",
//       encoding: "webm",
//       channels: 1,
//       sample_rate: 16000,
//     });

//     if (keepAlive) clearInterval(keepAlive);
//     keepAlive = setInterval(() => {
//       console.log("deepgram: keepalive");
//       deepgram.keepAlive();
//     }, 10 * 1000);

//     deepgram.addListener(LiveTranscriptionEvents.Open, async () => {
//       console.log("deepgram: connected");

//       deepgram.addListener(LiveTranscriptionEvents.Transcript, (data) => {
//         console.log("deepgram: transcript received:", data?.channel?.alternatives[0]?.transcript);
//         console.log("ws: transcript sent to client");
//         ws.send(JSON.stringify(data));
//       });

//       deepgram.addListener(LiveTranscriptionEvents.Close, async () => {
//         console.log("deepgram: disconnected");
//         clearInterval(keepAlive);
//         deepgram.finish();
//       });

//       deepgram.addListener(LiveTranscriptionEvents.Error, async (error) => {
//         console.log("deepgram: error received");
//         console.error(error);
//       });

//       deepgram.addListener(LiveTranscriptionEvents.Warning, async (warning) => {
//         console.log("deepgram: warning received");
//         console.warn(warning);
//       });

//       deepgram.addListener(LiveTranscriptionEvents.Metadata, (data) => {
//         console.log("deepgram: metadata received");
//         console.log("ws: metadata sent to client");
//         ws.send(JSON.stringify({ metadata: data }));
//       });
//     });

//     return deepgram;
//   };

//   wss.on("connection", (ws) => {
//     console.log("ws: client connected");
//     let deepgram = setupDeepgram(ws);

//     ws.on("message", (message) => {
//       console.log("ws: received audio chunk of size:", message.length);

//       if (deepgram.getReadyState() === 1 /* OPEN */) {
//         try {
//           deepgram.send(message);
//           console.log("ws: audio chunk sent to deepgram");
//         } catch (error) {
//           console.error("ws: error sending to deepgram:", error);
//         }
//       } else if (deepgram.getReadyState() >= 2 /* 2 = CLOSING, 3 = CLOSED */) {
//         console.log("ws: data couldn't be sent to deepgram");
//         console.log("ws: retrying connection to deepgram");
//         /* Attempt to reopen the Deepgram connection */
//         deepgram.finish();
//         deepgram.removeAllListeners();
//         deepgram = setupDeepgram(ws);
//       } else {
//         console.log("ws: deepgram not ready, state:", deepgram.getReadyState());
//       }
//     });

//     ws.on("close", () => {
//       console.log("ws: client disconnected");
//       deepgram.finish();
//       deepgram.removeAllListeners();
//       deepgram = null;
//     });
//   });

//   server.listen(3000, () => {
//     console.log("Server is listening on port 3000");
//   });

//   return server;
// };

// // If this file is run directly (not imported as a module)
// if (require.main === module) {
//   startServer();
// }

// module.exports = { startServer };