Update app.js

app.js

@@ -334,4 +334,87 @@ app.post("/webhook/call", async (req, res) => {
         const voice = getActiveVoice();
         const exactPhrase = encodeURIComponent("am I speaking with the business owner?");
         await telnyxCmd("playback_start", {
-          audio_url: `${AI_SERVER_URL}/play-aud
+          audio_url: `${AI_SERVER_URL}/play-audio/${voice}/${exactPhrase}`,
+          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;
+
+    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"
+              });
+            }
+          }
+        } 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,
+        recording_url: `/play-recording/${callId}`
+      });
+      break;
+
+    case "call.hangup":
+      updateLog({ status: "completed" });
+      log("CALL ENDED", `Call ${callId} has cleanly 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}`);
+});