You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
nodebb/src/user/jobs.js

105 lines
2.9 KiB
JavaScript

'use strict';
var db = require('../database'),
async = require('async'),
winston = require('winston'),
cronJob = require('cron').CronJob,
nconf = require('nconf'),
user = require('../user'),
topics = require('../topics'),
emailer = require('../emailer'),
meta = require('../meta'),
batch = require('../batch');
module.exports = function(User) {
User.startJobs = function() {
winston.verbose('[user.startJobs] Registering User Jobs');
new cronJob('0 0 17 * * *', function() {
User.sendDailyDigests();
}, null, true);
};
User.sendDailyDigests = function() {
11 years ago
var digestsDisabled = meta.config.disableEmailSubscriptions !== undefined && parseInt(meta.config.disableEmailSubscriptions, 10) === 1;
if (digestsDisabled) {
return winston.verbose('[user/jobs] Did not send daily digests because subscription system is disabled.');
11 years ago
}
topics.getLatestTopics(0, 0, 9, 'day', function(err, data) {
11 years ago
if (err) {
return winston.error('[user/jobs] Could not send daily digests: ' + err.message);
}
batch.processSortedSet('users:joindate', function(uids, next) {
User.getMultipleUserSettings(uids, function(err, userSettings) {
if (err) {
return next(err);
}
11 years ago
var subscribed = userSettings.filter(function(setting) {
return setting.dailyDigestFreq === 'daily';
}).map(function(setting) {
return setting.uid;
});
if (!subscribed.length) {
return next();
}
11 years ago
11 years ago
sendEmails(subscribed, data.topics, next);
});
}, function(err) {
if (err) {
winston.error('[user/jobs] Could not send daily digests: ' + err.message);
} else {
winston.verbose('[user/jobs] Daily Digests sent!');
}
11 years ago
});
});
};
11 years ago
function sendEmails(uids, recentTopics, callback) {
11 years ago
var now = new Date();
11 years ago
User.getMultipleUserFields(uids, ['uid', 'username', 'lastonline'], function(err, users) {
if (err) {
winston.error('[user/jobs] Could not send daily digests: ' + err.message);
return callback(err);
11 years ago
}
11 years ago
async.eachLimit(users, 100, function(userObj, next) {
user.notifications.getDailyUnread(userObj.uid, function(err, notifications) {
if (err) {
winston.error('[user/jobs] Could not send daily digests: ' + err.message);
11 years ago
return next(err);
}
notifications = notifications.filter(Boolean);
11 years ago
for(var i=0; i<notifications.length; ++i) {
if (notifications[i].image.indexOf('http') !== 0) {
notifications[i].image = nconf.get('url') + notifications[i].image;
}
}
11 years ago
emailer.send('dailydigest', userObj.uid, {
subject: '[' + meta.config.title + '] Daily Digest for ' + now.getFullYear()+ '/' + (now.getMonth()+1) + '/' + now.getDate(),
username: userObj.username,
url: nconf.get('url'),
site_title: meta.config.title || meta.config.browserTitle || 'NodeBB',
notifications: notifications,
recent: recentTopics
});
next();
});
}, callback);
});
11 years ago
}
};