Update app.js

app.js

@@ -139,41 +139,29 @@ 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() });
-});
+app.get("/api/logs", (req, res) => res.json([...callLogs].reverse()));
+app.get("/health", (req, res) => res.json({ status: "ok", uptime: process.uptime() }));
 
-// ─────────────────────────────────────────────
-// 2. 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);
 
   try {
     const s3Res = await fetch(logEntry.raw_telnyx_url);
-    if (!s3Res.ok) {
-      log("PROXY ERROR", `S3 returned ${s3Res.status}`);
-      return res.sendStatus(s3Res.status);
-    }
+    if (!s3Res.ok) return res.sendStatus(s3Res.status);
+
     const arrayBuffer = await s3Res.arrayBuffer();
     const buffer = Buffer.from(arrayBuffer);
+
     res.setHeader("Content-Type", "audio/mpeg");
     res.setHeader("Content-Length", buffer.length);
     res.send(buffer);
   } catch (e) {
-    log("PROXY ERROR", e.message);
     res.sendStatus(500);
   }
 });
 
-// ─────────────────────────────────────────────
-// 3. DIAL OUT ROUTE
-// ─────────────────────────────────────────────
+// ─── DIAL OUT ROUTE ──────────────────────────
 app.post("/dial", async (req, res) => {
   const { to } = req.body;
   const voice = "Algieba"; 
@@ -214,46 +202,24 @@ app.post("/dial", async (req, res) => {
   }
 });
 
-// ─────────────────────────────────────────────
-// 4. MANUAL HANG UP ROUTE (FIXED)
-// ─────────────────────────────────────────────
+// ─── MANUAL HANG UP ROUTE ──────────────────────────
 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" });
 
-  log("HANGUP", `Manual hangup request for ${call_control_id}`);
-
   try {
-    const response = 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}`,
-        },
-        // FIX: Completely stripped out client_state. Passing an empty object.
-        body: JSON.stringify({}), 
-      }
-    );
-
-    if (!response.ok) {
-      const errText = await response.text();
-      log("HANGUP ERROR", `Telnyx rejected manual hangup (${response.status}): ${errText}`);
-      return res.status(response.status).json({ ok: false, error: errText });
-    }
-
-    log("HANGUP SUCCESS", "Manual hangup command accepted.");
+    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({}), 
+    });
     res.json({ ok: true });
   } catch (err) {
-    log("HANGUP NETWORK ERROR", err.message);
     res.status(500).json({ ok: false, error: err.message });
   }
 });
 
-// ─────────────────────────────────────────────
-// 5. TELNYX WEBHOOK (FIXED)
-// ─────────────────────────────────────────────
+// ─── TELNYX WEBHOOK (Turn Detection & Alerts) ────────────────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
@@ -262,7 +228,6 @@ app.post("/webhook/call", async (req, res) => {
 
   if (!type) return res.sendStatus(200);
 
-  // ── FIX: Clean Telnyx Dispatcher (No base64 string breaking the API) ──
   const telnyxCmd = async (action, body = {}) => {
     try {
       const response = await fetch(`https://api.telnyx.com/v2/calls/${callId}/actions/${action}`, {
@@ -270,12 +235,7 @@ app.post("/webhook/call", async (req, res) => {
         headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
         body: JSON.stringify(body)
       });
-      if (!response.ok) {
-        const errText = await response.text();
-        log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${errText}`);
-      } else {
-        log("TELNYX CMD SUCCESS", `[${action}] accepted.`);
-      }
+      if (!response.ok) log("TELNYX CMD ERROR", `[${action}] failed (${response.status})`);
       return response;
     } catch (e) {
       log("TELNYX CMD NETWORK ERROR", e.message);
@@ -294,9 +254,16 @@ app.post("/webhook/call", async (req, res) => {
 
   switch (type) {
     case "call.initiated":
-      log("INITIATED", `from=${payload?.from} to=${payload?.to} direction=${payload?.direction}`);
+      log("INITIATED", `from=${payload?.from} to=${payload?.to}`);
       if (payload?.direction === "incoming") {
-        log("INBOUND", "Answering inbound call...");
+        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,
@@ -317,31 +284,29 @@ app.post("/webhook/call", async (req, res) => {
       updateLog({ status: "in-progress" });
 
       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"
       });
 
-      log("STT", "Activating native Telnyx real-time transcription engine...");
       await telnyxCmd("transcription_start", {
         transcription_engine: "Telnyx",
         transcription_tracks: "inbound"
       });
 
+      // ── FIX: Audio Playback URL uses Query Params ──
       setTimeout(async () => {
         const voice = getActiveVoice();
-        const exactPhrase = encodeURIComponent("am I speaking with the business owner?");
+        const phrase = encodeURIComponent("am I speaking with the business owner?");
         await telnyxCmd("playback_start", {
-          audio_url: `${AI_SERVER_URL}/play-audio/${voice}/${exactPhrase}`,
+          audio_url: `${AI_SERVER_URL}/play-audio?voice=${voice}&phrase=${phrase}`,
           target_legs: "self"
         });
       }, 1500);
 
-      // ── FIX: Clean auto-hangup (no client_state) ──
       setTimeout(async () => {
-        log("HANGUP", `Enforcing 60-second limit on call ${callId}`);
         await telnyxCmd("hangup", {});
       }, 60000);
       break;
@@ -371,50 +336,27 @@ app.post("/webhook/call", async (req, res) => {
               });
             }
           }
-        } catch (e) {
-          log("AI_SERVER_ERROR", e.message);
-        }
+        } catch (e) { log("AI_SERVER_ERROR", e.message); }
       }
       break;
 
     case "call.recording.saved":
-      const rawUrl = payload.recording_urls.mp3;
-      log("RECORDING", `Saved. URL: ${rawUrl}`);
       updateLog({ 
         status: "completed",
-        raw_telnyx_url: rawUrl,
+        raw_telnyx_url: payload.recording_urls.mp3,
         recording_url: `/play-recording/${callId}`
       });
       break;
 
     case "call.hangup":
       updateLog({ status: "completed" });
-      log("CALL ENDED", `Call ${callId} has cleanly terminated.`);
+      log("CALL ENDED", `Call ${callId} terminated.`);
       break;
   }
 
   res.sendStatus(200);
 });
 
-// ─── SMS WEBHOOK ─────────────────────────────
-app.post("/webhook/sms", (req, res) => {
-  const type = req.body?.data?.event_type;
-  if (type === "message.received") {
-    log("SMS INBOUND", `from=${req.body?.data?.payload?.from?.phone_number}`);
-  }
-  res.sendStatus(200);
-});
-
-wss.on("connection", (ws, req) => {
-  log("WS", `Legacy media connection from ${req.socket.remoteAddress}`);
-  ws.on("message", (raw) => {});
-});
-
-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}`);
-});
-
 server.listen(PORT, "0.0.0.0", () => {
   log("STARTUP", `Telecom Server running on port ${PORT}`);
 });