more fixes

src/categories.js

@@ -273,6 +273,7 @@ var	RDB = require('./redis.js'),
 
 	Categories.getRecentReplies = function(cid, callback) {
 		RDB.zrevrange('categories:recent_posts:cid:' + cid, 0, 4, function(err, pids) {
+
 			if (pids.length == 0) {
 				callback(false);
 				return;

src/feed.js

@@ -35,7 +35,7 @@
 			});
 		}
 
-		async.parallel([getTopicData, getPostsData], function(err, results) {
+		async.parallel([getTopicData], function(err, results) {
 			var topicData = results[0],
 				location = '/topic/' + topicData.slug,
 				xml_url = '/topic/' + tid + '.rss';

src/postTools.js

@@ -23,7 +23,7 @@ marked.setOptions({
 		//todo: break early if one condition is true 
 		
 		function getThreadPrivileges(next) {
-			posts.get_tid_by_pid(pid, function(tid) {
+			posts.getPostField(pid, 'tid', function(tid) {
 					threadTools.privileges(tid, uid, function(privileges) {
 						next(null, privileges);
 					});

src/posts.js

@@ -31,37 +31,42 @@ marked.setOptions({
 			}
 		});
 	}
+	
+	Posts.addUserInfoToPost = function(post, callback) {
+		user.getUserFields(post.uid, ['username', 'userslug', 'reputation', 'picture', 'signature'], function(userData) {
+
+			post.username = userData.username || 'anonymous';
+			post.userslug = userData.userslug || '';
+			post.user_rep = userData.reputation || 0;
+			post.picture = userData.picture || 'http://www.gravatar.com/avatar/d41d8cd98f00b204e9800998ecf8427e';
+			post.signature = marked(userData.signature || '');
+
+			callback();
+		});
+	}
 
-	// todo, getPostsByPids has duplicated stuff, have that call this fn - after userinfo calls are pulled out.
 	Posts.getPostSummaryByPids = function(pids, callback) {
-		var content = [], uid = [], timestamp = [];
-		for (var i=0, ii=pids.length; i<ii; i++) {
-			content.push('pid:' + pids[i] + ':content');
-			uid.push('pid:' + pids[i] + ':uid');
-			timestamp.push('pid:' + pids[i] + ':timestamp');
-		}
-
-		RDB.multi()
-			.mget(content)
-			.mget(uid)
-			.mget(timestamp)
-			.exec(function(err, replies) {
-				post_data = {
-					pids: pids,
-					content: replies[0],
-					uid: replies[1],
-					timestamp: replies[2]
-				}
-
-				// below, to be deprecated
-				user.getMultipleUserFields(post_data.uid, ['username','reputation','picture'], function(user_details) {
-					callback({
-						users: user_details,
-						posts: post_data
+		
+		var returnData = [];
+		
+		var loaded = 0;
+						
+		for(var i=0, ii=pids.length; i<ii; ++i) {
+			
+			(function(index, pid) {
+				Posts.getPostFields(pids[i], ['pid', 'content', 'uid', 'timestamp'], function(postData) {
+					Posts.addUserInfoToPost(postData, function() {
+						
+						returnData[index] = postData;
+						++loaded;
+						
+						if(loaded === pids.length) {
+							callback(returnData);		
+						}				
 					});
 				});
-				// above, to be deprecated
-			});
+			}(i, pids[i]));
+		}
 	};
 
 	Posts.getPostData = function(pid, callback) {
@@ -73,6 +78,22 @@ marked.setOptions({
 		});
 	}
 
+	Posts.getPostFields = function(uid, fields, callback) {
+		RDB.hmget('post:' + uid, fields, function(err, data) {
+			if(err === null) {
+				var returnData = {};
+				
+				for(var i=0, ii=fields.length; i<ii; ++i) {
+					returnData[fields[i]] = data[i];
+				}
+
+				callback(returnData);
+			}
+			else
+				console.log(err);
+		});		
+	}
+
 	Posts.getPostsByPids = function(pids, callback) {
 		var posts = [], 
 			loaded = 0;
@@ -95,7 +116,7 @@ marked.setOptions({
 	}
 
 	Posts.getPostField = function(pid, field, callback) {
-		RDB.hget('post:' + pid, field, function(data) {
+		RDB.hget('post:' + pid, field, function(err, data) {
 			if(err === null)
 				callback(data);
 			else
@@ -171,7 +192,12 @@ marked.setOptions({
 						RDB.zadd('categories:recent_posts:cid:' + cid, Date.now(), pid);
 					});
 
+					Posts.getTopicPostStats(socket);
 
+					// Send notifications to users who are following this topic
+					threadTools.notify_followers(tid, uid);
+
+					
 					socket.emit('event:alert', {
 						title: 'Reply Successful',
 						message: 'You have successfully replied. Click here to view your reply.',
@@ -179,10 +205,6 @@ marked.setOptions({
 						timeout: 2000
 					});
 
-					Posts.getTopicPostStats(socket);
-
-					// Send notifications to users who are following this topic
-					threadTools.notify_followers(tid, uid);
 
 					user.getUserFields(uid, ['username','reputation','picture','signature'], function(data) {
 
@@ -210,6 +232,8 @@ marked.setOptions({
 						io.sockets.in('topic_' + tid).emit('event:new_post', socketData);
 						io.sockets.in('recent_posts').emit('event:new_post', socketData);
 						
+						
+						
 					});
 				} else {
 					socket.emit('event:alert', {
@@ -255,7 +279,6 @@ marked.setOptions({
 
 					RDB.incr('totalpostcount');
 						
-					//RDB.get('tid:' + tid + ':cid', function(err, cid) {
 					topics.getTopicField(tid, 'cid', function(cid) {
 						RDB.handle(err);
 
@@ -271,8 +294,7 @@ marked.setOptions({
 						});
 					});
 					
-					user.onNewPostMade(uid, tid, pid, timestamp);
-					
+					user.onNewPostMade(uid, tid, pid, timestamp);					
 
 					if (callback) 
 						callback(pid);

src/topics.js

@@ -32,25 +32,13 @@ marked.setOptions({
 		});
 	}
 
-	function addUserInfoToPost(post, callback) {
-		user.getUserFields(post.uid, ['username', 'userslug', 'reputation', 'picture', 'signature'], function(userData) {
-
-			post.username = userData.username || 'anonymous';
-			post.userslug = userData.userslug || '';
-			post.user_rep = userData.reputation || 0;
-			post.gravatar = userData.picture || 'http://www.gravatar.com/avatar/d41d8cd98f00b204e9800998ecf8427e';
-			post.signature = marked(userData.signature || '');
-
-			callback();
-		});
-	}
 
 	function constructPosts(topicPosts, callback) {
 		var done = 0;
 
 		for(var i=0, ii=topicPosts.length; i<ii; ++i) {
 
-			addUserInfoToPost(topicPosts[i], function() {
+			posts.addUserInfoToPost(topicPosts[i], function() {
 				++done;
 				if(done === topicPosts.length)
 					callback();
@@ -393,6 +381,8 @@ marked.setOptions({
 					type: 'notify',
 					timeout: 2000
 				});
+				
+				console.log('topic posted');
 			});
 		});
 	};

src/websockets.js

@@ -335,7 +335,10 @@ var SocketIO = require('socket.io').listen(global.server, { log:false }),
 					topics.get_topic(data.tid, uid, function(topicData) {
 						topicData.tid = data.tid;
 						if (data.body) topicData.body = data.body;
-						socket.emit('api:composer.push', topicData);
+						socket.emit('api:composer.push', {
+							tid: data.tid,
+							title: topicData.title
+						});
 					});
 				} else if (parseInt(data.cid) > 0) {
 					user.getUserField(uid, 'username', function(username) {