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

defactored getUnreadTopics into separate getUnreadTids method -- for no reason, mind you

Browse Source
This commit is contained in:
Julian Lam
2013-12-05 12:20:56 -05:00
parent fe4aee177d
commit 43b012b32e
1 changed files with 61 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

115
src/topics.js
View File

@@ -304,8 +304,52 @@ var async = require('async'),
);
};
Topics.getUnreadTopics = function(uid, start, stop, callback) {
Topics.getUnreadTids = function(uid, start, stop, callback) {
var unreadTids = [],
done = false;
function continueCondition() {
return unreadTids.length < 20 && !done;
}
async.whilst(continueCondition, function(callback) {
RDB.zrevrange('topics:recent', start, stop, function(err, tids) {
if (err) {
return callback(err);
}
if (tids && !tids.length) {
done = true;
return callback(null);
}
if (uid === 0) {
unreadTids.push.apply(unreadTids, tids);
callback(null);
} else {
Topics.hasReadTopics(tids, uid, function(read) {
var newtids = tids.filter(function(tid, index, self) {
return parseInt(read[index], 10) === 0;
});
unreadTids.push.apply(unreadTids, newtids);
if(continueCondition()) {
start = stop + 1;
stop = start + 19;
}
callback(null);
});
}
});
}, function(err) {
callback(err, unreadTids);
});
};
Topics.getUnreadTopics = function(uid, start, stop, callback) {
var unreadTopics = {
'category_name': 'Unread',
'show_sidebar': 'hidden',
@@ -326,66 +370,29 @@ var async = require('async'),
Topics.getTopicsByTids(topicIds, uid, function(topicData) {
unreadTopics.topics = topicData;
unreadTopics.nextStart = start + topicIds.length;
if (!topicData || topicData.length === 0)
if (!topicData || topicData.length === 0) {
unreadTopics.no_topics_message = 'show';
if (uid === 0 || topicData.length === 0)
}
if (uid === 0 || topicData.length === 0) {
unreadTopics.show_markallread_button = 'hidden';
}
callback(unreadTopics);
});
}
var unreadTids = [],
done = false;
function continueCondition() {
return unreadTids.length < 20 && !done;
}
async.whilst(
continueCondition,
function(callback) {
RDB.zrevrange('topics:recent', start, stop, function(err, tids) {
if (err)
return callback(err);
if (tids && !tids.length) {
done = true;
return callback(null);
}
if (uid === 0) {
unreadTids.push.apply(unreadTids, tids);
callback(null);
} else {
Topics.hasReadTopics(tids, uid, function(read) {
var newtids = tids.filter(function(tid, index, self) {
return parseInt(read[index], 10) === 0;
});
unreadTids.push.apply(unreadTids, newtids);
if(continueCondition()) {
start = stop + 1;
stop = start + 19;
}
callback(null);
});
}
});
},
function(err) {
if (err)
return callback([]);
if (unreadTids.length)
sendUnreadTopics(unreadTids);
else
noUnreadTopics();
Topics.getUnreadTids(uid, start, stop, function(err, unreadTids) {
if (err) {
return callback([]);
}
);
}
if (unreadTids.length) {
sendUnreadTopics(unreadTids);
} else {
noUnreadTopics();
}
});
};
Topics.getTopicsByTids = function(tids, current_user, callback, category_id) {