问节点cron作业缓存后每2秒发送一次电子邮件

EN

'use strict';

const snoostorm = require('snoostorm');
const snoowrap = require('snoowrap');
const nodemailer = require('nodemailer');

// NOTE: The following examples illustrate how to use snoowrap. However, hardcoding
// credentials directly into your source code is generally a bad idea in practice (especially
// if you're also making your source code public). Instead, it's better to either (a) use a separate
// config file that isn't committed into version control, or (b) use environment variables.

// Alternatively, just pass in a username and password for script-type apps.
const r = new snoowrap({
    userAgent: 'NodeJS',
    clientId: '******',
    clientSecret: '*****',
    username: '******',
    password: '******'
});

var latestCache;

var client = new snoostorm(new snoowrap(r));


var transporter = nodemailer.createTransport('smtps://******@gmail.com:******@smtp.gmail.com');


var submissionStream = client.SubmissionStream({
    "subreddit": "AskReddit",
    "results": 1
});

submissionStream.on("submission", function(post) {
    if(post.title != latestCache.title){
        latestCache = post;

            var mailOptions = {
                from: '"Test message" <test@test.com>', // sender address
                to: '******@gmail.com', // list of receivers
                subject: 'Reddit post', // Subject line
                html: '' +
                '<table width="600" align="center" cellpadding="0" cellspacing="0">' +
                '<tr><td colspan="2"><h1>New Reddit AskReddit post from ' + post.author.name + '</h1></td></tr>' +
                '<tr><td><strong>Post Link</strong></td><td> <a href="' + post.url + '">Post Link</a></td></tr>' +
                '<tr><td>&nbsp;</td><td> <a href="http://www.reddit.com/message/compose?to=' + post.author.name + '&subject=Response+to+loan+request">Reply to loan request</a></td></tr>' +
                '</table>'
            };

            // send mail with defined transport object
            transporter.sendMail(mailOptions, function (error, info) {
                if (error) {
                    return console.log(error);
                }
                console.log('Message sent: ' + info.response);
            });
    }
});