利用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 { appendCall } = require("../db/callsCollectionUtils");

router.post("/webhook/voice", async (req, res) => {
  const { To, From, CallStatus } = req.body;

  // 假设getNumberWithoutUser函数能够根据掩码号码获取相关用户及设置
  const [numbers] = await getNumberWithoutUser(To);
  if (!numbers) {
    return res.status(400).send("User does not own this number");
  }

  const type = numbers.numbers.subscriptions.find(
    (subscription) => subscription.active
  ).type;
  const isToPrimaryPhone =
    numbers?.numbers?.settings?.forwarding?.toPrimaryPhone;
  const primaryPhoneNumber =
    numbers?.numbers?.settings?.forwarding?.primaryPhoneNumber;

  if (isToPrimaryPhone) {
    const twiml = new twilio.twiml.VoiceResponse();
    switch (CallStatus) {
      case "ringing":
        // 尝试拨打用户主号码，设置超时和未接通后的回调URL
        // 注意：action URL 必须是 Twilio 可访问的公共 URL (例如您的 ngrok 或生产环境域名)
        twiml.dial({
          timeout: 15, // 设置拨打超时时间，例如15秒
          action: `https://your-domain.com/webhook/voicemail?To=${To}&From=${From}`, // 超时或未接通后，Twilio会请求此URL
          method: 'POST'
        }, primaryPhoneNumber);

        // 更新呼叫转接配额
        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，但 'action' URL 会处理 'no-answer', 'busy' 等情况
    }
  }
  // 如果呼叫转接未启用或套餐已过期
  res.send("Call Forwarding is disabled or package has finished");
});

// ... (之前的导入和设置) ...

router.post("/webhook/voicemail", async (req, res) => {
  // 从查询参数中获取掩码号码 (To) 和客户号码 (From)
  const { To, From } = req.query;
  const twiml = new twilio.twiml.VoiceResponse();

  // 播放提示音，引导客户留言
  twiml.say({ voice: 'alice', language: 'zh-CN' }, "您拨打的用户暂时无法接听，请在'嘟'声后留言。留言结束后请按星号键。");
  twiml.record({
    recordingStatusCallback: `https://your-domain.com/webhook/recording-callback?To=${To}&From=${From}`, // 留言完成后，Twilio会请求此URL
    recordingStatusCallbackMethod: 'POST',
    maxLength: 60, // 最长录音60秒
    finishOnKey: '*' // 客户可以按星号键提前结束录音
  });
  twiml.say({ voice: 'alice', language: 'zh-CN' }, "感谢您的留言，再见。"); // 留言结束后播放感谢语

  res.type("text/xml");
  res.send(twiml.toString());
});

// ... (之前的导入和设置) ...
// const { getNumberWithoutUser, sendMessageNotificationEmail } = require("../db/dbOperations");
// const { appendMessage } = require("../db/messagingCollectionUtils"); // 用于存储留言信息
// const { client } = require("../twilioFunctions"); // 如果需要调用Twilio REST API进行转录

router.post("/webhook/recording-callback", async (req, res) => {
  const { To, From } = req.query; // 掩码号码 (To) 和客户号码 (From)
  const { RecordingUrl, RecordingDuration, CallSid, TranscriptionText, TranscriptionSid } = req.body; // Twilio发送的录音详情

  // 假设getNumberWithoutUser函数能够根据掩码号码获取相关用户
  const [numbers] = await getNumberWithoutUser(To);
  if (!numbers) {
    console.error(`User for masked number ${To} not found.`);
    return res.status(404).send("User not found");
  }

  try {
    // 1. 存储录音信息到数据库
    // 您可以将 RecordingUrl、RecordingDuration、From、To 等信息存储到数据库中
    await appendMessage(numbers._id, To, From, {
      type: 'voicemail',