NodeBB/src/privileges/posts.js

'use strict';

const _ = require('lodash');

const meta = require('../meta');
const posts = require('../posts');
const topics = require('../topics');
const user = require('../user');
const helpers = require('./helpers');
const plugins = require('../plugins');
const utils = require('../utils');

module.exports = function (privileges) {
	privileges.posts = {};

	privileges.posts.get = async function (pids, uid) {
		if (!Array.isArray(pids) || !pids.length) {
			return [];
		}
		const cids = await posts.getCidsByPids(pids);
		const uniqueCids = _.uniq(cids);

		const results = await utils.promiseParallel({
			isAdmin: user.isAdministrator(uid),
			isModerator: user.isModerator(uid, uniqueCids),
			isOwner: posts.isOwner(pids, uid),
			'topics:read': helpers.isUserAllowedTo('topics:read', uid, uniqueCids),
			read: helpers.isUserAllowedTo('read', uid, uniqueCids),
			'posts:edit': helpers.isUserAllowedTo('posts:edit', uid, uniqueCids),
			'posts:history': helpers.isUserAllowedTo('posts:history', uid, uniqueCids),
			'posts:view_deleted': helpers.isUserAllowedTo('posts:view_deleted', uid, uniqueCids),
		});

		const isModerator = _.zipObject(uniqueCids, results.isModerator);
		const privData = {};
		privData['topics:read'] = _.zipObject(uniqueCids, results['topics:read']);
		privData.read = _.zipObject(uniqueCids, results.read);
		privData['posts:edit'] = _.zipObject(uniqueCids, results['posts:edit']);
		privData['posts:history'] = _.zipObject(uniqueCids, results['posts:history']);
		privData['posts:view_deleted'] = _.zipObject(uniqueCids, results['posts:view_deleted']);

		const privileges = cids.map(function (cid, i) {
			const isAdminOrMod = results.isAdmin || isModerator[cid];
			const editable = (privData['posts:edit'][cid] && (results.isOwner[i] || results.isModerator)) || results.isAdmin;
			const viewDeletedPosts = results.isOwner[i] || privData['posts:view_deleted'][cid] || results.isAdmin;
			const viewHistory = results.isOwner[i] || privData['posts:history'][cid] || results.isAdmin;

			return {
				editable: editable,
				move: isAdminOrMod,
				isAdminOrMod: isAdminOrMod,
				'topics:read': privData['topics:read'][cid] || results.isAdmin,
				read: privData.read[cid] || results.isAdmin,
				'posts:history': viewHistory,
				'posts:view_deleted': viewDeletedPosts,
			};
		});

		return privileges;
	};

	privileges.posts.can = async function (privilege, pid, uid) {
		const cid = await posts.getCidByPid(pid);
		return await privileges.categories.can(privilege, cid, uid);
	};

	privileges.posts.filter = async function (privilege, pids, uid) {
		if (!Array.isArray(pids) || !pids.length) {
			return [];
		}

		pids = _.uniq(pids);
		const postData = await posts.getPostsFields(pids, ['uid', 'tid', 'deleted']);
		const tids = _.uniq(postData.map(post => post && post.tid).filter(Boolean));
		const topicData = await topics.getTopicsFields(tids, ['deleted', 'cid']);

		const tidToTopic = _.zipObject(tids, topicData);

		let cids = postData.map(function (post, index) {
			if (post) {
				post.pid = pids[index];
				post.topic = tidToTopic[post.tid];
			}
			return tidToTopic[post.tid] && tidToTopic[post.tid].cid;
		}).filter(cid => parseInt(cid, 10));

		cids = _.uniq(cids);

		const results = await privileges.categories.getBase(privilege, cids, uid);
		const allowedCids = cids.filter(function (cid, index) {
			return !results.categories[index].disabled &&
				(results.allowedTo[index] || results.isAdmin);
		});

		const cidsSet = new Set(allowedCids);
		const canViewDeleted = _.zipObject(cids, results.view_deleted);

		pids = postData.filter(function (post) {
			return post.topic && cidsSet.has(post.topic.cid) &&
				((!post.topic.deleted && !post.deleted) || canViewDeleted[post.topic.cid] || results.isAdmin);
		}).map(post => post.pid);

		const data = await plugins.fireHook('filter:privileges.posts.filter', {
			privilege: privilege,
			uid: uid,
			pids: pids,
		});

		return data ? data.pids : null;
	};

	privileges.posts.canEdit = async function (pid, uid) {
		const results = await utils.promiseParallel({
			isAdmin: privileges.users.isAdministrator(uid),
			isMod: posts.isModerator([pid], uid),
			owner: posts.isOwner(pid, uid),
			edit: privileges.posts.can('posts:edit', pid, uid),
			postData: posts.getPostFields(pid, ['tid', 'timestamp', 'deleted', 'deleterUid']),
			userData: user.getUserFields(uid, ['reputation']),
		});

		results.isMod = results.isMod[0];
		if (results.isAdmin) {
			return { flag: true };
		}

		if (!results.isMod && meta.config.postEditDuration && (Date.now() - results.postData.timestamp > meta.config.postEditDuration * 1000)) {
			return { flag: false, message: '[[error:post-edit-duration-expired, ' + meta.config.postEditDuration + ']]' };
		}
		if (!results.isMod && meta.config.newbiePostEditDuration > 0 && meta.config.newbiePostDelayThreshold > results.userData.reputation && Date.now() - results.postData.timestamp > meta.config.newbiePostEditDuration * 1000) {
			return { flag: false, message: '[[error:post-edit-duration-expired, ' + meta.config.newbiePostEditDuration + ']]' };
		}

		const isLocked = await topics.isLocked(results.postData.tid);
		if (!results.isMod && isLocked) {
			return { flag: false, message: '[[error:topic-locked]]' };
		}

		if (!results.isMod && results.postData.deleted && parseInt(uid, 10) !== parseInt(results.postData.deleterUid, 10)) {
			return { flag: false, message: '[[error:post-deleted]]' };
		}

		results.pid = parseInt(pid, 10);
		results.uid = uid;

		const result = await plugins.fireHook('filter:privileges.posts.edit', results);
		return { flag: result.edit && (result.owner || result.isMod), message: '[[error:no-privileges]]' };
	};

	privileges.posts.canDelete = async function (pid, uid) {
		const postData = await posts.getPostFields(pid, ['uid', 'tid', 'timestamp', 'deleterUid']);
		const results = await utils.promiseParallel({
			isAdmin: privileges.users.isAdministrator(uid),
			isMod: posts.isModerator([pid], uid),
			isLocked: topics.isLocked(postData.tid),
			isOwner: posts.isOwner(pid, uid),
			'posts:delete': privileges.posts.can('posts:delete', pid, uid),
		});
		results.isMod = results.isMod[0];
		if (results.isAdmin) {
			return { flag: true };
		}

		if (!results.isMod && results.isLocked) {
			return { flag: false, message: '[[error:topic-locked]]' };
		}

		var postDeleteDuration = meta.config.postDeleteDuration;
		if (!results.isMod && postDeleteDuration && (Date.now() - postData.timestamp > postDeleteDuration * 1000)) {
			return { flag: false, message: '[[error:post-delete-duration-expired, ' + meta.config.postDeleteDuration + ']]' };
		}
		var deleterUid = postData.deleterUid;
		var flag = results['posts:delete'] && ((results.isOwner && (deleterUid === 0 || deleterUid === postData.uid)) || results.isMod);
		return { flag: flag, message: '[[error:no-privileges]]' };
	};

	privileges.posts.canFlag = async function (pid, uid) {
		const [userReputation, isAdminOrModerator] = await Promise.all([
			user.getUserField(uid, 'reputation'),
			isAdminOrMod(pid, uid),
		]);
		const minimumReputation = meta.config['min:rep:flag'];
		const canFlag = isAdminOrModerator || (userReputation >= minimumReputation);
		return { flag: canFlag };
	};

	privileges.posts.canMove = async function (pid, uid) {
		const isMain = await posts.isMain(pid);
		if (isMain) {
			throw new Error('[[error:cant-move-mainpost]]');
		}
		return await isAdminOrMod(pid, uid);
	};

	privileges.posts.canPurge = async function (pid, uid) {
		const cid = await posts.getCidByPid(pid);
		const results = await utils.promiseParallel({
			purge: privileges.categories.isUserAllowedTo('purge', cid, uid),
			owner: posts.isOwner(pid, uid),
			isAdmin: privileges.users.isAdministrator(uid),
			isModerator: privileges.users.isModerator(uid, cid),
		});
		return (results.purge && (results.owner || results.isModerator)) || results.isAdmin;
	};

	async function isAdminOrMod(pid, uid) {
		if (parseInt(uid, 10) <= 0) {
			return false;
		}
		const cid = await posts.getCidByPid(pid);
		return await privileges.categories.isAdminOrMod(cid, uid);
	}
};