NodeBB/src/topics/fork.js

'use strict';

var async = require('async');

var db = require('../database');
var posts = require('../posts');
var privileges = require('../privileges');
var plugins = require('../plugins');
var meta = require('../meta');

module.exports = function (Topics) {
	Topics.createTopicFromPosts = function (uid, title, pids, fromTid, callback) {
		if (title) {
			title = title.trim();
		}

		if (title.length < meta.config.minimumTitleLength) {
			return callback(new Error('[[error:title-too-short, ' + meta.config.minimumTitleLength + ']]'));
		} else if (title.length > meta.config.maximumTitleLength) {
			return callback(new Error('[[error:title-too-long, ' + meta.config.maximumTitleLength + ']]'));
		}

		if (!pids || !pids.length) {
			return callback(new Error('[[error:invalid-pid]]'));
		}

		pids.sort(function (a, b) {
			return a - b;
		});
		var mainPid = pids[0];
		var cid;
		var tid;
		async.waterfall([
			function (next) {
				posts.getCidByPid(mainPid, next);
			},
			function (_cid, next) {
				cid = _cid;
				async.parallel({
					postData: function (next) {
						posts.getPostData(mainPid, next);
					},
					isAdminOrMod: function (next) {
						privileges.categories.isAdminOrMod(cid, uid, next);
					},
				}, next);
			},
			function (results, next) {
				if (!results.isAdminOrMod) {
					return next(new Error('[[error:no-privileges]]'));
				}
				Topics.create({ uid: results.postData.uid, title: title, cid: cid }, next);
			},
			function (tid, next) {
				Topics.updateTopicBookmarks(fromTid, pids, function (err) { next(err, tid); });
			},
			function (_tid, next) {
				tid = _tid;
				async.eachSeries(pids, function (pid, next) {
					privileges.posts.canEdit(pid, uid, function (err, canEdit) {
						if (err || !canEdit.flag) {
							return next(err || new Error(canEdit.message));
						}

						Topics.movePostToTopic(uid, pid, tid, next);
					});
				}, next);
			},
			function (next) {
				Topics.updateLastPostTime(tid, Date.now(), next);
			},
			function (next) {
				plugins.fireHook('action:topic.fork', { tid: tid, fromTid: fromTid, uid: uid });
				Topics.getTopicData(tid, next);
			},
		], callback);
	};

	Topics.movePostToTopic = function (callerUid, pid, tid, callback) {
		var postData;
		tid = parseInt(tid, 10);
		async.waterfall([
			function (next) {
				Topics.exists(tid, next);
			},
			function (exists, next) {
				if (!exists) {
					return next(new Error('[[error:no-topic]]'));
				}
				posts.getPostFields(pid, ['tid', 'uid', 'timestamp', 'upvotes', 'downvotes'], next);
			},
			function (post, next) {
				if (!post || !post.tid) {
					return next(new Error('[[error:no-post]]'));
				}

				if (post.tid === tid) {
					return next(new Error('[[error:cant-move-to-same-topic]]'));
				}

				postData = post;
				postData.pid = pid;

				Topics.removePostFromTopic(postData.tid, postData, next);
			},
			function (next) {
				async.parallel([
					function (next) {
						updateCategory(postData, tid, next);
					},
					function (next) {
						posts.setPostField(pid, 'tid', tid, next);
					},
					function (next) {
						Topics.addPostToTopic(tid, postData, next);
					},
				], next);
			},
			function (results, next) {
				async.parallel([
					async.apply(Topics.updateLastPostTimeFromLastPid, tid),
					async.apply(Topics.updateLastPostTimeFromLastPid, postData.tid),
				], function (err) {
					next(err);
				});
			},
			function (next) {
				plugins.fireHook('action:post.move', { uid: callerUid, post: postData, tid: tid });
				next();
			},
		], callback);
	};

	function updateCategory(postData, toTid, callback) {
		var topicData;
		async.waterfall([
			function (next) {
				Topics.getTopicsFields([postData.tid, toTid], ['cid', 'pinned'], next);
			},
			function (_topicData, next) {
				topicData = _topicData;
				if (!topicData[0].cid || !topicData[1].cid) {
					return callback();
				}
				var tasks = [];
				if (!topicData[0].pinned) {
					tasks.push(async.apply(db.sortedSetIncrBy, 'cid:' + topicData[0].cid + ':tids:posts', -1, postData.tid));
				}
				if (!topicData[1].pinned) {
					tasks.push(async.apply(db.sortedSetIncrBy, 'cid:' + topicData[1].cid + ':tids:posts', 1, toTid));
				}
				async.series(tasks, function (err) {
					next(err);
				});
			},
			function (next) {
				if (topicData[0].cid === topicData[1].cid) {
					return callback();
				}

				async.parallel([
					async.apply(db.incrObjectFieldBy, 'category:' + topicData[0].cid, 'post_count', -1),
					async.apply(db.incrObjectFieldBy, 'category:' + topicData[1].cid, 'post_count', 1),
					async.apply(db.sortedSetRemove, 'cid:' + topicData[0].cid + ':pids', postData.pid),
					async.apply(db.sortedSetAdd, 'cid:' + topicData[1].cid + ':pids', postData.timestamp, postData.pid),
				], next);
			},
		], callback);
	}
};