Update app.js

app.js

@@ -22,6 +22,9 @@ const log = (tag, ...args) => console.log(`[${new Date().toISOString()}] [${tag}
 let pendingCalls = new Map(); 
 let activeLeadIds = new Map(); 
 
+// 10-Second Debounce Buffer for Telnyx Incoming Webhook Spam
+const incomingCallDebounce = new Map(); 
+
 // ── MU-LAW VAD ──
 const MU_LAW_TABLE = new Int16Array(256);
 for (let i = 0; i < 256; i++) {
@@ -58,7 +61,7 @@ app.post("/api/call-action", async (req, res) => {
   const { call_control_id, action, lead_id } = req.body;
   if (!pendingCalls.has(call_control_id)) return res.status(404).json({ error: "Call not pending" });
   
-  activeLeadIds.set(call_control_id, lead_id);
+  if (lead_id) activeLeadIds.set(call_control_id, lead_id);
   pendingCalls.set(call_control_id, action);
   
   if (action === "reject") {
@@ -75,6 +78,16 @@ app.post("/api/hangup", async (req, res) => {
   res.json({ ok: true });
 });
 
+app.post("/api/send-sms", async (req, res) => {
+  try {
+     const response = await fetch("https://api.telnyx.com/v2/messages", {
+        method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
+        body: JSON.stringify({ from: TELNYX_FROM_NUMBER, to: req.body.to, text: req.body.text })
+     });
+     res.json(await response.json());
+  } catch(e) { res.status(500).json({ error: e.message }); }
+});
+
 app.post("/dial", async (req, res) => {
   const { to, lead_id, action = "manual" } = req.body;
   log("DIAL", `Outbound to ${to} (Mode: ${action})`);
@@ -109,13 +122,23 @@ app.post("/webhook/call", async (req, res) => {
   switch (type) {
     case "call.initiated":
       if (payload?.direction === "incoming") {
-        if (pendingCalls.has(callId)) return; // DEDUPLICATE SPAM FROM TELNYX FAILOVER
+        const fromNumber = payload.from;
+        const now = Date.now();
         
-        log("INCOMING", `From: ${payload.from}`);
+        if (incomingCallDebounce.has(fromNumber)) {
+           if (now - incomingCallDebounce.get(fromNumber) < 10000) {
+              log("INCOMING DEBOUNCED", `Ignoring duplicate payload from ${fromNumber}`);
+              return;
+           }
+        }
+        incomingCallDebounce.set(fromNumber, now);
+
+        log("INCOMING", `From: ${fromNumber}`);
         pendingCalls.set(callId, "waiting");
+        
         await fetch(`${AI_SERVER_URL}/api/incoming-call`, {
           method: "POST", headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ call_control_id: callId, from: payload.from })
+          body: JSON.stringify({ call_control_id: callId, from: fromNumber })
         }).catch(()=>{});
       }
       break;