Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-02 12:05:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

closes #1630

Browse Source
This commit is contained in:
barisusakli
2014-06-03 12:30:36 -04:00
parent 0574022e02
commit e20920c536
3 changed files with 58 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/user/notifications.js
View File

@@ -9,6 +9,7 @@ var async = require('async'),
utils = require('../../public/src/utils'),
db = require('../database'),
notifications = require('../notifications'),
posts = require('../posts'),
topics = require('../topics');
(function(UserNotifications) {
@@ -146,22 +147,36 @@ var async = require('async'),
};
UserNotifications.sendPostNotificationToFollowers = function(uid, tid, pid) {
user.getUserField(uid, 'username', function(err, username) {
db.getSetMembers('followers:' + uid, function(err, followers) {
if (followers && followers.length) {
topics.getTopicField(tid, 'slug', function(err, slug) {
var message = '[[notifications:user_made_post, ' + username + ']]';
db.getSetMembers('followers:' + uid, function(err, followers) {
if (err || !followers || !followers.length) {
return;
}
notifications.create({
text: message,
path: nconf.get('relative_path') + '/topic/' + slug + '#' + pid,
uniqueId: 'topic:' + tid,
from: uid
}, function(nid) {
notifications.push(nid, followers);
});
});
async.parallel({
usename: function(next) {
user.getUserField(uid, 'username', next);
},
slug: function(next) {
topics.getTopicField(tid, 'slug', next);
},
postIndex: function(next) {
posts.getPidIndex(pid, next);
}
}, function(err, results) {
if (err) {
return;
}
var message = '[[notifications:user_made_post, ' + results.username + ']]';
notifications.create({
text: message,
path: nconf.get('relative_path') + '/topic/' + results.slug + '/' + results.postIndex,
uniqueId: 'topic:' + tid,
from: uid
}, function(nid) {
notifications.push(nid, followers);
});
});
});
};