From d11bfab2759fa5b2887be6a16bbb50c027cfe291 Mon Sep 17 00:00:00 2001
From: barisusakli <barisusakli@gmail.com>
Date: Mon, 11 May 2015 15:38:14 -0400
Subject: [PATCH] async posts/topics.js

---
 src/posts.js        |  4 ++++
 src/posts/topics.js | 47 +++++++++++++++++++++++----------------------
 2 files changed, 28 insertions(+), 23 deletions(-)

diff --git a/src/posts.js b/src/posts.js
index c2e252302d..bea7b6673f 100644
--- a/src/posts.js
+++ b/src/posts.js
@@ -35,6 +35,10 @@ var async = require('async'),
 	};
 
 	Posts.getPostsByPids = function(pids, uid, callback) {
+		if (!Array.isArray(pids) || !pids.length) {
+			return callback(null, []);
+		}
+
 		var keys = [];
 
 		for (var x=0, numPids=pids.length; x<numPids; ++x) {
diff --git a/src/posts/topics.js b/src/posts/topics.js
index 29b32edf25..a9946fdace 100644
--- a/src/posts/topics.js
+++ b/src/posts/topics.js
@@ -7,38 +7,39 @@ var async = require('async'),
 module.exports = function(Posts) {
 
 	Posts.getPostsFromSet = function(set, start, stop, uid, reverse, callback) {
-		Posts.getPidsFromSet(set, start, stop, reverse, function(err, pids) {
-			if (err) {
-				return callback(err);
+		async.waterfall([
+			function(next) {
+				Posts.getPidsFromSet(set, start, stop, reverse, next);
+			},
+			function(pids, next) {
+				Posts.getPostsByPids(pids, uid, next);
 			}
-
-			if (!Array.isArray(pids) || !pids.length) {
-				return callback(null, []);
-			}
-
-			Posts.getPostsByPids(pids, uid, callback);
-		});
+		], callback);
 	};
 
 	Posts.isMain = function(pid, callback) {
-		Posts.getPostField(pid, 'tid', function(err, tid) {
-			if (err) {
-				return callback(err);
+		async.waterfall([
+			function(next) {
+				Posts.getPostField(pid, 'tid', next);
+			},
+			function(tid, next) {
+				topics.getTopicField(tid, 'mainPid', next);
+			},
+			function(mainPid, next) {
+				next(null, parseInt(pid, 10) === parseInt(mainPid, 10));
 			}
-			topics.getTopicField(tid, 'mainPid', function(err, mainPid) {
-				callback(err, parseInt(pid, 10) === parseInt(mainPid, 10));
-			});
-		});
+		], callback);
 	};
 
 	Posts.getTopicFields = function(pid, fields, callback) {
-		Posts.getPostField(pid, 'tid', function(err, tid) {
-			if (err) {
-				return callback(err);
+		async.waterfall([
+			function(next) {
+				Posts.getPostField(pid, 'tid', next);
+			},
+			function(tid, next) {
+				topics.getTopicFields(tid, fields, next);
 			}
-
-			topics.getTopicFields(tid, fields, callback);
-		});
+		], callback);
 	};
 
 };
\ No newline at end of file