为 Valine 评论系统加入 nodemailer 邮件提醒功能

function app(request) {
    // 引入nodemailer
    const nodemailer = require('nodemailer');
    // 创建smtp服务器对象
    const transporter = nodemailer.createTransport({
        host: 'smtp.qq.com', // 由邮件商提供
        port: 465, // SSL加密的smtp都用此端口
        secure: true, // SSL加密
        auth: {
            user: '123456789@qq.com', // 更换为你的邮箱地址
            pass: 'shouquanma', // 授权码
        },
    });
    // 创建邮件内容
    const mail = {
        from: '123456789@qq.com',
        to: '123456789@qq.com, other@qq.com',
        subject: '测试邮件',
        html: '<p>这是一封<strong>html</strong>格式的测试邮件</p>',
    };
    // 返回发送邮件的Promise
    return transporter.sendMail(mail);
}

app().then(
    () => {
        console.log('发送成功');
    },
    (err) => {
        console.log({ err });
    }
);

var sendEmail = function(request) {
    // 打印日志
    console.log("sendEmail is triggered.");
    // 引入nodemailer
    const nodemailer = require('nodemailer');
    // 创建smtp服务器对象
    const transporter = nodemailer.createTransport({
        host: 'smtp.qq.com', // 由邮件商提供
        port: 465, // SSL加密的smtp都用此端口
        secure: true, // SSL加密
        auth: {
            user: '123456789@qq.com', // 更换为你的邮箱地址
            pass: 'shouquanma', // 授权码
        },
    });
    // 获取新评论的rid和pid
    let commentObject = request.object;
    let rid = commentObject.get('rid'); // 发起者
    let pid = commentObject.get('pid'); // 被回复者
    // 生成邮件内容
    let receiver = '12345678@qq.com'; // 所有回复都发送给站长
    let subject = '您的评论有了新回复';
    let content = `<strong>评论内容：</strong>
            <br>${commentObject.get('comment')}<br>
            <a href="http://your.site${commentObject.get('url')}">
            点击查看</a>`;
    // 创建一个返回邮件内容的函数，receiver后面根据查询组装
    let email = function (receiver) {
        return {
            from: '"张三" <12345678@qq.com>', // 自动解析发件人名字和邮箱
            to: receiver,
            subject: subject,
            html: content,
        };
    };
    if (!(rid && pid)) {
        // 新评论项，只给站长发送
        // 返回发送邮件的Promise
        return transporter.sendMail(email(receiver));
    } else {
        // 回复评论，给站长和相关人同时发送
        let query1 = new AV.Query('Comment'); // 创建对Comment表的查询
        query1.get(rid).then(
            (cmt) => {
                // 通过rid查询，得到记录cmt
                let mail1 = cmt.get('mail'); // 得到记录中的mail项
                mail1 ? (receiver = mail1 + ', ' + receiver) : null; // 如果存在，加入收件人中。
                if (rid === pid) {
                    // 如果pid和rid相同，返回发送邮件的Promise
                    return transporter.sendMail(email(receiver));
                } else {
                    // 如果pid和rid不同，再找pid的记录
                    let query2 = new AV.Query('Comment');
                    query2.get(pid).then(
                        (cmt) => {
                            let mail2 = cmt.get('mail');
                            mail2 && mail2 != mail1
                                ? (receiver = mail2 + ', ' + receiver)
                                : null;
                            // 返回发送邮件的Promise
                            return transporter.sendMail(email(receiver));
                        },
                        (err) => {
                            console.log('bad pid');
                        }
                    );
                }
            },
            (err) => {
                console.log('bad rid');
            }
        );
    }
}

AV.Cloud.afterSave('Comment', async function(request) {
    ...
}

console.log('Cloud function wakeUp is triggered.');
return 'Hello!';