RocketChat/Rocket.Chat

import type { IMessage } from '@rocket.chat/core-typings';
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';

Meteor.methods<ServerMethods>({
    pinMessage(message: IMessage) {
        if (!Meteor.userId()) {
            throw new Meteor.Error('error-not-authorized', 'Not authorized', {
                method: 'pinMessage',
            });
        }
        if (!settings.get('Message_AllowPinning')) {
            throw new Meteor.Error('pinning-not-allowed', 'Pinning messages is not allowed', {
                method: 'pinMessage',
            });
        }
        if (!ChatSubscription.findOne({ rid: message.rid })) {
            throw new Meteor.Error('error-pinning-message', 'Pinning messages is not allowed', {
                method: 'pinMessage',
            });
        }
        if (typeof message._id !== 'string') {
            throw new Meteor.Error('error-pinning-message', 'Invalid message', {
                method: 'pinMessage',
            });
        }

        ChatMessage.update(
            {
                _id: message._id,
                rid: message.rid,
            },
            {
                $set: {
                    pinned: true,
                },
            },
        );

        const msg = ChatMessage.findOne({ _id: message._id });

        if (!msg) {
            throw new Meteor.Error('error-pinning-message', 'Error pinning message', {
                method: 'pinMessage',
            });
        }

        return msg;
    },
});