Update app.js

app.js

@@ -1,330 +1,3 @@
-/* import express from "express";
-import { createServer } from "http";
-import { WebSocketServer } from "ws";
-
-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());
-
-const PORT = process.env.PORT || 7860;
-const TELNYX_API_KEY       = process.env.TELNYX_API_KEY;
-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 TELNYX_ALPHA_SENDER  = process.env.TELNYX_ALPHA_SENDER || TELNYX_FROM_NUMBER; 
-const TELNYX_MESSAGING_PROFILE_ID = process.env.TELNYX_MESSAGING_PROFILE_ID;
-
-const ACTIVE_VOICE = "Enceladus_3";
-const log = (tag, ...args) => console.log(`[${new Date().toISOString()}] [${tag}]`, ...args);
-
-let pendingCalls = new Map(); 
-let activeLeadIds = new Map(); 
-const incomingCallDebounce = new Map(); 
-const agentDestinations = new Map(); // Stores where to route after Agent answers
-
-// ── MU-LAW VAD ──
-const MU_LAW_TABLE = new Int16Array(256);
-for (let i = 0; i < 256; i++) {
-  const sign = (i & 0x80) ? -1 : 1;
-  const exponent = (~i >> 4) & 0x07;
-  const mantissa = ~i & 0x0f;
-  const sample = ((mantissa << 3) + 132) << exponent;
-  MU_LAW_TABLE[i] = sign * (sample - 132);
-}
-function decodeMuLaw(buffer) {
-  const out = new Int16Array(buffer.length);
-  for (let i = 0; i < buffer.length; i++) out[i] = MU_LAW_TABLE[buffer[i]];
-  return out;
-}
-function calculateRMS(pcm) {
-  let sum = 0;
-  for (let i = 0; i < pcm.length; i++) sum += pcm[i] * pcm[i];
-  return Math.sqrt(sum / pcm.length);
-}
-
-const sendTelnyxCmd = async (callId, action, body = {}) => {
-  try {
-    const url = callId ? `https://api.telnyx.com/v2/calls/${callId}/actions/${action}` : `https://api.telnyx.com/v2/calls`;
-    const response = await fetch(url, {
-      method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-      body: JSON.stringify(body)
-    });
-    if (!response.ok) log("TELNYX CMD ERROR", `[${action}] ${await response.text()}`);
-    return response;
-  } catch (e) { log("TELNYX CMD NETWORK ERROR", e.message); }
-};
-
-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" });
-  
-  if (lead_id) activeLeadIds.set(call_control_id, lead_id);
-  pendingCalls.set(call_control_id, action);
-  
-  if (action === "reject") {
-    await sendTelnyxCmd(call_control_id, "hangup");
-    pendingCalls.delete(call_control_id);
-  } else {
-    await sendTelnyxCmd(call_control_id, "answer");
-  }
-  res.json({ ok: true });
-});
-
-app.post("/api/hangup", async (req, res) => {
-  await sendTelnyxCmd(req.body.call_control_id, "hangup");
-  res.json({ ok: true });
-});
-
-app.post("/api/send-sms", async (req, res) => {
-  log("SMS", `Attempting outbound SMS to ${req.body.to}...`);
-  try {
-     const sendRequest = async (fromNumber) => {
-         const payload = { from: fromNumber, to: req.body.to, text: req.body.text };
-         if (TELNYX_MESSAGING_PROFILE_ID) payload.messaging_profile_id = TELNYX_MESSAGING_PROFILE_ID;
-         
-         return await fetch("https://api.telnyx.com/v2/messages", {
-            method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-            body: JSON.stringify(payload)
-         });
-     };
-
-     let response = await sendRequest(TELNYX_ALPHA_SENDER);
-     let data = await response.json();
-
-     if (!response.ok && data.errors && data.errors.some(e => e.code === '40305' || e.code === '40012')) {
-         log("SMS WARNING", `Alpha Sender rejected. Falling back to standard US number ${TELNYX_FROM_NUMBER}...`);
-         response = await sendRequest(TELNYX_FROM_NUMBER);
-         data = await response.json();
-     }
-
-     if (!response.ok) log("SMS ERROR", JSON.stringify(data));
-     else log("SMS SUCCESS", `Message accepted by Telnyx for delivery to ${req.body.to}`);
-     
-     res.json(data);
-  } catch(e) { 
-     log("SMS NETWORK ERROR", e.message);
-     res.status(500).json({ error: e.message }); 
-  }
-});
-
-app.post("/dial", async (req, res) => {
-  const { to, lead_id, action = "manual" } = req.body;
-  log("DIAL", `Outbound request to ${to} (Mode: ${action})`);
-  
-  try {
-    let targetNumber = to;
-    const MY_CELL_NUMBER = "+2348069234734"; // Your agent number
-
-    // REVERSE DIALING: If manual, call the agent's cell phone FIRST
-    if (action === "manual") {
-      targetNumber = MY_CELL_NUMBER; 
-      log("DIAL", `Reverse dialing: Calling Agent ${MY_CELL_NUMBER} first...`);
-    }
-
-    const response = await fetch("https://api.telnyx.com/v2/calls", {
-      method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
-      body: JSON.stringify({ connection_id: TELNYX_CONNECTION_ID, to: targetNumber, from: TELNYX_FROM_NUMBER })
-    });
-    
-    const data = await response.json();
-    if (!response.ok) return res.status(400).json({ ok: false, error: data?.errors?.[0]?.detail });
-
-    const ccid = data.data.call_control_id;
-    
-    if (action === "manual") {
-      pendingCalls.set(ccid, "agent_leg");
-      agentDestinations.set(ccid, { to, lead_id }); // Save the lead's number for when you answer
-    } else {
-      pendingCalls.set(ccid, action); 
-    }
-    
-    if (lead_id) activeLeadIds.set(ccid, lead_id);
-
-    await fetch(`${AI_SERVER_URL}/api/log-outbound`, {
-      method: "POST", headers: { "Content-Type": "application/json" },
-      body: JSON.stringify({ call_control_id: ccid, action, lead_id })
-    }).catch(() => {});
-
-    res.json({ ok: true, call_control_id: ccid });
-  } catch (err) { res.status(500).json({ ok: false, error: err.message }); }
-});
-
-app.post("/webhook/call", async (req, res) => {
-  res.sendStatus(200); 
-  const type    = req.body?.data?.event_type;
-  const payload = req.body?.data?.payload;
-  const callId  = payload?.call_control_id;
-  if (!type) return;
-
-  switch (type) {
-    case "call.initiated":
-      if (payload?.direction === "incoming") {
-        const fromNumber = payload.from;
-        const now = Date.now();
-        
-        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: fromNumber })
-        }).catch(()=>{});
-      }
-      break;
-
-    case "call.answered":
-      // This block fires when the LEAD finally answers the second leg
-      if (payload?.client_state) {
-        const legACallId = Buffer.from(payload.client_state, "base64").toString("ascii");
-        log("BRIDGING", `Lead picked up! Stopping ringback and bridging you in instantly...`);
-        
-        // Stop the ringing sound playing in your (the agent's) ear
-        await sendTelnyxCmd(legACallId, "playback_stop");
-        
-        // Connect you to the lead immediately
-        await sendTelnyxCmd(callId, "bridge", { call_control_id: legACallId });
-        break;
-      }
-
-      const actionType = pendingCalls.get(callId) || "ai"; 
-      
-      await sendTelnyxCmd(callId, "record_start", { format: "mp3", channels: "dual", play_beep: false });
-
-      if (actionType === "agent_leg") {
-        // This block fires when YOU answer your cell phone
-        const dest = agentDestinations.get(callId);
-        log("BRIDGING", `You answered! Now automatically dialing the Lead at ${dest?.to}...`);
-        
-        // Play ringing to you so you know it's dialing the lead
-        await sendTelnyxCmd(callId, "playback_start", { 
-          audio_url: "https://actions.telnyx.com/sample-assets/ringback.wav", 
-          target_legs: "self" 
-        });
-
-        // Tell Telnyx to call the lead now
-        await sendTelnyxCmd(null, "dial", {
-          to: dest.to, 
-          from: TELNYX_FROM_NUMBER,
-          connection_id: TELNYX_CONNECTION_ID, 
-          // We pass your callId so the system knows who to connect the lead to when they answer
-          client_state: Buffer.from(callId).toString("base64") 
-        });
-        
-      } else if (actionType === "ai") {
-        log("AI CONNECTING", `Starting stream for ${callId}`);
-        await sendTelnyxCmd(callId, "playback_start", { audio_url: `http://${req.headers.host}/ambience.mp3`, target_legs: "caller", loop: "infinity" });
-        await sendTelnyxCmd(callId, "streaming_start", { stream_url: `wss://${req.headers.host}/audio-stream`, stream_track: "inbound_track" });
-        await sendTelnyxCmd(callId, "transcription_start", { transcription_engine: "Telnyx", transcription_tracks: "inbound" });
-        setTimeout(async () => { log("HANGUP", `Enforcing 90s limit on ${callId}`); await sendTelnyxCmd(callId, "hangup"); }, 90000);
-      }
-      break;
-
-    case "call.transcription":
-      if (!payload?.transcription_data?.is_final) break;
-      try {
-        const aiRes = await fetch(`${AI_SERVER_URL}/api/process-text-turn`, {
-          method: "POST", headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ text: payload.transcription_data.transcript.trim(), call_id: callId, lead_id: activeLeadIds.get(callId) || null })
-        });
-        if (aiRes.ok) {
-          const aiData = await aiRes.json();
-          if (aiData.speak_url) await sendTelnyxCmd(callId, "playback_start", { audio_url: aiData.speak_url, target_legs: "self" });
-        }
-      } catch (e) { log("AI_SERVER_ERROR", e.message); }
-      break;
-      
-    case "call.recording.saved":
-      if (payload.recording_urls?.mp3) {
-        await fetch(`${AI_SERVER_URL}/api/save-recording`, {
-          method: "POST", headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ call_control_id: callId, recording_url: payload.recording_urls.mp3 })
-        })
-        .then(async (r) => { if (!r.ok) log("RECORDING ERROR", `AI Server status: ${r.status}`); })
-        .catch((err) => log("RECORDING NET ERROR", err.message));
-      }
-      break;
-
-    case "call.hangup":
-      log("HANGUP", `Call ended. Reason: ${payload.hangup_cause}`); 
-      pendingCalls.delete(callId);
-      activeLeadIds.delete(callId);
-      agentDestinations.delete(callId); // Clean up the map
-      await fetch(`${AI_SERVER_URL}/api/call-ended`, {
-        method: "POST", headers: { "Content-Type": "application/json" },
-        body: JSON.stringify({ call_control_id: callId })
-      }).catch(() => {});
-      break;
-  }
-});
-
-wss.on("connection", (ws) => {
-  let isSpeaking = false;
-  let silenceFrames = 0;
-  let callControlId = null;
-  let hasPlayedFiller = false;
-  let hasGreeted = false;
-  let totalNoiseFrames = 0;
-
-  ws.on("message", async (raw) => {
-    try {
-      const msg = JSON.parse(raw);
-      if (msg.event === "start") {
-        callControlId = msg.start?.call_control_id;
-        setTimeout(async () => {
-          if (hasGreeted || !callControlId) return;
-          hasGreeted = true;
-          const greetingPhrase = "Hi, this is Nathan.";
-          await sendTelnyxCmd(callControlId, "playback_start", { audio_url: `${AI_SERVER_URL}/play-audio?voice=${ACTIVE_VOICE}&phrase=${encodeURIComponent(greetingPhrase)}`, target_legs: "self" });
-          fetch(`${AI_SERVER_URL}/api/register-greeting`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ call_id: callControlId, phrase: greetingPhrase, lead_id: activeLeadIds.get(callControlId) || null }) }).catch(() => {});
-        }, 1500);
-      }
-
-      if (msg.event === "media") {
-        const pcm16 = decodeMuLaw(Buffer.from(msg.media.payload, "base64"));
-        const rms = calculateRMS(pcm16);
-
-        if (rms > 500) {
-          hasGreeted = true;
-          silenceFrames = 0;
-          totalNoiseFrames++;
-          if (!isSpeaking) {
-            isSpeaking = true;
-            hasPlayedFiller = false;
-            await sendTelnyxCmd(callControlId, "playback_stop"); 
-          }
-        } else if (isSpeaking) {
-          silenceFrames++;
-          if (silenceFrames > 35 && !hasPlayedFiller) {
-            hasPlayedFiller = true;
-            isSpeaking = false;
-            if (totalNoiseFrames > 40) {
-              const fillers = ["Right.", "Got it.", "Okay.", "Yeah.", "Ah, okay."];
-              sendTelnyxCmd(callControlId, "playback_start", { audio_url: `${AI_SERVER_URL}/play-audio?voice=${ACTIVE_VOICE}&phrase=${encodeURIComponent(fillers[Math.floor(Math.random() * fillers.length)])}`, target_legs: "self" }).catch(() => {});
-            }
-            totalNoiseFrames = 0;
-          }
-        }
-      }
-    } catch {}
-  });
-});
-
-server.listen(PORT, "0.0.0.0", () => {
-  log("STARTUP", `Telecom routing server running on port ${PORT}`);
-});
-*/
-
 import express from "express";
 import { createServer } from "http";
 import { WebSocketServer } from "ws";
