From 193b1870bce310db27652404957df4f7143e58ce Mon Sep 17 00:00:00 2001
From: Gsk54 <sylvain.briat@free.fr>
Date: Mon, 26 Dec 2022 15:21:21 +0100
Subject: [PATCH] complete user and auth services logs

---
 .../adapters/primaries/auth.controller.ts     | 73 +++++++++++++++++++
 .../adapters/primaries/user.controller.ts     | 50 +++++++++++++
 2 files changed, 123 insertions(+)
 create mode 100644 src/modules/logger/adapters/primaries/auth.controller.ts

diff --git a/src/modules/logger/adapters/primaries/auth.controller.ts b/src/modules/logger/adapters/primaries/auth.controller.ts
new file mode 100644
index 0000000..3f22d3e
--- /dev/null
+++ b/src/modules/logger/adapters/primaries/auth.controller.ts
@@ -0,0 +1,73 @@
+import { RabbitSubscribe } from '@golevelup/nestjs-rabbitmq';
+import { Controller, Inject } from '@nestjs/common';
+import { WINSTON_MODULE_PROVIDER } from 'nest-winston';
+import { Logger } from 'winston';
+import { level } from './logger/level.enum';
+import loggerOptions from './logger/logger';
+
+@Controller()
+export class AuthController {
+  constructor(
+    @Inject(WINSTON_MODULE_PROVIDER) private readonly logger: Logger,
+  ) {}
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.create.crit',
+    queue: 'logging-auth-create-crit',
+  })
+  public async authCreatedCriticalHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.crit, 'critical'));
+    this.logger.crit(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.delete.crit',
+    queue: 'logging-auth-delete-crit',
+  })
+  public async authDeletedCriticalHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.crit, 'critical'));
+    this.logger.crit(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.username.add.warning',
+    queue: 'logging-auth-username-add-warning',
+  })
+  public async authUsernameAddedWarningHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.warning, 'warning'));
+    this.logger.warning(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.username.delete.warning',
+    queue: 'logging-auth-username-delete-warning',
+  })
+  public async authUsernameDeletedWarningHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.warning, 'warning'));
+    this.logger.warning(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.password.update.warning',
+    queue: 'logging-auth-password-update-warning',
+  })
+  public async authPasswordUpdatedWarningHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.warning, 'warning'));
+    this.logger.warning(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'auth.username.update.warning',
+    queue: 'logging-auth-username-update-warning',
+  })
+  public async authUsernameUpdatedWarningHandler(message: string) {
+    this.logger.configure(loggerOptions('auth', level.warning, 'warning'));
+    this.logger.warning(JSON.parse(message));
+  }
+}
diff --git a/src/modules/logger/adapters/primaries/user.controller.ts b/src/modules/logger/adapters/primaries/user.controller.ts
index 6bb2be3..b4111aa 100644
--- a/src/modules/logger/adapters/primaries/user.controller.ts
+++ b/src/modules/logger/adapters/primaries/user.controller.ts
@@ -40,4 +40,54 @@ export class UserController {
     this.logger.configure(loggerOptions('user', level.crit, 'critical'));
     this.logger.crit(JSON.parse(message));
   }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.delete.info',
+    queue: 'logging-user-delete-info',
+  })
+  public async userDeletedInfoHandler(message: string) {
+    this.logger.configure(loggerOptions('user', level.info, 'info'));
+    this.logger.info(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.delete.crit',
+    queue: 'logging-user-delete-crit',
+  })
+  public async userDeletedCriticalHandler(message: string) {
+    this.logger.configure(loggerOptions('user', level.crit, 'critical'));
+    this.logger.crit(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.read.warning',
+    queue: 'logging-user-read-warning',
+  })
+  public async userReadWarningHandler(message: string) {
+    this.logger.configure(loggerOptions('user', level.warning, 'warning'));
+    this.logger.warning(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.update.info',
+    queue: 'logging-user-update-info',
+  })
+  public async userUpdatedInfoHandler(message: string) {
+    this.logger.configure(loggerOptions('user', level.info, 'info'));
+    this.logger.info(JSON.parse(message));
+  }
+
+  @RabbitSubscribe({
+    exchange: 'logging',
+    routingKey: 'user.update.crit',
+    queue: 'logging-user-update-crit',
+  })
+  public async userUpdatedCriticalHandler(message: string) {
+    this.logger.configure(loggerOptions('user', level.crit, 'critical'));
+    this.logger.crit(JSON.parse(message));
+  }
 }