Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-03-06 12:31:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

closes #2522

Browse Source
This commit is contained in:
barisusakli
2014-12-12 00:45:43 -05:00
parent 52a53df80d
commit 8bba811aaf
2 changed files with 46 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
src/topics/fork.js
View File

@@ -4,12 +4,13 @@
var async = require('async'),
winston = require('winston'),
db = require('./../database'),
db = require('../database'),
posts = require('./../posts'),
posts = require('../posts'),
privileges = require('../privileges'),
postTools = require('./../postTools'),
threadTools = require('./../threadTools');
postTools = require('../postTools'),
plugins = require('../plugins'),
threadTools = require('../threadTools');
module.exports = function(Topics) {
@@ -70,41 +71,48 @@ module.exports = function(Topics) {
};
Topics.movePostToTopic = function(pid, tid, callback) {
threadTools.exists(tid, function(err, exists) {
if (err || !exists) {
return callback(err || new Error('[[error:no-topic]]'));
}
posts.getPostFields(pid, ['tid', 'timestamp', 'votes'], function(err, postData) {
if (err) {
return callback(err);
var postData;
async.waterfall([
function(next) {
threadTools.exists(tid, next);
},
function(exists, next) {
if (!exists) {
return next(new Error('[[error:no-topic]]'));
}
if (!postData || !postData.tid) {
return callback(new Error('[[error:no-post]]'));
posts.getPostFields(pid, ['tid', 'timestamp', 'votes'], next);
},
function(post, next) {
if (!post || !post.tid) {
return next(new Error('[[error:no-post]]'));
}
postData = post;
postData.pid = pid;
Topics.removePostFromTopic(postData.tid, pid, function(err) {
if (err) {
return callback(err);
Topics.removePostFromTopic(postData.tid, pid, next);
},
function(next) {
async.parallel([
function(next) {
Topics.decreasePostCount(postData.tid, next);
},
function(next) {
Topics.increasePostCount(tid, next);
},
function(next) {
posts.setPostField(pid, 'tid', tid, next);
},
function(next) {
Topics.addPostToTopic(tid, pid, postData.timestamp, postData.votes, next);
}
async.parallel([
function(next) {
Topics.decreasePostCount(postData.tid, next);
},
function(next) {
Topics.increasePostCount(tid, next);
},
function(next) {
posts.setPostField(pid, 'tid', tid, next);
},
function(next) {
Topics.addPostToTopic(tid, pid, postData.timestamp, postData.votes, next);
}
], callback);
});
});
], next);
}
], function(err) {
if (err) {
return callback(err);
}
plugins.fireHook('action:post.move', {post: postData, tid: tid});
callback(null);
});
};
};

4
src/topics/posts.js
View File

@@ -201,7 +201,9 @@ module.exports = function(Topics) {
function (next) {
db.sortedSetRemove('tid:' + tid + ':posts:votes', pid, next);
}
], callback);
], function(err, results) {
callback(err);
});
};
Topics.getPids = function(tid, callback) {