Update app.js

app.js

@@ -32,7 +32,10 @@ const sendTelnyxCmd = async (callId, action, body = {}) => {
       headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
       body: JSON.stringify(body)
     });
-    if (!response.ok) log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${await response.text()}`);
+    if (!response.ok) {
+      const errText = await response.text();
+      log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${errText}`);
+    }
     return response;
   } catch (e) {
     log("TELNYX CMD NETWORK ERROR", e.message);
@@ -45,6 +48,12 @@ const updateLog = (callId, statusUpdates) => {
   return entry;
 };
 
+const clearCallTimers = (entry) => {
+  if (!entry || !entry.timers) return;
+  Object.values(entry.timers).forEach(clearTimeout);
+  entry.timers = {};
+};
+
 // ─── VAD MATH UTILITIES ───
 const MU_LAW_TABLE = new Int16Array(256);
 for (let i = 0; i < 256; i++) {
@@ -181,7 +190,9 @@ app.get("/", (req, res) => {
                             <button onClick={() => hangup(log.call_control_id)} className="bg-red-600 hover:bg-red-500 text-xs px-3 py-1 rounded font-bold transition">
                               Force Hang Up
                             </button>
-                          ) : <span className="text-gray-500 text-xs">Ended</span>}
+                          ) : (
+                            <span className="text-gray-500 text-xs">Ended</span>
+                          )}
                         </td>
                         <td className="p-4">
                           {log.recording_url ? 
@@ -208,7 +219,7 @@ app.get("/", (req, res) => {
 app.get("/api/logs", (req, res) => res.json([...callLogs].reverse()));
 app.get("/health", (req, res) => res.json({ status: "ok", uptime: process.uptime() }));
 
-// ─── PROXY FOR TELNYX RECORDINGS ─────────────
+// ─── PROXY FOR TELNYX RECORDINGS ───────────────────────────
 app.get("/play-recording/:call_control_id", async (req, res) => {
   const logEntry = callLogs.find(l => l.call_control_id === req.params.call_control_id);
   if (!logEntry || !logEntry.raw_telnyx_url) return res.sendStatus(404);
@@ -219,22 +230,28 @@ app.get("/play-recording/:call_control_id", async (req, res) => {
     res.setHeader("Content-Type", "audio/mpeg");
     res.setHeader("Content-Length", buffer.length);
     res.send(buffer);
-  } catch (e) { res.sendStatus(500); }
+  } catch (e) {
+    res.sendStatus(500);
+  }
 });
 
-// ─── DIAL OUT ROUTE ──────────────────────────
+// ─── DIAL OUT ROUTE ────────────────────────────────────────
 app.post("/dial", async (req, res) => {
   const { to } = req.body;
   const voice = "Algieba"; 
   log("DIAL", `Dialing ${to}...`);
 
   try {
-    const response = await sendTelnyxCmd("", "v2/calls", {
-      connection_id: TELNYX_CONNECTION_ID,
-      to,
-      from: TELNYX_FROM_NUMBER,
-      custom_headers: [{ name: "X-Voice-Selection", value: voice }]
-    }, true);
+    const response = await fetch("https://api.telnyx.com/v2/calls", {
+      method: "POST",
+      headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
+      body: JSON.stringify({
+        connection_id: TELNYX_CONNECTION_ID,
+        to,
+        from: TELNYX_FROM_NUMBER,
+        custom_headers: [{ name: "X-Voice-Selection", value: voice }]
+      }),
+    });
 
     const data = await response.json();
     if (!response.ok) return res.status(400).json({ ok: false, error: data?.errors?.[0]?.detail });
@@ -252,19 +269,27 @@ app.post("/dial", async (req, res) => {
       timers: {},
       created_at: new Date().toISOString()
     });
+
     res.json({ ok: true });
-  } catch (err) { res.status(500).json({ ok: false, error: err.message }); }
+  } catch (err) {
+    res.status(500).json({ ok: false, error: err.message });
+  }
 });
 
-// ─── MANUAL HANG UP ──────────────────────────
+// ─── MANUAL HANG UP ────────────────────────────────────────
 app.post("/call/hangup", async (req, res) => {
   const { call_control_id } = req.body;
   if (!call_control_id) return res.status(400).json({ error: "Missing call_control_id" });
-  await sendTelnyxCmd(call_control_id, "hangup");
-  res.json({ ok: true });
+
+  try {
+    await sendTelnyxCmd(call_control_id, "hangup");
+    res.json({ ok: true });
+  } catch (err) {
+    res.status(500).json({ ok: false, error: err.message });
+  }
 });
 
-// ─── TELNYX WEBHOOK (State Only, No STT) ──────
+// ─── TELNYX WEBHOOK (State Only, No STT) ───────────────────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
@@ -273,6 +298,8 @@ app.post("/webhook/call", async (req, res) => {
   if (!type) return res.sendStatus(200);
 
   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); 
   }
@@ -300,9 +327,19 @@ 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 });
       
