From 753f1576ceceaaaf03bcb5b2fc62593cf084fc62 Mon Sep 17 00:00:00 2001 From: Baris Usakli Date: Wed, 16 Aug 2017 16:47:52 -0400 Subject: [PATCH] processSortedSet --- src/user/profile.js | 4 +++- src/user/reset.js | 9 ++------- 2 files changed, 5 insertions(+), 8 deletions(-) diff --git a/src/user/profile.js b/src/user/profile.js index 54ed58267b..dbdcbcba85 100644 --- a/src/user/profile.js +++ b/src/user/profile.js @@ -185,7 +185,9 @@ module.exports = function (User) { function (next) { db.sortedSetAdd('users:notvalidated', Date.now(), uid, next); }, - async.apply(User.reset.cleanByUid, uid), + function (next) { + User.reset.cleanByUid(uid, next); + }, ], function (err) { next(err); }); diff --git a/src/user/reset.js b/src/user/reset.js index 618ba680bc..db52ed033e 100644 --- a/src/user/reset.js +++ b/src/user/reset.js @@ -171,17 +171,12 @@ UserReset.clean = function (callback) { }; UserReset.cleanByUid = function (uid, callback) { - if (typeof callback !== 'function') { - callback = function () {}; - } - var toClean = []; uid = parseInt(uid, 10); async.waterfall([ - async.apply(db.getSortedSetRange.bind(db), 'reset:issueDate', 0, -1), - function (tokens, next) { - batch.processArray(tokens, function (tokens, next) { + function (next) { + batch.processSortedSet('reset:issueDate', function (tokens, next) { db.getObjectFields('reset:uid', tokens, function (err, results) { for (var code in results) { if (results.hasOwnProperty(code) && parseInt(results[code], 10) === uid) {