【玩转Lighthouse】 nodejs抓取邮箱收件信息

var Imap = require('imap')
var http = require('http')
var querystring = require('querystring')//可以结合http模块改造成一个API使用更高效
var MailParser = require("mailparser").MailParser
var fs = require("fs")

var imap = new Imap({
    user: 'abcdefg@outlook.com', //你的邮箱账号
    password: 'tencentpointcom', //你的邮箱密码
    host: 'outlook.office365.com', //邮箱服务器的主机地址
    port: 993, //邮箱服务器的端口地址
    tls: true, //使用安全传输协议
    tlsOptions: { rejectUnauthorized: false } //禁用对证书有效性的检查
});

function openInbox(cb) {
    imap.openBox('INBOX', true, cb);
}

imap.once('ready', function () {
    openInbox(function (err, box) {
        // console.log("打开邮箱")
        if (err) throw err;
        imap.search(['UNSEEN', ['SINCE', 'Jun 1, 2021']], function (err, results) {//搜寻2021 6 1后未读
            if (err) throw err;
            var f = imap.fetch(results, { bodies: '' });//抓取邮件（默认情况下邮件服务器的邮件是未读状态）
            f.on('message', function (msg, seqno) {
                var mailparser = new MailParser();
                msg.on('body', function (stream, info) {
                    stream.pipe(mailparser);//将为解析的数据流pipe到mailparser
                    //邮件头内容
                    // mailparser.on("headers", function (headers) {
                    //     console.log("邮件头信息>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
                    //     console.log("邮件主题: " + headers.get('subject'));
                    //     console.log("发件人: " + headers.get('from').text);
                    //     console.log("收件人: " + headers.get('to').text);
                    // });
                    mailparser.on("data", function (data) {
                        //xxxxxxx注册邮箱验证码获取，注意subject和下面正则表达式自行替换
                        if (data.type === 'text' && this.headers.get('subject') === '注册邮箱验证') {
                            var regex = /<span style=.+>(\d{6})<\/span>/g;
                            var contents = JSON.stringify(data.html);
                            var matches = regex.exec(contents);
                            if (matches) {
                                console.log("code：" + matches[1]);
                            }
                        }

                        //xxxxxxxx注册邮箱验证码英文，也是注意自行替换
                        if (data.type === 'text' && this.headers.get('subject') === (' Email Verification')) {
                            var regex = /<span style=.+>(\d{6})<\/span>/g;
                            var contents = JSON.stringify(data.html);
                            var matches = regex.exec(contents);
                            if (matches) {
                                console.log("code：" + matches[1]);
                            }
                        }

                        // if (data.type === 'attachment') {//附件
                        //     console.log("邮件附件信息>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
                        //     console.log("附件名称:" + data.filename);//打印附件的名称
                        //     data.content.pipe(fs.createWriteStream(data.filename));//保存附件到当前目录下
                        //     data.release();
                        // }
                    });
                });

                // // 邮件索引
                // msg.once('end', function () {
                //     console.log(seqno + '完成');
                // });
            });

            f.once('error', function (err) {
                console.log('抓取出现错误: ' + err);
            });

            f.once('end', function () {
                // console.log('所有邮件抓取完成!');
                imap.end();
            });
        });
    });
});

imap.once('error', function (err) {
    console.log(err);
});

imap.once('end', function () {
    // console.log('关闭邮箱');
});
imap.connect();