RocketChat/Rocket.Chat

import { FederationRoomEvents } from '@rocket.chat/models';

import { getFederatedRoomData, hasExternalDomain, isLocalUser } from '../functions/helpers';
import { dispatchEvent } from '../handler';
import { getFederationDomain } from '../lib/getFederationDomain';
import { clientLogger } from '../lib/logger';
import { normalizers } from '../normalizers';

async function afterRemoveFromRoom(involvedUsers, room) {
    const { removedUser } = involvedUsers;

    const localDomain = getFederationDomain();

    // If there are not federated users on this room, ignore it
    if (!hasExternalDomain(room) && isLocalUser(removedUser, localDomain)) {
        return involvedUsers;
    }

    clientLogger.debug({ msg: 'afterRemoveFromRoom', involvedUsers, room });

    const { users } = await getFederatedRoomData(room);

    try {
        // Get the domains after removal
        const domainsAfterRemoval = [...new Set(users.map((u) => u.federation.origin))];

        //
        // Normalize the room's federation status
        //
        const usersBeforeRemoval = users;
        usersBeforeRemoval.push(removedUser);

        // Get the users domains
        const domainsBeforeRemoval = [...new Set(usersBeforeRemoval.map((u) => u.federation.origin))];

        //
        // Create the user remove event
        //
        const normalizedSourceUser = await normalizers.normalizeUser(removedUser);

        const removeUserEvent = await FederationRoomEvents.createRemoveUserEvent(
            localDomain,
            room._id,
            normalizedSourceUser,
            domainsAfterRemoval,
        );

        // Dispatch the events
        dispatchEvent(domainsBeforeRemoval, removeUserEvent);
    } catch (err) {
        clientLogger.error({ msg: 'afterRemoveFromRoom => Could not remove user:', err });
    }

    return involvedUsers;
}

export const definition = {
    hook: 'afterRemoveFromRoom',
    callback: afterRemoveFromRoom,
    id: 'federation-after-remove-from-room',
};