diff --git a/src/posts/flags.js b/src/posts/flags.js index cbfa1f832c..47959a8d88 100644 --- a/src/posts/flags.js +++ b/src/posts/flags.js @@ -87,7 +87,12 @@ module.exports = function(Posts) { }; Posts.dismissAllFlags = function(callback) { - db.delete('posts:flagged', callback); + db.getSortedSetRange('posts:flagged', 0, -1, function(err, pids) { + if (err) { + return callback(err); + } + async.eachLimit(pids, 50, Posts.dismissFlag, callback); + }); }; Posts.getFlags = function(set, uid, start, stop, callback) {