Update app.js

app.js

@@ -148,25 +148,20 @@ app.get("/health", (req, res) => {
 });
 
 // ─────────────────────────────────────────────
-// 2. PROXY FOR TELNYX RECORDINGS (FIXED AWS S3 ISSUE)
+// 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 {
-    // FIX: Telnyx returns an AWS S3 presigned URL. 
-    // Do NOT send the Telnyx Bearer token here, or AWS blocks it with a 400 error!
     const s3Res = await fetch(logEntry.raw_telnyx_url);
-    
     if (!s3Res.ok) {
       log("PROXY ERROR", `S3 returned ${s3Res.status}`);
       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);
@@ -220,7 +215,7 @@ app.post("/dial", async (req, res) => {
 });
 
 // ─────────────────────────────────────────────
-// 4. MANUAL HANG UP ROUTE (Robust Error Checking)
+// 4. MANUAL HANG UP ROUTE (FIXED)
 // ─────────────────────────────────────────────
 app.post("/call/hangup", async (req, res) => {
   const { call_control_id } = req.body;
@@ -237,7 +232,8 @@ app.post("/call/hangup", async (req, res) => {
           "Content-Type": "application/json",
           Authorization: `Bearer ${TELNYX_API_KEY}`,
         },
-        body: JSON.stringify({ client_state: "manual_hangup" }), // Prevents silent rejection
+        // FIX: Completely stripped out client_state. Passing an empty object.
+        body: JSON.stringify({}), 
       }
     );
 
@@ -256,7 +252,7 @@ app.post("/call/hangup", async (req, res) => {
 });
 
 // ─────────────────────────────────────────────
-// 5. TELNYX WEBHOOK (Turn Detection & Automation)
+// 5. TELNYX WEBHOOK (FIXED)
 // ─────────────────────────────────────────────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
@@ -266,11 +262,8 @@ app.post("/webhook/call", async (req, res) => {
 
   if (!type) return res.sendStatus(200);
 
-  // ── FIX: Robust Telnyx Command Dispatcher ──
-  // If Telnyx rejects a command, this will log exactly why it failed.
+  // ── FIX: Clean Telnyx Dispatcher (No base64 string breaking the API) ──
   const telnyxCmd = async (action, body = {}) => {
-    // Adding client_state ensures Telnyx tracks the command properly
-    body.client_state = body.client_state || `cmd_${action}_${randomUUID().split('-')[0]}`;
     try {
       const response = await fetch(`https://api.telnyx.com/v2/calls/${callId}/actions/${action}`, {
         method: "POST",
@@ -341,77 +334,4 @@ 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-audio/${voice}/${exactPhrase}`,
-          target_legs: "self"
-        });
-      }, 1500);
-
-      // ── FIX: Auto-Hangup fallback. ──
-      setTimeout(async () => {
-        log("HANGUP", `Enforcing 60-second limit on call ${callId}`);
-        await telnyxCmd("hangup", { client_state: "auto_timeout" });
-      }, 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);
-});
-
-server.listen(PORT, "0.0.0.0", () => {
-  log("STARTUP", `Telecom Server running on port ${PORT}`);
-});
+          audio_url: `${AI_SERVER_URL}/play-aud