src/favourites.js

src/favourites.js

@@ -1,3 +1,5 @@
+"use strict";
+
 var async = require('async'),
 	winston = require('winston'),
 	db = require('./database'),
@@ -7,7 +9,6 @@ var async = require('async'),
 	meta = require('./meta');
 
 (function (Favourites) {
-	"use strict";
 
 	function vote(type, unvote, pid, uid, callback) {
 		uid = parseInt(uid, 10);
@@ -239,54 +240,56 @@ var async = require('async'),
 	};
 
 	function toggleFavourite(type, pid, uid, callback) {
-		if (uid === 0) {
+		if (!parseInt(uid, 10)) {
 			return callback(new Error('[[error:not-logged-in]]'));
 		}
 		var isFavouriting = type === 'favourite';
-		posts.getPostFields(pid, ['pid', 'uid', 'timestamp'], function (err, postData) {
+
+		async.parallel({
+			postData: function(next) {
+				posts.getPostFields(pid, ['pid', 'uid'], next);
+			},
+			hasFavourited: function(next) {
+				Favourites.hasFavourited(pid, uid, next);
+			}
+		}, function(err, results) {
 			if (err) {
 				return callback(err);
 			}
 
-			Favourites.hasFavourited(pid, uid, function (err, hasFavourited) {
+			if (isFavouriting && results.hasFavourited) {
-				if (err) {
-					return callback(err);
-				}
-
-				if (isFavouriting && hasFavourited) {
 				return callback(new Error('[[error:already-favourited]]'));
 			}
 
-				if (!isFavouriting && !hasFavourited) {
+			if (!isFavouriting && !results.hasFavourited) {
 				return callback(new Error('[[error:alrady-unfavourited]]'));
 			}
 
+			async.waterfall([
+				function(next) {
 					if (isFavouriting) {
-					db.sortedSetAdd('uid:' + uid + ':favourites', postData.timestamp, pid);
+						db.sortedSetAdd('uid:' + uid + ':favourites', Date.now(), pid, next);
 					} else {
-					db.sortedSetRemove('uid:' + uid + ':favourites', pid);
+						db.sortedSetRemove('uid:' + uid + ':favourites', pid, next);
 					}
-
+				},
-
+				function(next) {
-				db[isFavouriting ? 'setAdd' : 'setRemove']('pid:' + pid + ':users_favourited', uid, function(err) {
+					db[isFavouriting ? 'setAdd' : 'setRemove']('pid:' + pid + ':users_favourited', uid, next);
-					if (err) {
+				},
-						return callback(err);
+				function(next) {
-					}
+					db.setCount('pid:' + pid + ':users_favourited', next);
-
+				},
-					db.setCount('pid:' + pid + ':users_favourited', function(err, count) {
+				function(count, next) {
-						if (err) {
+					results.postData.reputation = count;
-							return callback(err);
+					posts.setPostField(pid, 'reputation', count, next);
-						}
+				},
-						postData.reputation = count;
+				function(next) {
-						posts.setPostField(pid, 'reputation', count, function(err) {
+					next(null, {
-							callback(err, {
+						post: results.postData,
-								post: postData,
 						isFavourited: isFavouriting
 					});
-						});
+				}
-					});
+			], callback);
-				});
-			});
 		});
 	}
 
@@ -310,13 +313,6 @@ var async = require('async'),
 		db.isMemberOfSets(sets, uid, callback);
 	};
 
-	Favourites.getFavouritedUidsByPids = function(pids, callback) {
-		var sets = pids.map(function(pid) {
-			return 'pid:' + pid + ':users_favourited';
-		});
-		db.getSetsMembers(sets, callback);
-	};
-
 	Favourites.getUpvotedUidsByPids = function(pids, callback) {
 		var sets = pids.map(function(pid) {
 			return 'pid:' + pid + ':upvote';