Update app.js

app.js

@@ -51,7 +51,7 @@ const updateLog = (callId, statusUpdates) => {
 const clearCallTimers = (entry) => {
   if (!entry || !entry.timers) return;
   Object.values(entry.timers).forEach(clearTimeout);
-  entry.timers = {};
+  entry.timers = {}; // clear out the objects
 };
 
 // ─── VAD MATH UTILITIES ───
@@ -216,7 +216,16 @@ app.get("/", (req, res) => {
   `);
 });
 
-app.get("/api/logs", (req, res) => res.json([...callLogs].reverse()));
+// ── FIX: Strip Circular Timer Objects Before Sending to Dashboard ──
+app.get("/api/logs", (req, res) => {
+  const safeLogs = callLogs.map(entry => {
+    // Destructure to remove 'timers' from the object we send to the frontend
+    const { timers, ...safeEntry } = entry;
+    return safeEntry;
+  });
+  res.json(safeLogs.reverse());
+});
+
 app.get("/health", (req, res) => res.json({ status: "ok", uptime: process.uptime() }));
 
 // ─── PROXY FOR TELNYX RECORDINGS ───────────────────────────
@@ -266,7 +275,7 @@ app.post("/dial", async (req, res) => {
       recording_url: null,
       raw_telnyx_url: null,
       is_playing: false,
-      timers: {},
+      timers: {}, // Timers object correctly initialized
       created_at: new Date().toISOString()
     });
 
@@ -289,7 +298,7 @@ app.post("/call/hangup", async (req, res) => {
   }
 });
 
-// ─── TELNYX WEBHOOK (State Only, No STT) ───────────────────
+// ─── TELNYX WEBHOOK ────────────────────────────────────────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
@@ -299,7 +308,6 @@ app.post("/webhook/call", async (req, res) => {
 
   const entry = callLogs.find(l => l.call_control_id === callId);
   
-  // Local Lock: Ignore events for dead calls to prevent 422 errors
   if (entry && entry.status === "completed" && type !== "call.recording.saved") {
     return res.sendStatus(200); 
   }
@@ -327,21 +335,13 @@ app.post("/webhook/call", async (req, res) => {
       log("ANSWERED", `Call ${callId} connected.`);
       updateLog(callId, { status: "in-progress" });
 
-      // Start Dual-Channel Recording
       await sendTelnyxCmd(callId, "record_start", { format: "mp3", channels: "dual", play_beep: false });
       
-      // DEACTIVATED UNTIL YOU FIX AUDIO LEVELS:
-      /*
-      await sendTelnyxCmd(callId, "playback_start", {
-        audio_url: `https://${req.headers.host}/ambience.mp3`,
-        loop: "infinity",
-        target_legs: "self"
-      });
-      */
-
       // Start WebSocket Media Stream to listen to the caller natively via VAD
       const wsUrl = `wss://${req.headers.host}/audio-stream`;
-      await sendTelnyxCmd(callId, "stream_start", { stream_url: wsUrl, track: "inbound_track" });
+      
+      // Changed to `fork_start` as it's the more stable command for Telnyx V2 Media Streaming
+      await sendTelnyxCmd(callId, "fork_start", { stream_url: wsUrl, track: "inbound_track" });
 
       if (entry) {
         entry.timers.hangup = setTimeout(async () => {
@@ -358,7 +358,6 @@ app.post("/webhook/call", async (req, res) => {
       break;
 
     case "call.recording.saved":
-      // THE PROMINENT RECORDING LOG YOU REQUESTED
       const rawUrl = payload.recording_urls.mp3;
       log("RECORDING URL", `\n\n⬇️ DOWNLOAD RAW AUDIO HERE ⬇️\n${rawUrl}\n\n`);
       
@@ -388,8 +387,8 @@ wss.on("connection", (ws, req) => {
   let isProcessingTurn = false; 
   let hasGreeted = false;
 
-  const SILENCE_THRESHOLD_FRAMES = 25; // 25 frames * 20ms = 500ms of silence
-  const VOLUME_THRESHOLD = 400; // RMS Volume Threshold
+  const SILENCE_THRESHOLD_FRAMES = 25; 
+  const VOLUME_THRESHOLD = 400; 
 
   ws.on("message", async (raw) => {
     try {
@@ -399,7 +398,6 @@ wss.on("connection", (ws, req) => {
         callControlId = msg.start?.call_control_id;
         log("WS_STREAM", `Receiving audio for call ${callControlId}`);
         
-        // Smart Initial Greeting
         setTimeout(async () => {
           if (!hasGreeted && callControlId) {
              const entry = callLogs.find(l => l.call_control_id === callControlId);
@@ -422,7 +420,6 @@ wss.on("connection", (ws, req) => {
         const pcm16 = decodeMuLaw(mulawBuffer);
         const rms = calculateRMS(pcm16);
 
-        // ── 1. NOISE DETECTED (Human is speaking) ──
         if (rms > VOLUME_THRESHOLD) {
           hasGreeted = true; 
           silenceFrames = 0;
@@ -433,7 +430,6 @@ wss.on("connection", (ws, req) => {
             isProcessingTurn = false;
             log("VAD", "Human started speaking.");
             
-            // ── BARGE IN ──
             const entry = callLogs.find(l => l.call_control_id === callControlId);
             if (entry && entry.is_playing) {
               log("BARGE-IN", "Interrupting AI playback.");
@@ -442,13 +438,10 @@ wss.on("connection", (ws, req) => {
             }
           }
         } 
-        
-        // ── 2. SILENCE DETECTED ──
         else if (isSpeaking) {
           pcmChunks.push(pcm16);
           silenceFrames++;
 
-          // ── 3. SOFT TURN TRIGGER (500ms silence limit reached) ──
           if (silenceFrames > SILENCE_THRESHOLD_FRAMES && !isProcessingTurn) {
             log("VAD", "500ms silence detected. Turn ended.");
             isSpeaking = false;
@@ -462,9 +455,8 @@ wss.on("connection", (ws, req) => {
             const finalPcm = new Int16Array(totalLength);
             let offset = 0;
             for (let chunk of pcmChunks) { finalPcm.set(chunk, offset); offset += chunk.length; }
-            pcmChunks = []; // Clear for next turn
+            pcmChunks = []; 
             
-            // Ignore tiny noise bursts (coughs, mic bumps)
             if (totalLength < 8000 * 0.2) {
                isProcessingTurn = false;
                return;
@@ -472,7 +464,6 @@ wss.on("connection", (ws, req) => {
 
             const wavBuffer = pcm16ToWav(finalPcm, 8000);
 
-            // ── IMMEDIATE BACKCHANNEL HACK (0ms perceived latency) ──
             const fillers = ["Right.", "Got it.", "Okay."];
             const filler = fillers[Math.floor(Math.random() * fillers.length)];
             
@@ -482,7 +473,6 @@ wss.on("connection", (ws, req) => {
               target_legs: "self"
             }).catch(()=>{});
 
-            // ── BACKGROUND AI PROCESSING ──
             try {
               const aiRes = await fetch(`${AI_SERVER_URL}/api/process-audio-turn?voice=${voice}&call_id=${callControlId}`, {
                 method: "POST", headers: { "Content-Type": "audio/wav" }, body: wavBuffer
@@ -492,7 +482,6 @@ wss.on("connection", (ws, req) => {
                 const aiData = await aiRes.json();
                 if (aiData.transcript) updateLog(callControlId, { last_transcript: aiData.transcript });
 
-                // Check race condition: Did human interrupt the AI while it was thinking?
                 if (!isSpeaking && aiData.speak_url) {
                   log("AI_REPLY", `Playing full reply.`);
                   if (entry) entry.is_playing = true;