RocketChat/Rocket.Chat

import { Apps, AppEvents } from '@rocket.chat/apps';
import type { IMessage } from '@rocket.chat/core-typings';
import type { ServerMethods } from '@rocket.chat/ddp-client';
import { Messages } from '@rocket.chat/models';
import { check } from 'meteor/check';
import { Meteor } from 'meteor/meteor';

import { canAccessRoomIdAsync } from '../../../authorization/server/functions/canAccessRoom';
import { RateLimiter } from '../../../lib/server';
import { notifyOnMessageChange } from '../../../lib/server/lib/notifyListener';
import { settings } from '../../../settings/server';
import { follow } from '../functions';

declare module '@rocket.chat/ddp-client' {
    // eslint-disable-next-line @typescript-eslint/naming-convention
    interface ServerMethods {
        followMessage(message: { mid: IMessage['_id'] }): false | undefined;
    }
}

Meteor.methods<ServerMethods>({
    async followMessage({ mid }) {
        check(mid, String);

        const uid = Meteor.userId();
        if (!uid) {
            throw new Meteor.Error('error-invalid-user', 'Invalid user', { method: 'followMessage' });
        }

        if (mid && !settings.get('Threads_enabled')) {
            throw new Meteor.Error('error-not-allowed', 'not-allowed', { method: 'followMessage' });
        }

        const message = await Messages.findOneById(mid);
        if (!message) {
            throw new Meteor.Error('error-invalid-message', 'Invalid message', {
                method: 'followMessage',
            });
        }

        if (!(await canAccessRoomIdAsync(message.rid, uid))) {
            throw new Meteor.Error('error-not-allowed', 'not-allowed', { method: 'followMessage' });
        }

        const id = message.tmid || message._id;

        const followResult = await follow({ tmid: id, uid });

        void notifyOnMessageChange({
            id,
        });

        const isFollowed = true;
        await Apps.self?.triggerEvent(AppEvents.IPostMessageFollowed, message, await Meteor.userAsync(), isFollowed);

        return followResult;
    },
});

RateLimiter.limitMethod('followMessage', 5, 5000, {
    userId() {
        return true;
    },
});