interim commit

src/threadTools.js

@@ -298,21 +298,36 @@ var RDB = require('./redis.js'),
 	}
 
 	ThreadTools.get_latest_undeleted_pid = function(tid, callback) {
+		RDB.lrange('tid:' + tid + ':posts', 0, -1, function(err, pids) {
+			if (pids.length === 0) return callback(new Error('no-undeleted-pids-found'));
 
-		posts.getPostsByTid(tid, 0, -1, function(posts) {
+			console.log(tid, pids);
-
+			pids.reverse();
-			var numPosts = posts.length;
+			async.detectSeries(pids, function(pid, next) {
-			if (!numPosts)
+				RDB.hget('post:' + pid, 'deleted', function(err, deleted) {
-				return callback(new Error('no-undeleted-pids-found'));
+					if (deleted === '1') next(true);
-
+					else next(false);
-			while (numPosts--) {
+				});
-				if (posts[numPosts].deleted !== '1') {
+			}, function(pid) {
-					callback(null, posts[numPosts].pid);
+				// console.log(pid);
-					return;
+				if (pid) callback(null, pid);
-				}
+				else callback(new Error('no-undeleted-pids-found'));
-			}
+			});
-
-			callback(new Error('no-undeleted-pids-found'));
 		});
+		// posts.getPostsByTid(tid, 0, -1, function(posts) {
+		// 	var numPosts = posts.length;
+		// 	if (!numPosts)
+		// 		return callback(new Error('no-undeleted-pids-found'));
+
+		// 	while (numPosts--) {
+		// 		if (posts[numPosts].deleted !== '1') {
+		// 			console.log(posts[numPosts].pid);
+		// 			callback(null, posts[numPosts].pid);
+		// 			return;
+		// 		}
+		// 	}
+
+		// 	callback(new Error('no-undeleted-pids-found'));
+		// });
 	}
 }(exports));