diff --git a/src/posts.js b/src/posts.js index a9ab69f9d4..054ae82a52 100644 --- a/src/posts.js +++ b/src/posts.js @@ -134,6 +134,10 @@ var db = require('./database'), callback(new Error('reply-error'), null); } + Posts.getCidByPid(postData.pid, function(err, cid) { + db.delete('cid:' + cid + ':read_by_uid'); + }); + async.parallel([ function(next) { topics.markUnRead(tid, function(err) { @@ -147,16 +151,6 @@ var db = require('./database'), function(next) { topics.pushUnreadCount(null, next); }, - function(next) { - Posts.getCidByPid(postData.pid, function(err, cid) { - if(err) { - return next(err); - } - - db.delete('cid:' + cid + ':read_by_uid'); - next(); - }); - }, function(next) { threadTools.notifyFollowers(tid, uid); next();