socketio/posts socketio/topics refactor

src/socket.io/topics/unread.js

@@ -0,0 +1,112 @@
+'use strict';
+
+var async = require('async'),
+
+	db = require('../../database'),
+	user = require('../../user'),
+	topics = require('../../topics'),
+	utils = require('../../../public/src/utils');
+
+module.exports = function(SocketTopics) {
+
+	SocketTopics.markAsRead = function(socket, tids, callback) {
+		if (!Array.isArray(tids) || !socket.uid) {
+			return callback(new Error('[[error:invalid-data]]'));
+		}
+
+		if (!tids.length) {
+			return callback();
+		}
+		tids = tids.filter(function(tid) {
+			return tid && utils.isNumber(tid);
+		});
+
+		topics.markAsRead(tids, socket.uid, function(err) {
+			if (err) {
+				return callback(err);
+			}
+
+			topics.pushUnreadCount(socket.uid);
+
+			for (var i=0; i<tids.length; ++i) {
+				topics.markTopicNotificationsRead(tids[i], socket.uid);
+			}
+			callback();
+		});
+	};
+
+	SocketTopics.markTopicNotificationsRead = function(socket, tid, callback) {
+		if (!tid || !socket.uid) {
+			return callback(new Error('[[error:invalid-data]]'));
+		}
+		topics.markTopicNotificationsRead(tid, socket.uid);
+	};
+
+	SocketTopics.markAllRead = function(socket, data, callback) {
+		db.getSortedSetRevRangeByScore('topics:recent', 0, -1, '+inf', Date.now() - topics.unreadCutoff, function(err, tids) {
+			if (err) {
+				return callback(err);
+			}
+
+			SocketTopics.markAsRead(socket, tids, callback);
+		});
+	};
+
+	SocketTopics.markCategoryTopicsRead = function(socket, cid, callback) {
+		topics.getUnreadTids(cid, socket.uid, 0, -1, function(err, tids) {
+			if (err) {
+				return callback(err);
+			}
+
+			SocketTopics.markAsRead(socket, tids, callback);
+		});
+	};
+
+	SocketTopics.markAsUnreadForAll = function(socket, tids, callback) {
+		if (!Array.isArray(tids)) {
+			return callback(new Error('[[error:invalid-tid]]'));
+		}
+
+		if (!socket.uid) {
+			return callback(new Error('[[error:no-privileges]]'));
+		}
+
+		user.isAdministrator(socket.uid, function(err, isAdmin) {
+			if (err) {
+				return callback(err);
+			}
+
+			async.each(tids, function(tid, next) {
+				async.waterfall([
+					function(next) {
+						topics.exists(tid, next);
+					},
+					function(exists, next) {
+						if (!exists) {
+							return next(new Error('[[error:invalid-tid]]'));
+						}
+						topics.getTopicField(tid, 'cid', next);
+					},
+					function(cid, next) {
+						user.isModerator(socket.uid, cid, next);
+					},
+					function(isMod, next) {
+						if (!isAdmin && !isMod) {
+							return next(new Error('[[error:no-privileges]]'));
+						}
+						topics.markAsUnreadForAll(tid, next);
+					},
+					function(next) {
+						topics.updateRecent(tid, Date.now(), next);
+					}
+				], next);
+			}, function(err) {
+				if (err) {
+					return callback(err);
+				}
+				topics.pushUnreadCount(socket.uid);
+				callback();
+			});
+		});
+	};
+};