Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-27 17:16:14 +01:00
Code Issues Packages Projects Releases Wiki Activity

closes #1353

Browse Source 
mark all read will mark everything read, can also select topics and mark
them read, can mark specific categories read too
This commit is contained in:
barisusakli
2014-04-07 17:09:55 -04:00
parent e383524334
commit e5cf44d398
4 changed files with 144 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/socket.io/topics.js
View File

@@ -97,18 +97,18 @@ SocketTopics.markAsRead = function(socket, data) {
});
};
SocketTopics.markAllRead = function(socket, tids, callback) {
SocketTopics.markTidsRead = function(socket, tids, callback) {
if (!Array.isArray(tids)) {
return callback(new Error('invalid-data'));
}
topics.markAllRead(socket.uid, tids, function(err) {
topics.markTidsRead(socket.uid, tids, function(err) {
if(err) {
return callback(err);
}
index.server.sockets.in('uid_' + socket.uid).emit('event:unread.updateCount', null, 0);
topics.pushUnreadCount(socket.uid);
for (var i=0; i<tids.length; ++i) {
topics.markTopicNotificationsRead(tids[i], socket.uid);
@@ -118,6 +118,43 @@ SocketTopics.markAllRead = function(socket, tids, callback) {
});
};
SocketTopics.markAllRead = function(socket, data, callback) {
topics.getUnreadTids(socket.uid, 0, -1, function(err, tids) {
if (err) {
return callback(err);
}
SocketTopics.markTidsRead(socket, tids, callback);
});
};
SocketTopics.markCategoryTopicsRead = function(socket, cid, callback) {
topics.getUnreadTids(socket.uid, 0, -1, function(err, tids) {
if (err) {
return callback(err);
}
var keys = tids.map(function(tid) {
return 'topic:' + tid;
});
db.getObjectsFields(keys, ['tid', 'cid'], function(err, topicData) {
if (err) {
return callback(err);
}
tids = topicData.filter(function(topic) {
return parseInt(topic.cid, 10) === parseInt(cid, 10);
}).map(function(topic) {
return topic.tid;
});
SocketTopics.markTidsRead(socket, tids, callback);
});
});
};
SocketTopics.markAsUnreadForAll = function(socket, tid, callback) {
topics.markAsUnreadForAll(tid, function(err) {
if(err) {