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 #2053

Browse Source
This commit is contained in:
barisusakli
2014-09-15 16:26:25 -04:00
parent da86c46b4c
commit 9a96458f79
5 changed files with 89 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/messaging.js
View File

@@ -222,26 +222,39 @@ var db = require('./database'),
return callback(err);
}
db.isSortedSetMembers('uid:' + uid + ':chats:unread', uids, function(err, unreadUids) {
async.parallel({
unread: function(next) {
db.isSortedSetMembers('uid:' + uid + ':chats:unread', uids, next);
},
users: function(next) {
user.getMultipleUserFields(uids, ['uid', 'username', 'picture', 'status'] , next);
}
}, function(err, results) {
if (err) {
return callback(err);
}
user.getMultipleUserFields(uids, ['uid', 'username', 'picture', 'status'] , function(err, users) {
results.users = results.users.filter(function(user) {
return user && parseInt(user.uid, 10);
});
if (!results.users.length) {
return callback(null, {users: [], nextStart: end + 1});
}
results.users.forEach(function(user, index) {
if (user) {
user.unread = results.unread[index];
user.status = websockets.isUserOnline(user.uid) ? user.status : 'offline';
}
});
db.sortedSetRevRank('uid:' + uid + ':chats', results.users[results.users.length - 1].uid, function(err, rank) {
if (err) {
return callback(err);
}
users = users.filter(function(user) {
return user && parseInt(user.uid, 10);
});
users.forEach(function(user, index) {
if (user) {
user.unread = unreadUids[index];
user.status = websockets.isUserOnline(user.uid) ? user.status : 'offline';
}
});
callback(null, users);
callback(null, {users: results.users, nextStart: rank + 1});
});
});
});