实现Twilio掩码号码呼叫未接听时的语音留言功能

const twilio = require("twilio"); const express = require("express"); const router = express.Router();  // 假设这些是您的数据库和邮件发送工具函数 const { getNumberWithoutUser, updateQuota } = require("../db/dbOperations"); const { sendMessageNotificationEmail } = require("../emailing/email"); const { sendSms, client } = require("../twilioFunctions"); const { appendMessage } = require("../db/messagingCollectionUtils"); const { appendCall } = require("../db/callsCollectionUtils");  router.post("/webhook/voice", async (req, res) => {   const { To, From, CallStatus } = req.body;    const [numbers] = await getNumberWithoutUser(To);   if (!numbers) {     console.warn(`User does not own number: ${To}`);     return res.status(400).send("User does not own this number");   }    const activeSubscription = numbers.numbers.subscriptions.find(     (subscription) => subscription.active   );   if (!activeSubscription) {     console.warn(`No active subscription for number: ${To}`);     return res.send("Call Forwarding is disabled or package has finished");   }    const type = activeSubscription.type;   const isToPrimaryPhone = numbers?.numbers?.settings?.forwarding?.toPrimaryPhone;   const primaryPhoneNumber = numbers?.numbers?.settings?.forwarding?.primaryPhoneNumber;    console.log("CallStatus", CallStatus);    if (isToPrimaryPhone && primaryPhoneNumber) {     const twiml = new twilio.twiml.VoiceResponse();      switch (CallStatus) {       case "ringing":         // 尝试拨打用户主号码，设置15秒超时         // 如果在15秒内未接听，Twilio将继续执行TwiML响应中的下一个动词         twiml.dial({ timeout: 15 }, primaryPhoneNumber);          // 如果呼叫未接通（超时、占线、无人接听），则播放提示音并开始录音         twiml.say("您拨打的用户当前无法接听，请在哔声后留言，按星号键结束。");         twiml.record({           recordingStatusCallback: "https://your-ngrok-url/webhook/voicemail-callback", // 替换为您的Webhook URL           maxLength: 60, // 最长录音时间60秒           finishOnKey: '*' // 按星号键结束录音         });         twiml.say("感谢您的留言，再见。"); // 录音结束后播放         twiml.hangup(); // 结束通话          await updateQuota(numbers._id, To, "callForwarding", type);         res.type("text/xml");         return res.send(twiml.toString());        case "completed":         // 呼叫成功完成，记录通话信息         await appendCall(numbers._id, To, From, req.body);         return res.send("success");        // 可以根据需要处理其他CallStatus，例如 "no-answer", "busy", "failed"       // 但对于语音留言回退，主要逻辑已在 'ringing' 状态的TwiML中处理     }   } else {     console.log("Call Forwarding is disabled or primaryPhoneNumber is not set.");   }   res.send("Call Forwarding is disabled or package has finished"); });  // 导出router以供主应用使用 module.exports = router;

Napkin AI

Napkin AI 可以将您的文本转换为图表、流程图、信息图、思维导图视觉效果，以便快速有效地分享您的想法。

2238

查看详情

// ... (其他引入和router定义) ...  router.post("/webhook/voicemail-callback", async (req, res) => {   const { RecordingUrl, CallSid, From, To, RecordingDuration, TranscriptionText } = req.body;    console.log("Voicemail Callback Received:");   console.log(`Recording URL: ${RecordingUrl}`);   console.log(`Call SID: ${CallSid}`);   console.log(`From: ${From}, To: ${To}`);   console.log(`Duration: ${RecordingDuration} seconds`);   console.log(`Transcription: ${TranscriptionText || "Not available or not requested"}`);    try {     // 1. 获取掩码号码对应的用户信息     const [numbers] = await getNumberWithoutUser(To);     if (!numbers) {       console.error(`Voicemail: User does not own number: ${To}`);       return res.status(400).send("User does not own this number");     }      // 2. 将语音留言信息存储到数据库     // 假设您有一个 appendVoicemail 函数来处理此逻辑     await appendVoicemail(numbers._id, To, From, {       recordingUrl: RecordingUrl,       duration: RecordingDuration,       callSid: CallSid,       // 如果您在Record动词中启用了转录，TranscriptionText 会在这里       transcription: TranscriptionText || null,       timestamp: new Date(),     });      // 3. 将语音留言转录为文本（如果未在Record动词中启用）并发送邮件     // Twilio的Record动词可以直接进行转录，但如果需要更高级的转录或后续处理，可以在这里调用Twilio的Transcription API     let finalTranscription = TranscriptionText;     if (!finalTranscription && RecordingUrl) {       // 示例：手动调用Twilio API进行转录 (需要配置client)       // const transcription = await client.transcriptions.create({       //   recordingSid: RecordingUrl.split('/').pop().split('.')[0] // 从URL中提取Recording SID       // });       // finalTranscription = transcription.transcriptionText;       // console.log("Manual Transcription:", finalTranscription);     }      // 4. 将语音留言（或其转录文本）通过邮件发送给用户     const userEmail = numbers?.numbers?.settings?.emailForVoicemail || numbers?.user?.email; // 假设用户邮箱配置在这里     if (userEmail) {       await sendMessageNotificationEmail(         userEmail,         `您有一个来自 ${From} 的新语音留言`,         `您收到一个新语音留言。时长：${RecordingDuration}秒。nn` +         `语音链接：${RecordingUrl}.mp3nn` + // Twilio录音URL通常支持.mp3扩展         (finalTranscription ? `转录文本：n${finalTranscription}` : "无转录文本。")       );       console.log(`Voicemail sent to user email: ${userEmail}`);     } else {       console.warn(`No email configured for user associated with number: ${To}`);     }      res.status(200).send("Voicemail callback processed successfully");   } catch (error) {     console.error("Error processing voicemail callback:", error);     res.status(500).send("Error processing voicemail callback");   } });  // 辅助函数，需要您在 dbOperations.js 中实现 async function appendVoicemail(userId, maskedNumber, fromNumber, voicemailData) {   // 实际的数据库操作，将语音留言数据存储到您的DB中   console.log(`Storing voicemail for user ${userId} from ${fromNumber} on ${maskedNumber}:`, voicemailData);   // 示例: await db.collection('voicemails').insertOne({ userId, maskedNumber, fromNumber, ...voicemailData });   return Promise.resolve(); // 模拟成功 }  // ... (导出router) ...