upstream-rocketchat/apps/meteor/ee/server/hooks/omnichannel/resumeOnHold.ts

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

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

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({ msg: '[afterOmnichannelSaveMessage] Visitor Not found for room while trying to resume on hold', rid });
		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({ msg: '[afterOmnichannelSaveMessage] User Not found for room while trying to resume on hold', rid });
		throw new Error(`User not found while trying to resume on hold`);
	}

	return { comment: resumeChatComment, resumedBy };
};

callbacks.add(
	'afterOmnichannelSaveMessage',
	async (message: IMessage, { room }) => {
		if (isEditedMessage(message) || message.t) {
			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 (isMessageFromVisitor(message) && room.onHold) {
			callbackLogger.debug({ msg: '[afterOmnichannelSaveMessage] Room is on hold, resuming it now since visitor sent a message', rid });

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

		return message;
	},
	callbacks.priority.HIGH,
	'livechat-resume-on-hold',
);