RocketChat/Rocket.Chat

import { CannedResponse } from '@rocket.chat/models';

import notifications from '../../../../../app/notifications/server/lib/Notifications';
import { callbacks } from '../../../../../lib/callbacks';

callbacks.add(
    'livechat.saveAgentDepartment',
    async (options: Record<string, any>): Promise<any> => {
        const { departmentId, agentsId } = options;
        await CannedResponse.findByDepartmentId(departmentId, {}).forEach((response) => {
            notifications.streamCannedResponses.emit('canned-responses', { type: 'changed', ...response }, { agentsId });
        });

        return options;
    },
    callbacks.priority.HIGH,
    'canned-responses-on-save-agent-department',
);