RocketChat/Rocket.Chat

import { Messages, Roles, Rooms, Subscriptions, ReadReceipts } from '@rocket.chat/models';

import { FileUpload } from '../../../file-upload/server';
import { notifyOnSubscriptionChanged } from '../lib/notifyListener';
import type { SubscribedRoomsForUserWithDetails } from './getRoomsWithSingleOwner';

const bulkRoomCleanUp = async (rids: string[]): Promise<unknown> => {
    // no bulk deletion for files
    await Promise.all(rids.map((rid) => FileUpload.removeFilesByRoomId(rid)));

    return Promise.all([
        Subscriptions.removeByRoomIds(rids, {
            async onTrash(doc) {
                void notifyOnSubscriptionChanged(doc, 'removed');
            },
        }),
        Messages.removeByRoomIds(rids),
        ReadReceipts.removeByRoomIds(rids),
        Rooms.removeByIds(rids),
    ]);
};

export const relinquishRoomOwnerships = async function (
    userId: string,
    subscribedRooms: SubscribedRoomsForUserWithDetails[],
    removeDirectMessages = true,
): Promise<SubscribedRoomsForUserWithDetails[]> {
    // change owners
    const changeOwner = subscribedRooms.filter(({ shouldChangeOwner }) => shouldChangeOwner);

    for await (const { newOwner, rid } of changeOwner) {
        newOwner && (await Roles.addUserRoles(newOwner, ['owner'], rid));
    }

    const roomIdsToRemove: string[] = subscribedRooms.filter(({ shouldBeRemoved }) => shouldBeRemoved).map(({ rid }) => rid);

    if (removeDirectMessages) {
        (await Rooms.find1On1ByUserId(userId, { projection: { _id: 1 } }).toArray()).map(({ _id }: { _id: string }) =>
            roomIdsToRemove.push(_id),
        );
    }

    await bulkRoomCleanUp(roomIdsToRemove);

    return subscribedRooms;
};