RocketChat/Rocket.Chat

import { useEndpoint } from '@rocket.chat/ui-contexts';
import type { UseMutationOptions } from '@tanstack/react-query';
import { useMutation } from '@tanstack/react-query';

import { ChatSubscription } from '../../../../app/models/client';

export const useClearUnreadAllMessagesMutation = (options?: Omit<UseMutationOptions<void, unknown, void, unknown>, 'mutationFn'>) => {
    const readSubscription = useEndpoint('POST', '/v1/subscriptions.read');

    return useMutation(async () => {
        const promises = ChatSubscription.find(
            {
                open: true,
            },
            {
                fields: {
                    unread: 1,
                    alert: 1,
                    rid: 1,
                    t: 1,
                    name: 1,
                    ls: 1,
                },
            },
        ).map((subscription) => {
            if (subscription.alert || subscription.unread > 0) {
                return readSubscription({ rid: subscription.rid, readThreads: true });
            }

            return Promise.resolve();
        });

        await Promise.all(promises);
    }, options);
};