send new post/topic to users who can read it

src/socket.io/posts.js

@@ -27,34 +27,38 @@ SocketPosts.reply = function(socket, data, callback) {
 	data.req = websockets.reqFromSocket(socket);
 
 	topics.reply(data, function(err, postData) {
-		if(err) {
+		if (err) {
 			return callback(err);
 		}
 
-		if (postData) {
-			var privileges = {
+		var result = {
+			posts: [postData],
+			privileges: {
 				'topics:reply': true
-			};
+			},
+			'reputation:disabled': parseInt(meta.config['reputation:disabled'], 10) === 1,
+			'downvote:disabled': parseInt(meta.config['downvote:disabled'], 10) === 1,
+		};
 
-			callback();
+		callback();
 
-			socket.emit('event:new_post', {
-				posts: [postData],
-				privileges: privileges,
-				'reputation:disabled': parseInt(meta.config['reputation:disabled'], 10) === 1,
-				'downvote:disabled': parseInt(meta.config['downvote:disabled'], 10) === 1,
-			});
+		socket.emit('event:new_post', result);
 
-			socket.broadcast.emit('event:new_post', {
-				posts: [postData],
-				privileges: privileges,
-				'reputation:disabled': parseInt(meta.config['reputation:disabled'], 10) === 1,
-				'downvote:disabled': parseInt(meta.config['downvote:disabled'], 10) === 1,
-			});
+		var uids = websockets.getConnectedClients();
 
-			websockets.emitTopicPostStats();
-			topics.pushUnreadCount();
-		}
+		privileges.categories.filterUids('read', postData.topic.cid, uids, function(err, uids) {
+			if (err) {
+				return;
+			}
+			for(var i=0; i<uids.length; ++i) {
+				if (uids[i] !== socket.uid) {
+					websockets.in('uid_' + uids[i]).emit('event:new_post', result);
+				}
+			}
+		});
+
+		websockets.emitTopicPostStats();
+		topics.pushUnreadCount();
 	});
 };
 

src/socket.io/topics.js

@@ -19,7 +19,6 @@ var nconf = require('nconf'),
 	SocketTopics = {};
 
 SocketTopics.post = function(socket, data, callback) {
-
 	if(!data) {
 		return callback(new Error('[[error:invalid-data]]'));
 	}
@@ -33,27 +32,30 @@ SocketTopics.post = function(socket, data, callback) {
 		tags: data.tags,
 		req: websockets.reqFromSocket(socket)
 	}, function(err, result) {
-		if(err) {
+		if (err) {
 			return callback(err);
 		}
 
-		if (result) {
+		callback(null, result.topicData);
+		socket.emit('event:new_post', {posts: result.postData});
+		socket.emit('event:new_topic', result.topicData);
 
-			websockets.server.sockets.in('category_' + data.category_id).emit('event:new_topic', result.topicData);
-			websockets.server.sockets.in('recent_posts').emit('event:new_topic', result.topicData);
-			websockets.server.sockets.in('home').emit('event:new_topic', result.topicData);
-			websockets.server.sockets.in('home').emit('event:new_post', {
-				posts: result.postData
-			});
-			websockets.server.sockets.in('user/' + socket.uid).emit('event:new_post', {
-				posts: result.postData
-			});
+		var uids = websockets.getConnectedClients();
 
-			websockets.emitTopicPostStats();
-			topics.pushUnreadCount();
+		privileges.categories.filterUids('read', result.topicData.cid, uids, function(err, uids) {
+			if (err) {
+				return;
+			}
+			for(var i=0; i<uids.length; ++i) {
+				if (uids[i] !== socket.uid) {
+					websockets.in('uid_' + uids[i]).emit('event:new_post', result.postData);
+					websockets.in('uid_' + uids[i]).emit('event:new_topic', result.topicData);
+				}
+			}
+		});
 
-			callback(null, result.topicData);
-		}
+		websockets.emitTopicPostStats();
+		topics.pushUnreadCount();
 	});
 };