Update app.js

app.js

@@ -1,11 +1,9 @@
 import express from "express";
 import { createServer } from "http";
-import { WebSocketServer } from "ws";
 import { randomUUID } from "crypto";
 
 const app = express();
 const server = createServer(app);
-const wss = new WebSocketServer({ server, path: "/audio-stream" });
 
 app.use(express.static("public", { index: false }));
 app.use(express.json());
@@ -17,10 +15,7 @@ const TELNYX_CONNECTION_ID = process.env.TELNYX_CONNECTION_ID;
 const TELNYX_FROM_NUMBER = process.env.TELNYX_FROM_NUMBER;
 const AI_SERVER_URL = process.env.AI_SERVER_URL;
 
-const log = (tag, ...args) => {
-  const time = new Date().toISOString();
-  console.log(`[${time}] [${tag}]`, ...args);
-};
+const log = (tag, ...args) => console.log(`[${new Date().toISOString()}] [${tag}]`, ...args);
 
 let callLogs = [];
 
@@ -76,7 +71,7 @@ app.get("/", (req, res) => {
               body: JSON.stringify({ call_control_id: callControlId })
             });
             const data = await res.json();
-            setStatus(data.ok ? "Hung up successfully." : "Error: " + data.error);
+            setStatus(data.ok ? "Hung up successfully." : "Error hanging up.");
             fetchLogs();
           };
 
