NodeBB/src/controllers/accounts/chats.js

'use strict';

const db = require('../../database');
const messaging = require('../../messaging');
const meta = require('../../meta');
const user = require('../../user');
const privileges = require('../../privileges');
const helpers = require('../helpers');

const chatsController = module.exports;

chatsController.get = async function (req, res, next) {
	if (meta.config.disableChat) {
		return next();
	}

	const uid = await user.getUidByUserslug(req.params.userslug);
	if (!uid) {
		return next();
	}
	const canChat = await privileges.global.can(['chat', 'chat:privileged'], req.uid);
	if (!canChat.includes(true)) {
		return helpers.notAllowed(req, res);
	}

	const payload = {
		title: '[[pages:chats]]',
		uid: uid,
		userslug: req.params.userslug,
	};
	const isSwitch = res.locals.isAPI && parseInt(req.query.switch, 10) === 1;
	if (!isSwitch) {
		const [recentChats, publicRooms, privateRoomCount] = await Promise.all([
			messaging.getRecentChats(req.uid, uid, 0, 29),
			messaging.getPublicRooms(req.uid, uid),
			db.sortedSetCard(`uid:${uid}:chat:rooms`),
		]);
		if (!recentChats) {
			return next();
		}
		payload.rooms = recentChats.rooms;
		payload.nextStart = recentChats.nextStart;
		payload.publicRooms = publicRooms;
		payload.privateRoomCount = privateRoomCount;
	}

	if (!req.params.roomid) {
		return res.render('chats', payload);
	}

	const { index } = req.params;
	let start = 0;
	payload.scrollToIndex = null;
	if (index) {
		const msgCount = await db.getObjectField(`chat:room:${req.params.roomid}`, 'messageCount');
		start = Math.max(0, parseInt(msgCount, 10) - index - 49);
		payload.scrollToIndex = Math.min(msgCount, Math.max(0, parseInt(index, 10) || 1));
	}
	const room = await messaging.loadRoom(req.uid, {
		uid: uid,
		roomId: req.params.roomid,
		start: start,
	});
	if (!room) {
		return next();
	}

	room.title = room.roomName || room.usernames || '[[pages:chats]]';
	room.bodyClasses = ['chat-loaded'];
	const [canViewInfo, canUploadImage, canUploadFile] = await privileges.global.can([
		'view:users:info', 'upload:post:image', 'upload:post:file',
	], uid);
	room.canViewInfo = canViewInfo;
	room.canUpload = (canUploadImage || canUploadFile) && (meta.config.maximumFileSize > 0 || room.isAdmin);
	res.render('chats', {
		...payload,
		...room,
	});
};

chatsController.redirectToChat = async function (req, res, next) {
	if (!req.loggedIn) {
		return next();
	}
	const userslug = await user.getUserField(req.uid, 'userslug');
	if (!userslug) {
		return next();
	}
	const roomid = parseInt(req.params.roomid, 10);
	const index = parseInt(req.params.index, 10);
	helpers.redirect(res, `/user/${userslug}/chats${roomid ? `/${roomid}` : ''}${index ? `/${index}` : ''}`);
};

chatsController.redirectToMessage = async function (req, res, next) {
	const mid = parseInt(req.params.mid, 10);
	if (!mid) {
		return next();
	}
	const [userslug, roomId] = await Promise.all([
		user.getUserField(req.uid, 'userslug'),
		messaging.getMessageField(mid, 'roomId'),
	]);
	if (!userslug || !roomId) {
		return next();
	}
	const index = await db.sortedSetRank(`chat:room:${roomId}:mids`, mid);
	if (!(parseInt(index, 10) >= 0)) {
		return next();
	}

	helpers.redirect(res, `/user/${userslug}/chats/${roomId}${index ? `/${index + 1}` : ''}`, true);
};