实现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;

// ... (其他引入和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}秒。\n\n` +
        `语音链接：${RecordingUrl}.mp3\n\n` + // 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) ...