RocketChat/Rocket.Chat

import type { ILivechatInquiryRecord } from '@rocket.chat/core-typings';
import moment from 'moment';

import { settings } from '../../../../../app/settings/server';
import { callbacks } from '../../../../../lib/callbacks';
import { OmnichannelQueueInactivityMonitor } from '../lib/QueueInactivityMonitor';
import { cbLogger } from '../lib/logger';

export const afterInquiryQueued = async (inquiry: ILivechatInquiryRecord) => {
    if (!inquiry?._id || !inquiry?._updatedAt) {
        return;
    }

    const timer = settings.get<number>('Livechat_max_queue_wait_time');

    if (timer <= 0) {
        return;
    }

    // schedule individual jobs instead of property for close inactivty
    const newQueueTime = moment(inquiry._updatedAt).add(timer, 'minutes');
    cbLogger.debug(`Scheduling estimated close time at ${newQueueTime} for queued inquiry ${inquiry._id}`);
    await OmnichannelQueueInactivityMonitor.scheduleInquiry(inquiry._id, new Date(newQueueTime.format()));
};

settings.watch<number>('Livechat_max_queue_wait_time', (value) => {
    if (value <= 0) {
        callbacks.remove('livechat.afterInquiryQueued', 'livechat-inquiry-queued-set-queue-timer');
        return;
    }
    callbacks.add('livechat.afterInquiryQueued', afterInquiryQueued, callbacks.priority.HIGH, 'livechat-inquiry-queued-set-queue-timer');
});