RocketChat/Rocket.Chat

import type { ServerMethods } from '@rocket.chat/ddp-client';
import { Meteor } from 'meteor/meteor';

import { ChatMessage, ChatSubscription } from '../../app/models/client';
import { settings } from '../../app/settings/client';
import { t } from '../../app/utils/lib/i18n';
import { dispatchToastMessage } from '../lib/toast';

Meteor.methods<ServerMethods>({
    starMessage(message) {
        const uid = Meteor.userId();

        if (!uid) {
            dispatchToastMessage({ type: 'error', message: t('error-starring-message') });
            return false;
        }

        if (!ChatSubscription.findOne({ rid: message.rid })) {
            dispatchToastMessage({ type: 'error', message: t('error-starring-message') });
            return false;
        }

        if (!ChatMessage.findOneByRoomIdAndMessageId(message.rid, message._id)) {
            dispatchToastMessage({ type: 'error', message: t('error-starring-message') });
            return false;
        }

        if (!settings.get('Message_AllowStarring')) {
            dispatchToastMessage({ type: 'error', message: t('error-starring-message') });
            return false;
        }

        if (message.starred) {
            ChatMessage.update(
                { _id: message._id },
                {
                    $addToSet: {
                        starred: { _id: uid },
                    },
                },
            );

            dispatchToastMessage({ type: 'success', message: t('Message_has_been_starred') });

            return true;
        }

        ChatMessage.update(
            { _id: message._id },
            {
                $pull: {
                    starred: { _id: uid },
                },
            },
        );

        dispatchToastMessage({ type: 'success', message: t('Message_has_been_unstarred') });
        return true;
    },
});