refactor(nestjs): Implement users module

packages/server/src/modules/UsersModule/subscribers/SyncSystemSendInvite.subscriber.ts

@@ -0,0 +1,106 @@
+
+import { EventEmitter2, OnEvent } from '@nestjs/event-emitter';
+import { Inject, Injectable } from '@nestjs/common';
+import {
+  IUserInvitedEventPayload,
+  IUserInviteResendEventPayload,
+  IUserInviteTenantSyncedEventPayload,
+} from '../Users.types';
+import { events } from '@/common/events/events';
+import { TenantModelProxy } from '@/modules/System/models/TenantBaseModel';
+import { TenantUser } from '@/modules/Tenancy/TenancyModels/models/TenantUser.model';
+import { UserInvite } from '../models/InviteUser.model';
+import { SystemUser } from '@/modules/System/models/SystemUser';
+import { TenancyContext } from '@/modules/Tenancy/TenancyContext.service';
+
+@Injectable()
+export class SyncSystemSendInviteSubscriber {
+  constructor(
+    @Inject(TenantUser.name)
+    private readonly tenantUserModel: TenantModelProxy<typeof TenantUser>,
+
+    @Inject(SystemUser.name)
+    private readonly systemUserModel: typeof SystemUser,
+
+    @Inject(UserInvite.name)
+    private readonly inviteModel: typeof UserInvite,
+    private readonly eventEmitter: EventEmitter2,
+    private readonly tenancyContext: TenancyContext
+  ) {}
+
+  /**
+   * Syncs send invite to system user.
+   * @param {IUserInvitedEventPayload} payload -
+   */
+  @OnEvent(events.inviteUser.sendInvite)
+  async syncSendInviteSystem({ inviteToken, user }: IUserInvitedEventPayload) {
+    const authorizedUser = await this.tenancyContext.getSystemUser();
+    const tenantId = authorizedUser.tenantId;
+
+    // Creates a new system user.
+    const systemUser = await this.systemUserModel.query().insert({
+      email: user.email,
+      active: user.active,
+      tenantId,
+
+      // Email should be verified since the user got the invite token through email.
+      verified: true,
+    });
+    // Creates a invite user token.
+    const invite = await this.inviteModel.query().insert({
+      email: user.email,
+      tenantId,
+      userId: systemUser.id,
+      token: inviteToken,
+    });
+    // Links the tenant user with created system user.
+    await this.tenantUserModel().query().findById(user.id).patch({
+      systemUserId: systemUser.id,
+    });
+    // Triggers `onUserSendInviteTenantSynced` event.
+    await this.eventEmitter.emitAsync(
+      events.inviteUser.sendInviteTenantSynced,
+      {
+        invite,
+        user,
+      } as IUserInviteTenantSyncedEventPayload,
+    );
+  }
+
+  /**
+   * Syncs resend invite to system user.
+   * @param {IUserInviteResendEventPayload} payload -
+   */
+  @OnEvent(events.inviteUser.resendInvite)
+  async syncResendInviteSystemUser({
+    inviteToken,
+    user,
+  }: IUserInviteResendEventPayload) {
+    const authorizedUser = await this.tenancyContext.getSystemUser();
+    const tenantId = authorizedUser.tenantId;
+
+    // Clear all invite tokens of the given user id.
+    await this.clearInviteTokensByUserId(tenantId, user.systemUserId);
+
+    const invite = await this.inviteModel.query().insert({
+      email: user.email,
+      tenantId,
+      userId: user.systemUserId,
+      token: inviteToken,
+    });
+  }
+
+  /**
+   * Clear invite tokens of the given user id.
+   * @param {number} userId - User id.
+   */
+  private clearInviteTokensByUserId = async (tenantId: number, userId: number) => {
+    await this.inviteModel
+      .query()
+      .where({
+        userId,
+        tenantId,
+      })
+      .delete();
+  };
+}