|
|
|
|
@ -8,7 +8,6 @@ var db = require('../database'),
|
|
|
|
|
nconf = require('nconf'),
|
|
|
|
|
|
|
|
|
|
user = require('../user'),
|
|
|
|
|
UserNotifications = require('./notifications'),
|
|
|
|
|
topics = require('../topics'),
|
|
|
|
|
emailer = require('../emailer'),
|
|
|
|
|
meta = require('../meta');
|
|
|
|
|
@ -23,6 +22,8 @@ module.exports = function(User) {
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
User.sendDailyDigests = function() {
|
|
|
|
|
var yesterday = Date.now() - (1000*60*60*24);
|
|
|
|
|
|
|
|
|
|
async.parallel({
|
|
|
|
|
recent: function(next) {
|
|
|
|
|
topics.getLatestTopics(0, 0, 10, 'day', next);
|
|
|
|
|
@ -33,29 +34,50 @@ module.exports = function(User) {
|
|
|
|
|
}, function(err, data) {
|
|
|
|
|
var now = new Date();
|
|
|
|
|
|
|
|
|
|
async.each(data.uids, function(uid, next) {
|
|
|
|
|
UserNotifications.getDailyUnread(uid, function(err, notifications) {
|
|
|
|
|
if (!err && notifications && notifications.length) {
|
|
|
|
|
async.parallel({
|
|
|
|
|
recipients: function(next) {
|
|
|
|
|
User.getMultipleUserFields(data.uids, ['uid', 'username', 'lastonline'], next);
|
|
|
|
|
},
|
|
|
|
|
userSettings: function(next) {
|
|
|
|
|
User.getMultipleUserSettings(data.uids, next);
|
|
|
|
|
}
|
|
|
|
|
}, function(err, users) {
|
|
|
|
|
var recipients = users.recipients,
|
|
|
|
|
userSettings = users.userSettings,
|
|
|
|
|
subscribed;
|
|
|
|
|
|
|
|
|
|
// Find uids subscribed to daily digest emails
|
|
|
|
|
subscribed = userSettings.filter(function(setting) {
|
|
|
|
|
return !setting.dailyDigestFreq || setting.dailyDigestFreq === 'daily';
|
|
|
|
|
}).map(function(setting) {
|
|
|
|
|
return setting.uid;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
// Find only those users who have not been online in the past 24 hours
|
|
|
|
|
var users = recipients.filter(function(userObj) {
|
|
|
|
|
return subscribed.indexOf(userObj.uid) !== -1 && yesterday > parseInt(userObj.lastonline, 10);
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
// Consider using eachLimit, but *only* if people complain about email relays choking -- otherwise we're ok.
|
|
|
|
|
async.each(users, function(userObj, next) {
|
|
|
|
|
user.notifications.getDailyUnread(userObj.uid, function(err, notifications) {
|
|
|
|
|
// Turn relative URLs into absolute ones
|
|
|
|
|
for(var i=0; i<notifications.length; ++i) {
|
|
|
|
|
if (notifications[i].image.indexOf('http') !== 0) {
|
|
|
|
|
notifications[i].image = nconf.get('url') + notifications[i].image;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
user.getUserField(uid, 'username', function(err, username) {
|
|
|
|
|
// Send daily digest email
|
|
|
|
|
// winston.info('[user/notifications] Sending Daily Digest to uid ' + uid);
|
|
|
|
|
emailer.send('dailydigest', uid, {
|
|
|
|
|
// winston.info('[user/notifications] Sending Daily Digest to uid ' + userObj.uid);
|
|
|
|
|
emailer.send('dailydigest', userObj.uid, {
|
|
|
|
|
subject: '[' + meta.config.title + '] Daily Digest for ' + now.getFullYear()+ '/' + (now.getMonth()+1) + '/' + now.getDate(),
|
|
|
|
|
username: username,
|
|
|
|
|
username: userObj.username,
|
|
|
|
|
url: nconf.get('url'),
|
|
|
|
|
site_title: meta.config.title,
|
|
|
|
|
notifications: notifications,
|
|
|
|
|
recent: data.recent.topics
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
next(err);
|
|
|
|
|
});
|
|
|
|
|
@ -68,6 +90,7 @@ module.exports = function(User) {
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
psychobunny
11 years ago