NodeBB/NodeBB

'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'];
    room.canViewInfo = await privileges.global.can('view:users:info', uid);

    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);
};