Firebase Cloud Functions集成Nodemailer发邮件问题求助

一、邮件发送失败的核心代码问题 #

你的代码存在异步处理错误：sendMail是异步操作，但函数直接返回了SUCCESS_CODE，此时Cloud Functions会立即终止执行，根本没等到邮件发送任务完成。另外代码中未定义htmlBody变量，也会导致潜在报错。

修复后的完整代码 #

const functions = require('firebase-functions');
const admin=require('firebase-admin');
const nodemailer = require('nodemailer');
admin.initializeApp();
require('dotenv').config()

const {SENDER_EMAIL, SENDER_PASSWORD} = process.env;

exports.sendEmail = functions.database.ref('Contestants/{contestantID}').onCreate(async (snap, context) =>{
    let contestant = snap.val();
    
    // 定义HTML邮件内容，替换为你实际需要的内容
    const htmlBody = `<h1>订阅成功通知</h1><p>感谢您参与订阅，您的订阅编号是${contestant.uid}</p>`;

    let transporter = nodemailer.createTransport({
        host:'smtp.gmail.com',
        port:465,
        secure:true,
        auth:{
            user:SENDER_EMAIL,
            pass:SENDER_PASSWORD
        }
    });

    try {
        await transporter.sendMail({
            from: SENDER_EMAIL,
            to: contestant.email,
            subject:`Subscription nº ${contestant.uid} - Concluded!`,
            text:`This is a test.`,
            html: htmlBody
        });
        console.log('邮件发送成功');
        // 可选：在数据库中标记邮件发送状态，方便前端追踪
        await snap.ref.update({emailSent: true});
        return null;
    } catch (err) {
        console.error('邮件发送失败:', err);
        await snap.ref.update({emailSent: false, errorMsg: err.message});
        throw err; // 抛出错误让Cloud Functions标记执行失败
    }
});

关键修复点 #

• 使用async/await处理异步操作（比then/catch更直观，适合JS新手）
• 删除无用的SUCCESS_CODE变量，Cloud Functions通过Promise状态判断执行结果
• 补全未定义的htmlBody变量
• 添加日志和数据库状态更新，方便后续排查问题

二、Gmail配置问题 #

即使开启了“允许不安全应用”，Google Workspace（原G Suite）账户若开启了两步验证，必须使用应用专用密码（App Password）替代原账户密码：

1. 登录Google Workspace账户，确保已开启两步验证
2. 生成应用专用密码，替换代码中的SENDER_PASSWORD
3. 确认SMTP配置参数：host:'smtp.gmail.com'、port:465、secure:true是正确的

三、向网站传递执行结果的方案 #

由于你的函数是数据库触发型，无法直接向前端返回数据，可通过以下两种方式实现：

方案1：实时数据库状态监听 #

前端写入Contestants数据后，监听该节点的emailSent字段变化：

// 前端示例代码
const db = firebase.database();
// 假设你刚完成订阅数据写入，获取节点key
const contestantKey = await db.ref('Contestants').push(contestantData).key;

// 监听邮件发送状态
db.ref(`Contestants/${contestantKey}`).on('value', (snapshot) => {
    const data = snapshot.val();
    if (data.emailSent !== undefined) {
        if (data.emailSent) {
            window.location.href = '/success-page'; // 跳转成功页面
        } else {
            alert('邮件发送失败，请稍后重试');
        }
        // 取消监听避免重复触发
        db.ref(`Contestants/${contestantKey}`).off('value');
    }
});

方案2：改用Callable函数（更直接） #

如果不需要数据库自动触发，可改用Callable函数，前端主动调用并直接获取执行结果：

// Cloud Functions代码
exports.sendEmail = functions.https.onCall(async (data, context) => {
    const {contestant} = data;
    const htmlBody = `<h1>订阅成功通知</h1><p>您的订阅编号是${contestant.uid}</p>`;
    let transporter = nodemailer.createTransport({
        host:'smtp.gmail.com',
        port:465,
        secure:true,
        auth:{
            user:SENDER_EMAIL,
            pass:SENDER_PASSWORD
        }
    });

    try {
        await transporter.sendMail({
            from: SENDER_EMAIL,
            to: contestant.email,
            subject:`Subscription nº ${contestant.uid} - Concluded!`,
            text:`This is a test.`,
            html: htmlBody
        });
        return {success: true, message: '邮件发送成功'};
    } catch (err) {
        return {success: false, message: err.message};
    }
});

// 前端调用代码
const sendEmail = firebase.functions().httpsCallable('sendEmail');
sendEmail({contestant: contestantData})
  .then((result) => {
      if (result.data.success) {
          window.location.href = '/success-page';
      } else {
          alert(result.data.message);
      }
  })
  .catch((error) => {
      alert('请求失败：' + error.message);
  });

内容的提问来源于stack exchange，提问作者ReDevil