Jjj

Paused

App Files Files Community

Pepguy commited on Jun 24

Commit

233fa4e

verified ·

1 Parent(s): d644408

Update app.js

Browse files

Files changed (1) hide show

app.js +20 -35

app.js CHANGED Viewed

@@ -24,7 +24,6 @@ const log = (tag, ...args) => {
 let callLogs = [];
-// ─── UTILITY: GLOBAL TELNYX COMMAND DISPATCHER ───
 const sendTelnyxCmd = async (callId, action, body = {}) => {
   try {
     const response = await fetch(`https://api.telnyx.com/v2/calls/${callId}/actions/${action}`, {
@@ -32,7 +31,6 @@ const sendTelnyxCmd = async (callId, action, body = {}) => {
       headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
       body: JSON.stringify(body)
     });
     if (!response.ok) {
       log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${await response.text()}`);
     } else {
@@ -56,7 +54,6 @@ const clearCallTimers = (entry) => {
   entry.timers = {};
 };
-// ─── VAD MATH UTILITIES ───
 const MU_LAW_TABLE = new Int16Array(256);
 for (let i = 0; i < 256; i++) {
   let sign = (i & 0x80) ? -1 : 1;
@@ -78,9 +75,6 @@ function calculateRMS(pcm16Array) {
   return Math.sqrt(sum / pcm16Array.length);
 }
-// ─────────────────────────────────────────────
-// 1. EMBEDDED DASHBOARD
-// ─────────────────────────────────────────────
 app.get("/", (req, res) => {
   res.send(`
     <!DOCTYPE html>
@@ -209,11 +203,9 @@ app.get("/api/logs", (req, res) => {
 app.get("/health", (req, res) => res.json({ status: "ok", uptime: process.uptime() }));
-// ─── 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 {
     const s3Res = await fetch(logEntry.raw_telnyx_url);
     if (!s3Res.ok) return res.sendStatus(s3Res.status);
@@ -226,11 +218,9 @@ app.get("/play-recording/:call_control_id", async (req, res) => {
   }
 });
-// ─── DIAL OUT ROUTE ────────────────────────────────────────
 app.post("/dial", async (req, res) => {
   const { to } = req.body;
-  // SETTING ENCELADUS AS THE DEFAULT VOICE
-  const voice = "Enceladus";
   log("DIAL", `Dialing ${to}...`);
   try {
@@ -268,7 +258,6 @@ app.post("/dial", async (req, res) => {
   }
 });
-// ─── MANUAL HANG UP ────────────────────────────────────────
 app.post("/call/hangup", async (req, res) => {
   const { call_control_id } = req.body;
   if (!call_control_id) return res.status(400).json({ error: "Missing call_control_id" });
@@ -281,7 +270,6 @@ app.post("/call/hangup", async (req, res) => {
   }
 });
-// ─── HYBRID WEBHOOK (Telnyx STT Engine + VAD) ──────────────
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
@@ -307,7 +295,7 @@ app.post("/webhook/call", async (req, res) => {
         callLogs.push({
           id: randomUUID(), call_control_id: callId, target_number: payload?.from,
-          voice_used: "Enceladus", status: "in-progress", last_transcript: "", recording_url: null,
           raw_telnyx_url: null, is_playing: false, timers: {}, created_at: new Date().toISOString()
         });
         await sendTelnyxCmd(callId, "answer");
@@ -316,7 +304,7 @@ app.post("/webhook/call", async (req, res) => {
     case "call.answered":
       log("ANSWERED", `Call ${callId} connected.`);
-      updateLog(callId, { status: "in-progress" });
       await sendTelnyxCmd(callId, "record_start", { format: "mp3", channels: "dual", play_beep: false });
@@ -351,9 +339,8 @@ app.post("/webhook/call", async (req, res) => {
       const data = payload?.transcription_data;
       if (!data) break;
-      const voice = entry ? entry.voice_used : "Enceladus";
-      // 1. BARGE-IN (User is currently speaking)
       if (!data.is_final) {
         if (entry && entry.is_playing) {
           log("BARGE-IN", "User is speaking. Shutting up AI.");
@@ -362,7 +349,6 @@ app.post("/webhook/call", async (req, res) => {
         }
       }
-      // 2. TURN ENDED (User finished speaking)
       if (data.is_final) {
         const transcript = data.transcript.trim();
         if (!transcript) break;
@@ -370,7 +356,6 @@ app.post("/webhook/call", async (req, res) => {
         log("TRANSCRIPT", `User said: "${transcript}"`);
         updateLog(callId, { last_transcript: transcript });
-        // FETCH FULL AI RESPONSE
         try {
           const aiRes = await fetch(`${AI_SERVER_URL}/api/process-text-turn`, {
             method: "POST",
@@ -381,7 +366,7 @@ app.post("/webhook/call", async (req, res) => {
           if (aiRes.ok) {
             const aiData = await aiRes.json();
             if (aiData.speak_url && entry && entry.status !== "completed") {
-              log("AI_REPLY", `Playing full reply: ${aiData.raw_text}`);
               updateLog(callId, { is_playing: true });
               await sendTelnyxCmd(callId, "playback_start", {
                 audio_url: aiData.speak_url,
@@ -413,7 +398,6 @@ app.post("/webhook/call", async (req, res) => {
   res.sendStatus(200);
 });
-// ─── WEBSOCKET (VAD & Early Staller) ───
 wss.on("connection", (ws, req) => {
   log("WS", `VAD WebSocket connected`);
@@ -424,9 +408,8 @@ wss.on("connection", (ws, req) => {
   let hasGreeted = false;
   let totalNoiseFrames = 0;
-  // INCREASED THRESHOLDS FOR A MORE PATIENT AI
-  const SILENCE_THRESHOLD_FRAMES = 37; // ~750ms of silence needed before declaring a turn end
-  const VOLUME_THRESHOLD = 500; // Require louder noise to prevent false barge-ins
   ws.on("message", async (raw) => {
     try {
@@ -435,12 +418,11 @@ wss.on("connection", (ws, req) => {
       if (msg.event === "start") {
         callControlId = msg.start?.call_control_id;
-        // Smart Initial Greeting
         setTimeout(async () => {
           if (!hasGreeted && callControlId) {
              const entry = callLogs.find(l => l.call_control_id === callControlId);
              if (entry && entry.status === "in-progress") {
-               const voice = entry.voice_used || "Enceladus";
                log("SMART_GREETING", "No immediate human audio detected. Saying Hello.");
                entry.is_playing = true;
                hasGreeted = true;
@@ -482,23 +464,26 @@ wss.on("connection", (ws, req) => {
             hasPlayedFiller = true;
             isSpeaking = false;
-            // LAZY BACKCHANNELING:
-            // Only play a filler word if they spoke continuously for ~800ms
-            // This prevents it from saying "Okay" to an IVR breath or a short "Yeah".
-            if (totalNoiseFrames > 40) {
-              log("VAD_EARLY_TURN", "Long sentence detected. Playing early staller...");
-              const entry = callLogs.find(l => l.call_control_id === callControlId);
-              const voice = entry ? entry.voice_used : "Enceladus";
               const fillers = ["Right.", "Got it.", "Okay.", "Yeah.", "Ah, okay."];
               const filler = fillers[Math.floor(Math.random() * fillers.length)];
               if (entry) entry.is_playing = true;
               sendTelnyxCmd(callControlId, "playback_start", {
                 audio_url: `${AI_SERVER_URL}/play-audio?voice=${voice}&phrase=${encodeURIComponent(filler)}`,
                 target_legs: "self"
-              }).catch(()=>{});
             }
             totalNoiseFrames = 0;
           }
         }

 let callLogs = [];
 const sendTelnyxCmd = async (callId, action, body = {}) => {
   try {
     const response = await fetch(`https://api.telnyx.com/v2/calls/${callId}/actions/${action}`, {
       headers: { "Content-Type": "application/json", Authorization: `Bearer ${TELNYX_API_KEY}` },
       body: JSON.stringify(body)
     });
     if (!response.ok) {
       log("TELNYX CMD ERROR", `[${action}] failed (${response.status}): ${await response.text()}`);
     } else {
   entry.timers = {};
 };
 const MU_LAW_TABLE = new Int16Array(256);
 for (let i = 0; i < 256; i++) {
   let sign = (i & 0x80) ? -1 : 1;
   return Math.sqrt(sum / pcm16Array.length);
 }
 app.get("/", (req, res) => {
   res.send(`
     <!DOCTYPE html>
 app.get("/health", (req, res) => res.json({ status: "ok", uptime: process.uptime() }));
 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 {
     const s3Res = await fetch(logEntry.raw_telnyx_url);
     if (!s3Res.ok) return res.sendStatus(s3Res.status);
   }
 });
 app.post("/dial", async (req, res) => {
   const { to } = req.body;
+  const voice = "Enceladus_2";
   log("DIAL", `Dialing ${to}...`);
   try {
   }
 });
 app.post("/call/hangup", async (req, res) => {
   const { call_control_id } = req.body;
   if (!call_control_id) return res.status(400).json({ error: "Missing call_control_id" });
   }
 });
 app.post("/webhook/call", async (req, res) => {
   const type = req.body?.data?.event_type;
   const payload = req.body?.data?.payload;
         callLogs.push({
           id: randomUUID(), call_control_id: callId, target_number: payload?.from,
+          voice_used: "Enceladus_2", status: "in-progress", last_transcript: "", recording_url: null,
           raw_telnyx_url: null, is_playing: false, timers: {}, created_at: new Date().toISOString()
         });
         await sendTelnyxCmd(callId, "answer");
     case "call.answered":
       log("ANSWERED", `Call ${callId} connected.`);
+      updateLog(callId, { status: "in-progress", answered_at: new Date().toISOString() });
       await sendTelnyxCmd(callId, "record_start", { format: "mp3", channels: "dual", play_beep: false });
       const data = payload?.transcription_data;
       if (!data) break;
+      const voice = entry ? entry.voice_used : "Enceladus_2";
       if (!data.is_final) {
         if (entry && entry.is_playing) {
           log("BARGE-IN", "User is speaking. Shutting up AI.");
         }
       }
       if (data.is_final) {
         const transcript = data.transcript.trim();
         if (!transcript) break;
         log("TRANSCRIPT", `User said: "${transcript}"`);
         updateLog(callId, { last_transcript: transcript });
         try {
           const aiRes = await fetch(`${AI_SERVER_URL}/api/process-text-turn`, {
             method: "POST",
           if (aiRes.ok) {
             const aiData = await aiRes.json();
             if (aiData.speak_url && entry && entry.status !== "completed") {
+              log("AI_REPLY", `Playing full reply.`);
               updateLog(callId, { is_playing: true });
               await sendTelnyxCmd(callId, "playback_start", {
                 audio_url: aiData.speak_url,
   res.sendStatus(200);
 });
 wss.on("connection", (ws, req) => {
   log("WS", `VAD WebSocket connected`);
   let hasGreeted = false;
   let totalNoiseFrames = 0;
+  const SILENCE_THRESHOLD_FRAMES = 37;
+  const VOLUME_THRESHOLD = 500;
   ws.on("message", async (raw) => {
     try {
       if (msg.event === "start") {
         callControlId = msg.start?.call_control_id;
         setTimeout(async () => {
           if (!hasGreeted && callControlId) {
              const entry = callLogs.find(l => l.call_control_id === callControlId);
              if (entry && entry.status === "in-progress") {
+               const voice = entry.voice_used || "Enceladus_2";
                log("SMART_GREETING", "No immediate human audio detected. Saying Hello.");
                entry.is_playing = true;
                hasGreeted = true;
             hasPlayedFiller = true;
             isSpeaking = false;
+            const entry = callLogs.find(l => l.call_control_id === callControlId);
+            const voice = entry ? entry.voice_used : "Enceladus_2";
+            const callAge = entry?.answered_at
+              ? Date.now() - new Date(entry.answered_at).getTime()
+              : 0;
+            if (totalNoiseFrames > 40 && callAge > 8000) {
+              log("VAD_EARLY_TURN", "Long sentence detected. Playing early staller...");
               const fillers = ["Right.", "Got it.", "Okay.", "Yeah.", "Ah, okay."];
               const filler = fillers[Math.floor(Math.random() * fillers.length)];
               if (entry) entry.is_playing = true;
               sendTelnyxCmd(callControlId, "playback_start", {
                 audio_url: `${AI_SERVER_URL}/play-audio?voice=${voice}&phrase=${encodeURIComponent(filler)}`,
                 target_legs: "self"
+              }).catch(() => {});
+            } else {
+              log("VAD_BLACKOUT", `Suppressed filler (call age: ${callAge}ms)`);
             }
             totalNoiseFrames = 0;
           }
         }