@@ -341,7 +14,6 @@ const TELNYX_API_KEY       = process.env.TELNYX_API_KEY;
 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 SIP_USERNAME         = process.env.TELNYX_SIP_USERNAME;
 const TELNYX_ALPHA_SENDER  = process.env.TELNYX_ALPHA_SENDER || TELNYX_FROM_NUMBER; 
 const TELNYX_MESSAGING_PROFILE_ID = process.env.TELNYX_MESSAGING_PROFILE_ID;
 
@@ -495,9 +167,12 @@ app.post("/webhook/call", async (req, res) => {
     case "call.answered":
       if (payload?.client_state) {
         const legACallId = Buffer.from(payload.client_state, "base64").toString("ascii");
-        log("BRIDGING", `Agent picked up via WebRTC! Stopping ringback and Bridging Leg A (${legACallId}) ↔ Leg B (${callId})`);
+        log("BRIDGING", `Agent picked up! Stopping ringback and Bridging Leg A (${legACallId}) ↔ Leg B (${callId})`);
         
+        // Stop the ringing sound for the customer
         await sendTelnyxCmd(legACallId, "playback_stop");
+        
+        // Bridge them
         await sendTelnyxCmd(callId, "bridge", { call_control_id: legACallId });
         break;
       }
@@ -507,17 +182,18 @@ app.post("/webhook/call", async (req, res) => {
       await sendTelnyxCmd(callId, "record_start", { format: "mp3", channels: "dual", play_beep: false });
 
       if (actionType === "manual") {
-        log("BRIDGING", `Dialing Telnyx WebRTC client for manual takeover...`);
+        log("BRIDGING", `Dialing Agent Cell (+2348069234734) for manual takeover...`);
         
-        // Play ringing to the customer while they wait for you
+        // 1. Play ringing to the customer
         await sendTelnyxCmd(callId, "playback_start", { 
           audio_url: "https://actions.telnyx.com/sample-assets/ringback.wav", 
           target_legs: "self" 
         });
 
-        // Dial your SIP Username
+        // 2. Dial your cell phone
+        const MY_CELL_NUMBER = "+2348069234734"; 
         await sendTelnyxCmd(null, "dial", {
-          to: `sip:${SIP_USERNAME}@sip.telnyx.com`, 
+          to: MY_CELL_NUMBER, 
           from: TELNYX_FROM_NUMBER,
           connection_id: TELNYX_CONNECTION_ID, 
           client_state: Buffer.from(callId).toString("base64")