moved unread to new file

src/topics/unread.js

@@ -0,0 +1,216 @@
+
+'use strict';
+
+var async = require('async'),
+	winston = require('winston'),
+
+	db = require('./../database'),
+	user = require('./../user'),
+	notifications = require('./../notifications'),
+	categories = require('./../categories'),
+	threadTools = require('./../threadTools');
+
+module.exports = function(Topics) {
+
+	Topics.getTotalUnread = function(uid, callback) {
+		Topics.getUnreadTids(uid, 0, 20, function(err, tids) {
+			callback(err, tids ? tids.length : 0);
+		});
+	};
+
+	Topics.getUnreadTids = function(uid, start, stop, callback) {
+		var unreadTids = [],
+			done = false;
+
+		uid = parseInt(uid, 10);
+		if(uid === 0) {
+			return callback(null, unreadTids);
+		}
+
+		async.whilst(function() {
+			return unreadTids.length < 21 && !done;
+		}, function(callback) {
+			Topics.getLatestTids(start, stop, 'month', function(err, tids) {
+				if (err) {
+					return callback(err);
+				}
+
+				if (tids && !tids.length) {
+					done = true;
+					return callback();
+				}
+
+				Topics.hasReadTopics(tids, uid, function(err, read) {
+					if(err) {
+						return callback(err);
+					}
+					var newtids = tids.filter(function(tid, index, self) {
+						return parseInt(read[index], 10) === 0;
+					});
+
+					async.filter(newtids, function(tid, next) {
+						threadTools.privileges(tid, uid, function(err, privileges) {
+							next(!err && privileges.read);
+						});
+					}, function(newtids) {
+						unreadTids.push.apply(unreadTids, newtids);
+
+						start = stop + 1;
+						stop = start + 19;
+
+						callback();
+					});
+				});
+			});
+		}, function(err) {
+			callback(err, unreadTids);
+		});
+	};
+
+	Topics.getUnreadTopics = function(uid, start, stop, callback) {
+
+		var unreadTopics = {
+			no_topics_message: '',
+			show_markallread_button: 'hidden',
+			nextStart : 0,
+			topics: []
+		};
+
+		function sendUnreadTopics(topicIds) {
+
+			Topics.getTopicsByTids(topicIds, uid, function(err, topicData) {
+				if(err) {
+					return callback(err);
+				}
+
+				db.sortedSetRevRank('topics:recent', topicData[topicData.length - 1].tid, function(err, rank) {
+					if(err) {
+						return callback(err);
+					}
+
+					unreadTopics.topics = topicData;
+					unreadTopics.nextStart = parseInt(rank, 10) + 1;
+					unreadTopics.no_topics_message = (!topicData || topicData.length === 0) ? '' : 'hidden';
+					unreadTopics.show_markallread_button = topicData.length === 0 ? 'hidden' : '';
+
+					callback(null, unreadTopics);
+				});
+			});
+		}
+
+		Topics.getUnreadTids(uid, start, stop, function(err, unreadTids) {
+			if (err) {
+				return callback(err);
+			}
+
+			if (unreadTids.length) {
+				sendUnreadTopics(unreadTids);
+			} else {
+				callback(null, unreadTopics);
+			}
+		});
+	};
+
+	Topics.pushUnreadCount = function(uids, callback) {
+		var	websockets = require('./../socket.io');
+
+		if (!uids) {
+			uids = websockets.getConnectedClients();
+		} else if (!Array.isArray(uids)) {
+			uids = [uids];
+		}
+
+		uids = uids.filter(function(value) {
+			return parseInt(value, 10) !== 0;
+		});
+
+		async.each(uids, function(uid, next) {
+			Topics.getTotalUnread(uid, function(err, count) {
+				websockets.in('uid_' + uid).emit('event:unread.updateCount', null, count);
+				next();
+			});
+		}, function(err) {
+			if (err) {
+				winston.error(err.message);
+			}
+
+			if (callback) {
+				callback();
+			}
+		});
+	};
+
+	Topics.markAsUnreadForAll = function(tid, callback) {
+		db.delete('tid:' + tid + ':read_by_uid', function(err) {
+			if(err) {
+				return callback(err);
+			}
+			Topics.markCategoryUnreadForAll(tid, callback);
+		});
+	};
+
+	Topics.markAllRead = function(uid, tids, callback) {
+		if(!tids || !tids.length) {
+			return callback();
+		}
+
+		async.each(tids, function (tid, next) {
+			Topics.markAsRead(tid, uid, next);
+		}, callback);
+	};
+
+	Topics.markAsRead = function(tid, uid, callback) {
+
+		db.setAdd('tid:' + tid + ':read_by_uid', uid, function(err) {
+			if(callback) {
+				callback(err);
+			}
+		});
+
+		Topics.getTopicField(tid, 'cid', function(err, cid) {
+			categories.markAsRead(cid, uid);
+		});
+
+		user.notifications.getUnreadByUniqueId(uid, 'topic:' + tid, function(err, nids) {
+			notifications.mark_read_multiple(nids, uid, function() {
+				user.notifications.pushCount(uid);
+			});
+		});
+	};
+
+	Topics.markCategoryUnreadForAll = function(tid, callback) {
+		Topics.getTopicField(tid, 'cid', function(err, cid) {
+			if(err) {
+				return callback(err);
+			}
+
+			categories.markAsUnreadForAll(cid, callback);
+		});
+	};
+
+	Topics.hasReadTopics = function(tids, uid, callback) {
+		if(!parseInt(uid, 10)) {
+			return callback(null, tids.map(function() {
+				return false;
+			}));
+		}
+
+		var sets = [];
+
+		for (var i = 0, ii = tids.length; i < ii; i++) {
+			sets.push('tid:' + tids[i] + ':read_by_uid');
+		}
+
+		db.isMemberOfSets(sets, uid, callback);
+	};
+
+	Topics.hasReadTopic = function(tid, uid, callback) {
+		if(!parseInt(uid, 10)) {
+			return callback(null, false);
+		}
+
+		db.isSetMember('tid:' + tid + ':read_by_uid', uid, callback);
+	};
+
+
+};