RocketChat/Rocket.Chat

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

import { callbacks } from '../../../../lib/callbacks';
import { settings } from '../../../settings/server';
import { searchProviderService } from '../service';
import { EventService } from './EventService';

export const searchEventService = new EventService();

/**
 * Listen to message changes via Hooks
 */
function afterSaveMessage(m: IMessage) {
    searchEventService.promoteEvent('message.save', m._id, m);
    return m;
}

function afterDeleteMessage(m: IMessage) {
    searchEventService.promoteEvent('message.delete', m._id);
    return m;
}

settings.watch('Search.Provider', () => {
    if (searchProviderService.activeProvider?.on) {
        callbacks.add('afterSaveMessage', afterSaveMessage, callbacks.priority.MEDIUM, 'search-events');
        callbacks.add('afterDeleteMessage', afterDeleteMessage, callbacks.priority.MEDIUM, 'search-events-delete');
        return;
    }

    callbacks.remove('afterSaveMessage', 'search-events');
    callbacks.remove('afterDeleteMessage', 'search-events-delete');
});