RocketChat/Rocket.Chat

import { OmnichannelEEService } from '@rocket.chat/core-services';
import type { ILivechatVisitor, IMessage, IOmnichannelRoom, IRoom, IUser } from '@rocket.chat/core-typings';
import { isEditedMessage, isOmnichannelRoom } from '@rocket.chat/core-typings';
import { LivechatRooms, LivechatVisitors, Users } from '@rocket.chat/models';

import { callbackLogger } from '../../../../../app/livechat/server/lib/logger';
import { callbacks } from '../../../../../lib/callbacks';
import { i18n } from '../../../../../server/lib/i18n';

const resumeOnHoldCommentAndUser = async (room: IOmnichannelRoom): Promise<{ comment: string; resumedBy: IUser }> => {
    const {
        v: { _id: visitorId },
        _id: rid,
    } = room;
    const visitor = await LivechatVisitors.findOneEnabledById<Pick<ILivechatVisitor, 'name' | 'username'>>(visitorId, {
        projection: { name: 1, username: 1 },
    });
    if (!visitor) {
        callbackLogger.error(`[afterSaveMessage] Visitor Not found for room ${rid} while trying to resume on hold`);
        throw new Error('Visitor not found while trying to resume on hold');
    }

    const guest = visitor.name || visitor.username;

    const resumeChatComment = i18n.t('Omnichannel_on_hold_chat_automatically', { guest });

    const resumedBy = await Users.findOneById('rocket.cat');
    if (!resumedBy) {
        callbackLogger.error(`[afterSaveMessage] User Not found for room ${rid} while trying to resume on hold`);
        throw new Error(`User not found while trying to resume on hold`);
    }

    return { comment: resumeChatComment, resumedBy };
};

const handleAfterSaveMessage = async (message: IMessage, room: IRoom) => {
    if (isEditedMessage(message) || message.t || !isOmnichannelRoom(room)) {
        return message;
    }

    const { _id: rid, v: roomVisitor } = room;

    if (!roomVisitor?._id) {
        return message;
    }

    // Need to read the room every time, the room object is not updated
    const updatedRoom = await LivechatRooms.findOneById(rid);
    if (!updatedRoom) {
        return message;
    }

    if (message.token && room.onHold) {
        callbackLogger.debug(`[afterSaveMessage] Room ${rid} is on hold, resuming it now since visitor sent a message`);

        try {
            const { comment: resumeChatComment, resumedBy } = await resumeOnHoldCommentAndUser(updatedRoom);
            await OmnichannelEEService.resumeRoomOnHold(updatedRoom, resumeChatComment, resumedBy);
        } catch (error) {
            callbackLogger.error(`[afterSaveMessage] Error while resuming room ${rid} on hold: Error: `, error);
            return message;
        }
    }

    return message;
};

callbacks.add('afterSaveMessage', handleAfterSaveMessage, callbacks.priority.HIGH, 'livechat-resume-on-hold');