moving deleted topics wont cause topic count to go negative

v1.18.x
Baris Soner Usakli 11 years ago
parent 3d61a1b15b
commit 8bba4889d2

@ -186,43 +186,39 @@ var winston = require('winston'),
} }
ThreadTools.move = function(tid, cid, callback) { ThreadTools.move = function(tid, cid, callback) {
topics.getTopicFields(tid, ['cid', 'lastposttime'], function(err, topicData) { var topic;
async.waterfall([
function(next) {
topics.getTopicFields(tid, ['cid', 'lastposttime', 'deleted'], next);
},
function(topicData, next) {
topic = topicData;
db.sortedSetRemove('categories:' + topicData.cid + ':tid', tid, next);
},
function(result, next) {
db.sortedSetAdd('categories:' + cid + ':tid', topic.lastposttime, tid, next);
}
], function(err, result) {
if(err) { if(err) {
return callback(err); return callback(err);
} }
var oldCid = topic.cid;
var oldCid = topicData.cid; topics.setTopicField(tid, 'cid', cid);
if(!oldCid) {
return callback(new Error('invalid-topic'));
}
db.sortedSetRemove('categories:' + oldCid + ':tid', tid, function(err, result) { categories.moveActiveUsers(tid, oldCid, cid);
if(err) { categories.moveRecentReplies(tid, oldCid, cid, function(err, data) {
return callback(err); if (err) {
winston.err(err);
} }
});
db.sortedSetAdd('categories:' + cid + ':tid', topicData.lastposttime, tid, function(err, result) { if(!parseInt(topic.deleted, 10)) {
categories.incrementCategoryFieldBy(oldCid, 'topic_count', -1);
if(err) { categories.incrementCategoryFieldBy(cid, 'topic_count', 1);
return callback(err); }
}
topics.setTopicField(tid, 'cid', cid);
categories.moveRecentReplies(tid, oldCid, cid, function(err, data) {
if (err) {
winston.err(err);
}
});
categories.moveActiveUsers(tid, oldCid, cid);
categories.incrementCategoryFieldBy(oldCid, 'topic_count', -1);
categories.incrementCategoryFieldBy(cid, 'topic_count', 1);
callback(null); callback(null);
});
});
}); });
} }

Loading…
Cancel
Save