AbstractFederationApplicationServiceEE.ts

import { AbstractFederationApplicationService } from '../../../../../server/services/federation/application/AbstractFederationApplicationService';
import type { RocketChatFileAdapter } from '../../../../../server/services/federation/infrastructure/rocket-chat/adapters/File';
import type { RocketChatSettingsAdapter } from '../../../../../server/services/federation/infrastructure/rocket-chat/adapters/Settings';
import { FederatedUserEE } from '../domain/FederatedUser';
import type { IFederationBridgeEE } from '../domain/IFederationBridge';
import type { RocketChatUserAdapterEE } from '../infrastructure/rocket-chat/adapters/User';
import type { IFederationInviteeDto } from './room/sender/input/RoomSenderDto';

export abstract class AbstractFederationApplicationServiceEE extends AbstractFederationApplicationService {
	constructor(
		protected bridge: IFederationBridgeEE,
		protected internalUserAdapter: RocketChatUserAdapterEE,
		protected internalFileAdapter: RocketChatFileAdapter,
		protected internalSettingsAdapter: RocketChatSettingsAdapter,
	) {
		super(bridge, internalUserAdapter, internalFileAdapter, internalSettingsAdapter);
	}

	protected async createUsersLocallyOnly(invitees: IFederationInviteeDto[]): Promise<void> {
		const externalUsersToBeCreatedLocally = invitees.filter(
			(invitee) =>
				!FederatedUserEE.isOriginalFromTheProxyServer(
					this.bridge.extractHomeserverOrigin(invitee.rawInviteeId),
					this.internalHomeServerDomain,
				),
		);

		for await (const invitee of externalUsersToBeCreatedLocally) {
			const externalUserProfileInformation = await this.bridge.getUserProfileInformation(invitee.rawInviteeId);

			const name = externalUserProfileInformation?.displayName || invitee.normalizedInviteeId;
			const username = invitee.normalizedInviteeId;
			const existsOnlyOnProxyServer = false;

			await this.internalUserAdapter.createLocalUser(
				FederatedUserEE.createLocalInstanceOnly({
					username,
					name,
					existsOnlyOnProxyServer,
				}),
			);

			const federatedUser = await this.internalUserAdapter.getFederatedUserByExternalId(invitee.rawInviteeId);
			if (!federatedUser) {
				return;
			}
			await this.updateUserAvatarInternally(federatedUser, externalUserProfileInformation?.avatarUrl);
			await this.updateUserDisplayNameInternally(federatedUser, externalUserProfileInformation?.displayName);
		}
	}
}