-      // Start WebSocket Media Stream to listen to the caller natively
+      // 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" });
 
@@ -321,19 +358,19 @@ app.post("/webhook/call", async (req, res) => {
       break;
 
     case "call.recording.saved":
-      log("RECORDING URL", `\n\n⬇️ DOWNLOAD RAW AUDIO HERE ⬇️\n${payload.recording_urls.mp3}\n`);
+      // 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`);
+      
       updateLog(callId, { 
-        raw_telnyx_url: payload.recording_urls.mp3,
+        raw_telnyx_url: rawUrl,
         recording_url: `/play-recording/${callId}`
       });
       break;
 
     case "call.hangup":
       updateLog(callId, { status: "completed", is_playing: false });
-      if (entry && entry.timers) {
-        Object.values(entry.timers).forEach(clearTimeout);
-        entry.timers = {};
-      }
+      clearCallTimers(entry);
       log("CALL ENDED", `Terminated.`);
       break;
   }
@@ -387,7 +424,7 @@ wss.on("connection", (ws, req) => {
 
         // ── 1. NOISE DETECTED (Human is speaking) ──
         if (rms > VOLUME_THRESHOLD) {
-          hasGreeted = true; // They spoke, disable smart greeting timer
+          hasGreeted = true; 
           silenceFrames = 0;
           pcmChunks.push(pcm16);
 
@@ -421,14 +458,13 @@ wss.on("connection", (ws, req) => {
             const entry = callLogs.find(l => l.call_control_id === callControlId);
             const voice = entry ? entry.voice_used : "Algieba";
 
-            // Compile WAV buffer for Groq
             const totalLength = pcmChunks.reduce((acc, val) => acc + val.length, 0);
             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
             
-            // If the noise burst was less than ~200ms total, ignore it (mic bump/cough)
+            // Ignore tiny noise bursts (coughs, mic bumps)
             if (totalLength < 8000 * 0.2) {
                isProcessingTurn = false;
                return;
@@ -456,9 +492,9 @@ 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 thinking?
+                // Check race condition: Did human interrupt the AI while it was thinking?
                 if (!isSpeaking && aiData.speak_url) {
-                  log("AI_REPLY", `Playing reply: ${aiData.raw_text}`);
+                  log("AI_REPLY", `Playing full reply.`);
                   if (entry) entry.is_playing = true;
                   await sendTelnyxCmd(callControlId, "playback_start", {
                     audio_url: aiData.speak_url, target_legs: "self"
@@ -475,59 +511,6 @@ wss.on("connection", (ws, req) => {
   });
 });
 
-// Custom fetch wrapper for internal call initiation without full endpoint
-const originalFetch = global.fetch;
-global.fetch = async (url, options) => {
-  if (url === "https://api.telnyx.com/v2/calls" && options?.method === "POST" && options?.isCustomDial) {
-    const rawUrl = url;
-    delete options.isCustomDial;
-    return originalFetch(rawUrl, options);
-  }
-  return originalFetch(url, options);
-};
-
-// Replace Dial API implementation to use standard fetch safely
-app.post("/dial", async (req, res) => {
-  const { to } = req.body;
-  const voice = "Algieba"; 
-  log("DIAL", `Dialing ${to}...`);
-
-  try {
-    const response = await fetch("https://api.telnyx.com/v2/calls", {
-      method: "POST",
-      isCustomDial: true,
-      headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-      body: JSON.stringify({
-        connection_id: TELNYX_CONNECTION_ID,
-        to,
-        from: TELNYX_FROM_NUMBER,
-        custom_headers: [{ name: "X-Voice-Selection", value: voice }]
-      }),
-    });
-
-    const data = await response.json();
-    if (!response.ok) return res.status(400).json({ ok: false, error: data?.errors?.[0]?.detail });
-
-    callLogs.push({
-      id: randomUUID(),
-      call_control_id: data.data.call_control_id,
-      target_number: to,
-      voice_used: voice,
-      status: "dialing",
-      last_transcript: "",
-      recording_url: null,
-      raw_telnyx_url: null,
-      is_playing: false,
-      timers: {},
-      created_at: new Date().toISOString()
-    });
-
-    res.json({ ok: true });
-  } catch (err) {
-    res.status(500).json({ ok: false, error: err.message });
-  }
-});
-
 const requiredEnv = ["TELNYX_API_KEY", "TELNYX_CONNECTION_ID", "TELNYX_FROM_NUMBER", "AI_SERVER_URL"];
 requiredEnv.forEach((key) => {
   if (!process.env[key]) log("STARTUP WARNING", `Missing env var: ${key}`);