improve logging

api/src/modules/admin/admin.module.ts

@@ -1,11 +1,13 @@
 import { Module } from '@nestjs/common';
 import { AdminController } from './admin.controller';
 import { AuthModule } from '@api/modules/auth/auth.module';
-
 import { ImportModule } from '@api/modules/import/import.module';
+import { NewUserEventHandler } from '@api/modules/admin/events/handlers/new-user-event.handler';
+import { PasswordRecoveryRequestedEventHandler } from '@api/modules/admin/events/handlers/password-recovery-requested.handler';
 
 @Module({
   imports: [AuthModule, ImportModule],
+  providers: [NewUserEventHandler, PasswordRecoveryRequestedEventHandler],
   controllers: [AdminController],
 })
 export class AdminModule {}

api/src/modules/admin/events/handlers/new-user-event.handler.ts

@@ -0,0 +1,47 @@
+import { EventsHandler, IEventHandler } from '@nestjs/cqrs';
+import { NewUserEvent } from '../new-user.event';
+import { ApiEventsService } from '@api/modules/api-events/api-events.service';
+import { API_EVENT_TYPES } from '@api/modules/api-events/events.enum';
+
+@EventsHandler(NewUserEvent)
+export class NewUserEventHandler implements IEventHandler<NewUserEvent> {
+  constructor(private readonly apiEventsService: ApiEventsService) {}
+
+  async handle(event: NewUserEvent): Promise<void> {
+    const { userId, email, type: eventType } = event;
+    if (eventType === API_EVENT_TYPES.USER_CREATED) {
+      await this.registerUserCreatedEvent(userId, { email });
+    }
+    if (eventType === API_EVENT_TYPES.USER_SIGNED_UP) {
+      await this.registerUserSignedUpEvent(userId, { email });
+    }
+  }
+
+  private async registerUserCreatedEvent(
+    userId: string,
+    payload: { email: string },
+  ) {
+    await this.apiEventsService.create({
+      eventType: API_EVENT_TYPES.USER_CREATED,
+      resourceId: userId,
+      payload,
+    });
+    this.apiEventsService.logger.warn(
+      `New user added to the system with email: ${payload.email}`,
+    );
+  }
+
+  private async registerUserSignedUpEvent(
+    userId: string,
+    payload: { email: string },
+  ) {
+    await this.apiEventsService.create({
+      eventType: API_EVENT_TYPES.USER_SIGNED_UP,
+      resourceId: userId,
+      payload,
+    });
+    this.apiEventsService.logger.warn(
+      `New user signed up to the system with email: ${payload.email}`,
+    );
+  }
+}

api/src/modules/admin/events/new-user.event.ts

@@ -0,0 +1,11 @@
+import { API_EVENT_TYPES } from '@api/modules/api-events/events.enum';
+
+export class NewUserEvent {
+  constructor(
+    public readonly userId: string,
+    public readonly email: string,
+    public readonly type:
+      | API_EVENT_TYPES.USER_CREATED
+      | API_EVENT_TYPES.USER_SIGNED_UP,
+  ) {}
+}

api/src/modules/api-events/api-events.service.ts

@@ -1,4 +1,4 @@
-import { Injectable } from '@nestjs/common';
+import { Injectable, Logger } from '@nestjs/common';
 import { InjectRepository } from '@nestjs/typeorm';
 import { Repository } from 'typeorm';
 import { ApiEventsEntity } from './api-events.entity';
@@ -12,6 +12,7 @@ type CreateApiEvent = {
 
 @Injectable()
 export class ApiEventsService {
+  logger: Logger = new Logger(ApiEventsService.name);
   constructor(
     @InjectRepository(ApiEventsEntity)
     private readonly apiEventsRepository: Repository<ApiEventsEntity>,

api/src/modules/auth/authentication.service.ts

@@ -15,11 +15,12 @@ import { randomBytes } from 'node:crypto';
 import { SendWelcomeEmailCommand } from '@api/modules/notifications/email/commands/send-welcome-email.command';
 import { JwtManager } from '@api/modules/auth/services/jwt.manager';
 import { SignUpDto } from '@shared/schemas/auth/sign-up.schema';
-import { UserSignedUpEvent } from '@api/modules/admin/events/user-signed-up.event';
+import { NewUserEvent } from '@api/modules/admin/events/new-user.event';
 import { UpdateUserPasswordDto } from '@shared/dtos/users/update-user-password.dto';
 import { RequestEmailUpdateDto } from '@shared/dtos/users/request-email-update.dto';
 import { SendEmailConfirmationEmailCommand } from '@api/modules/notifications/email/commands/send-email-confirmation-email.command';
 import { PasswordManager } from '@api/modules/auth/services/password.manager';
+import { API_EVENT_TYPES } from '@api/modules/api-events/events.enum';
 
 @Injectable()
 export class AuthenticationService {
@@ -70,6 +71,9 @@ export class AuthenticationService {
       partnerName,
       isActive: false,
     });
+    this.eventBus.publish(
+      new NewUserEvent(newUser.id, newUser.email, API_EVENT_TYPES.USER_CREATED),
+    );
     return {
       newUser,
       plainTextPassword,
@@ -89,7 +93,9 @@ export class AuthenticationService {
     user.isActive = true;
     user.password = await this.passwordManager.hashPassword(newPassword);
     await this.usersService.saveUser(user);
-    this.eventBus.publish(new UserSignedUpEvent(user.id, user.email));
+    this.eventBus.publish(
+      new NewUserEvent(user.id, user.email, API_EVENT_TYPES.USER_SIGNED_UP),
+    );
   }
 
   async verifyToken(token: string, type: TOKEN_TYPE_ENUM): Promise<boolean> {