Update app.js

app.js

@@ -23,6 +23,7 @@ const log = (tag, ...args) => console.log(`[${new Date().toISOString()}] [${tag}
 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);
@@ -111,17 +112,35 @@ app.post("/api/send-sms", async (req, res) => {
 
 app.post("/dial", async (req, res) => {
   const { to, lead_id, action = "manual" } = req.body;
-  log("DIAL", `Outbound to ${to} (Mode: ${action})`);
+  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, from: TELNYX_FROM_NUMBER })
+      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;
-    pendingCalls.set(ccid, action); 
+    
+    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`, {
@@ -165,14 +184,15 @@ app.post("/webhook/call", async (req, res) => {
       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", `Agent picked up! Stopping ringback and Bridging Leg A (${legACallId}) ↔ Leg B (${callId})`);
+        log("BRIDGING", `Lead picked up! Stopping ringback and bridging you in instantly...`);
         
-        // Stop the ringing sound for the customer
+        // Stop the ringing sound playing in your (the agent's) ear
         await sendTelnyxCmd(legACallId, "playback_stop");
         
-        // Bridge them
+        // Connect you to the lead immediately
         await sendTelnyxCmd(callId, "bridge", { call_control_id: legACallId });
         break;
       }
@@ -181,24 +201,27 @@ 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 Agent Cell (+2348069234734) for manual takeover...`);
+      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}...`);
         
-        // 1. Play ringing to the customer
+        // 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" 
         });
 
-        // 2. Dial your cell phone
-        const MY_CELL_NUMBER = "+2347066923490"; 
+        // Tell Telnyx to call the lead now
         await sendTelnyxCmd(null, "dial", {
-          to: MY_CELL_NUMBER, 
+          to: dest.to, 
           from: TELNYX_FROM_NUMBER,
           connection_id: TELNYX_CONNECTION_ID, 
-          client_state: Buffer.from(callId).toString("base64")
+          // 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 {
+        
+      } 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" });
@@ -236,6 +259,7 @@ app.post("/webhook/call", async (req, res) => {
       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 })