@@ -96,13 +91,16 @@ app.get("/", (req, res) => {
               <div className="bg-gray-800 rounded-lg overflow-hidden shadow-lg">
                 <table className="w-full text-left">
                   <thead className="bg-gray-900 text-gray-400 text-sm">
-                    <tr><th className="p-4">Call ID</th><th className="p-4">Number</th><th className="p-4">Status</th><th className="p-4">Action</th><th className="p-4">Recording</th></tr>
+                    <tr><th className="p-4">Call ID</th><th className="p-4">Number</th><th className="p-4">Last Transcript</th><th className="p-4">Status</th><th className="p-4">Action</th><th className="p-4">Recording</th></tr>
                   </thead>
                   <tbody className="divide-y divide-gray-700">
                     {logs.map(log => (
                       <tr key={log.id}>
                         <td className="p-4 text-xs font-mono text-gray-500">{log.call_control_id.slice(0,8)}...</td>
                         <td className="p-4 font-mono">{log.target_number}</td>
+                        <td className="p-4 text-xs text-gray-300 italic truncate max-w-[200px]" title={log.last_transcript}>
+                          {log.last_transcript || "..."}
+                        </td>
                         <td className="p-4">
                           <span className={\`px-2 py-1 rounded text-xs \${log.status === 'completed' ? 'bg-green-900 text-green-300' : 'bg-yellow-900 text-yellow-300'}\`}>
                             {log.status}
@@ -113,9 +111,7 @@ 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 ? 
@@ -125,7 +121,7 @@ app.get("/", (req, res) => {
                         </td>
                       </tr>
                     ))}
-                    {logs.length === 0 && <tr><td colSpan="5" className="p-4 text-center text-gray-500">No calls registered yet</td></tr>}
+                    {logs.length === 0 && <tr><td colSpan="6" className="p-4 text-center text-gray-500">No calls registered yet</td></tr>}
                   </tbody>
                 </table>
               </div>
@@ -142,6 +138,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 ─────────────
 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);
@@ -149,10 +146,7 @@ app.get("/play-recording/:call_control_id", async (req, res) => {
   try {
     const s3Res = await fetch(logEntry.raw_telnyx_url);
     if (!s3Res.ok) return res.sendStatus(s3Res.status);
-
-    const arrayBuffer = await s3Res.arrayBuffer();
-    const buffer = Buffer.from(arrayBuffer);
-
+    const buffer = Buffer.from(await s3Res.arrayBuffer());
     res.setHeader("Content-Type", "audio/mpeg");
     res.setHeader("Content-Length", buffer.length);
     res.send(buffer);
@@ -182,11 +176,9 @@ app.post("/dial", async (req, res) => {
     const data = await response.json();
     if (!response.ok) return res.status(400).json({ ok: false, error: data?.errors?.[0]?.detail });
 
-    const callControlId = data.data.call_control_id;
-
     callLogs.push({
       id: randomUUID(),
-      call_control_id: callControlId,
+      call_control_id: data.data.call_control_id,
       target_number: to,
       voice_used: voice,
       status: "dialing",
@@ -202,16 +194,14 @@ app.post("/dial", async (req, res) => {
   }
 });
 
-// ─── MANUAL HANG UP ROUTE ──────────────────────────
+// ─── 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" });
 
   try {
     await fetch(`https://api.telnyx.com/v2/calls/${call_control_id}/actions/hangup`, {
-      method: "POST",
-      headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-      body: JSON.stringify({}), 
+      method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` }, body: JSON.stringify({}), 
     });
     res.json({ ok: true });
   } catch (err) {
@@ -219,26 +209,38 @@ app.post("/call/hangup", async (req, res) => {
   }
 });
 
-// ─── TELNYX WEBHOOK (Turn Detection & Alerts) ────────────────
+// ─── TELNYX WEBHOOK (With Timeout Safety) ────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
   const callId = payload?.call_control_id;
-  const host = `https://${req.headers.host}`;
 
   if (!type) return res.sendStatus(200);
 
+  // ── FIX: AbortController prevents fetch from hanging indefinitely ──
   const telnyxCmd = async (action, body = {}) => {
+    const controller = new AbortController();
+    const timeout = setTimeout(() => controller.abort(), 5000); // 5 second hard timeout
+
     try {
+      log("TELNYX CMD DISPATCH", `Sending [${action}]...`);
       const response = await fetch(`https://api.telnyx.com/v2/calls/${callId}/actions/${action}`, {
         method: "POST",
         headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-        body: JSON.stringify(body)
+        body: JSON.stringify(body),
+        signal: controller.signal
       });
-      if (!response.ok) log("TELNYX CMD ERROR", `[${action}] failed (${response.status})`);
+      clearTimeout(timeout);
+      
+      if (!response.ok) {
+        log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${await response.text()}`);
+      } else {
+        log("TELNYX CMD SUCCESS", `[${action}] accepted.`);
+      }
       return response;
     } catch (e) {
-      log("TELNYX CMD NETWORK ERROR", e.message);
+      clearTimeout(timeout);
+      log("TELNYX CMD NETWORK ERROR", `[${action}] failed: ${e.message}`);
     }
   };
 
@@ -252,106 +254,98 @@ app.post("/webhook/call", async (req, res) => {
     return entry ? entry.voice_used : "Algieba";
   };
 
-  switch (type) {
-    case "call.initiated":
-      log("INITIATED", `from=${payload?.from} to=${payload?.to}`);
-      if (payload?.direction === "incoming") {
-        log("INBOUND", "Answering inbound call & alerting AI Server...");
-        
-        // ── NEW: Alert AI Server so human can pick up ──
-        fetch(`${AI_SERVER_URL}/api/inbound-call`, {
-          method: "POST", headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ from: payload?.from, to: payload?.to, call_id: callId })
-        }).catch(() => {});
-
-        callLogs.push({
-          id: randomUUID(),
-          call_control_id: callId,
-          target_number: payload?.from,
-          voice_used: "Algieba",
-          status: "in-progress",
-          last_transcript: "",
-          recording_url: null,
-          raw_telnyx_url: null,
-          created_at: new Date().toISOString()
-        });
-        await telnyxCmd("answer", {});
-      }
-      break;
-
-    case "call.answered":
-      log("ANSWERED", `Call ${callId} connected.`);
-      updateLog({ status: "in-progress" });
+  try {
+    switch (type) {
+      case "call.initiated":
+        log("INITIATED", `from=${payload?.from} to=${payload?.to}`);
+        if (payload?.direction === "incoming") {
+          log("INBOUND", "Answering inbound call...");
+          fetch(`${AI_SERVER_URL}/api/inbound-call`, {
+            method: "POST", headers: { "Content-Type": "application/json" },
+            body: JSON.stringify({ from: payload?.from, to: payload?.to, call_id: callId })
+          }).catch(() => {});
+
+          callLogs.push({
+            id: randomUUID(), call_control_id: callId, target_number: payload?.from, voice_used: "Algieba",
+            status: "in-progress", last_transcript: "", recording_url: null, raw_telnyx_url: null, created_at: new Date().toISOString()
+          });
+          await telnyxCmd("answer", {});
+        }
+        break;
 
-      await telnyxCmd("record_start", { format: "mp3", channels: "dual", play_beep: false });
-      
-      await telnyxCmd("playback_start", {
-        audio_url: `${host}/ambience.mp3`,
-        loop: "infinity",
-        target_legs: "self"
-      });
+      case "call.answered":
+        log("ANSWERED", `Call ${callId} connected.`);
+        updateLog({ status: "in-progress" });
 
-      await telnyxCmd("transcription_start", {
-        transcription_engine: "Telnyx",
-        transcription_tracks: "inbound"
-      });
+        await telnyxCmd("record_start", { format: "mp3", channels: "dual", play_beep: false });
+        
+        // Removed Ambience Playback entirely per your request
 
-      // ── FIX: Audio Playback URL uses Query Params ──
-      setTimeout(async () => {
-        const voice = getActiveVoice();
-        const phrase = encodeURIComponent("am I speaking with the business owner?");
-        await telnyxCmd("playback_start", {
-          audio_url: `${AI_SERVER_URL}/play-audio?voice=${voice}&phrase=${phrase}`,
-          target_legs: "self"
+        await telnyxCmd("transcription_start", {
+          transcription_engine: "Telnyx",
+          transcription_tracks: "inbound"
         });
-      }, 1500);
-
-      setTimeout(async () => {
-        await telnyxCmd("hangup", {});
-      }, 60000);
-      break;
-
-    case "call.transcription":
-      const data = payload?.transcription_data;
-      if (data && data.is_final) {
-        const transcript = data.transcript;
-        const voice = getActiveVoice();
-        log("TRANSCRIPT", `User said: "${transcript}"`);
-        updateLog({ last_transcript: transcript });
-
-        try {
-          const aiRes = await fetch(`${AI_SERVER_URL}/api/process-text-turn`, {
-            method: "POST",
-            headers: { "Content-Type": "application/json" },
-            body: JSON.stringify({ text: transcript, voice: voice })
+
+        setTimeout(async () => {
+          const voice = getActiveVoice();
+          const phrase = encodeURIComponent("am I speaking with the business owner?");
+          await telnyxCmd("playback_start", {
+            audio_url: `${AI_SERVER_URL}/play-audio?voice=${voice}&phrase=${phrase}`,
+            target_legs: "self"
           });
+        }, 1500);
+
+        setTimeout(async () => {
+          log("HANGUP", `Enforcing 60-second limit on call ${callId}`);
+          await telnyxCmd("hangup", {});
+        }, 60000);
+        break;
+
+      case "call.transcription":
+        const data = payload?.transcription_data;
+        if (data && data.is_final) {
+          const transcript = data.transcript;
+          const voice = getActiveVoice();
+          log("TRANSCRIPT", `User said: "${transcript}"`);
+          updateLog({ last_transcript: transcript });
+
+          try {
+            const aiRes = await fetch(`${AI_SERVER_URL}/api/process-text-turn`, {
+              method: "POST",
+              headers: { "Content-Type": "application/json" },
+              body: JSON.stringify({ text: transcript, voice: voice })
+            });
 
-          if (aiRes.ok) {
-            const aiData = await aiRes.json();
-            if (aiData.speak_url) {
-              log("AI_REPLY", `Instructing Telnyx to play generated reply.`);
-              await telnyxCmd("playback_start", {
-                audio_url: aiData.speak_url,
-                target_legs: "self"
-              });
+            if (aiRes.ok) {
+              const aiData = await aiRes.json();
+              if (aiData.speak_url) {
+                log("AI_REPLY", `Instructing Telnyx to play generated reply.`);
+                await telnyxCmd("playback_start", {
+                  audio_url: aiData.speak_url,
+                  target_legs: "self"
+                });
+              }
             }
-          }
-        } catch (e) { log("AI_SERVER_ERROR", e.message); }
-      }
-      break;
-
-    case "call.recording.saved":
-      updateLog({ 
-        status: "completed",
-        raw_telnyx_url: payload.recording_urls.mp3,
-        recording_url: `/play-recording/${callId}`
-      });
-      break;
+          } catch (e) { log("AI_SERVER_ERROR", e.message); }
+        }
+        break;
+
+      case "call.recording.saved":
+        log("RECORDING", `Saved. URL: ${payload.recording_urls.mp3}`);
+        updateLog({ 
+          status: "completed",
+          raw_telnyx_url: payload.recording_urls.mp3,
+          recording_url: `/play-recording/${callId}`
+        });
+        break;
 
-    case "call.hangup":
-      updateLog({ status: "completed" });
-      log("CALL ENDED", `Call ${callId} terminated.`);
-      break;
+      case "call.hangup":
+        updateLog({ status: "completed" });
+        log("CALL ENDED", `Call terminated.`);
+        break;
+    }
+  } catch (fatalError) {
+    log("WEBHOOK FATAL ERROR", fatalError.message);
   }
 
   res.sendStatus(200);