fixing topic moving

v1.18.x
Julian Lam 11 years ago
parent a32aee60c2
commit bc407ee59c

@ -398,7 +398,7 @@ var db = require('./database.js'),
Categories.moveActiveUsers = function(tid, oldCid, cid, callback) { Categories.moveActiveUsers = function(tid, oldCid, cid, callback) {
function updateUser(uid) { function updateUser(uid) {
Categories.addActiveUser(cid, uid); Categories.addActiveUser(cid, uid, Date.now());
Categories.isUserActiveIn(oldCid, uid, function(err, active) { Categories.isUserActiveIn(oldCid, uid, function(err, active) {
if (!err && !active) { if (!err && !active) {

@ -177,8 +177,8 @@ SocketTopics.movePost = function(data, callback, sessionData) {
}); });
}; };
SocketTopics.move = function(data, sessionData) { SocketTopics.move = function(data, callback, sessionData) {
threadTools.move(data.tid, data.cid, sessionData.socket); threadTools.move(data.tid, data.cid, callback, sessionData);
}; };
SocketTopics.followCheck = function(tid, callback, sessionData) { SocketTopics.followCheck = function(tid, callback, sessionData) {

@ -167,8 +167,7 @@ var winston = require('winston'),
} }
} }
ThreadTools.move = function(tid, cid, socket) { ThreadTools.move = function(tid, cid, callback, sessionData) {
topics.getTopicFields(tid, ['cid', 'lastposttime'], function(err, topicData) { topics.getTopicFields(tid, ['cid', 'lastposttime'], function(err, topicData) {
var oldCid = topicData.cid; var oldCid = topicData.cid;
@ -176,10 +175,9 @@ var winston = require('winston'),
db.sortedSetAdd('categories:' + cid + ':tid', topicData.lastposttime, tid, function(err, result) { db.sortedSetAdd('categories:' + cid + ':tid', topicData.lastposttime, tid, function(err, result) {
if(err) { if(err) {
socket.emit('api:topic.move', { return callback({
status: 'error' status: 'error'
}); });
return;
} }
topics.setTopicField(tid, 'cid', cid); topics.setTopicField(tid, 'cid', cid);
@ -199,11 +197,11 @@ var winston = require('winston'),
categories.incrementCategoryFieldBy(oldCid, 'topic_count', -1); categories.incrementCategoryFieldBy(oldCid, 'topic_count', -1);
categories.incrementCategoryFieldBy(cid, 'topic_count', 1); categories.incrementCategoryFieldBy(cid, 'topic_count', 1);
socket.emit('api:topic.move', { callback({
status: 'ok' status: 'ok'
}); });
websockets.in('topic_' + tid).emit('event:topic_moved', { sessionData.server.sockets.in('topic_' + tid).emit('event:topic_moved', {
tid: tid tid: tid
}); });
}); });

Loading…
Cancel
Save