UPDATE: Added log-lib on more routes and services

src/modules/auth/auth.controller.ts

@@ -1,5 +1,4 @@
 import {
-  Logger,
   Body,
   Controller,
   Headers,
@@ -7,6 +6,7 @@ import {
   HttpCode,
   HttpStatus,
   OnApplicationBootstrap,
+  Inject,
 } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import {
@@ -24,23 +24,26 @@ import {
 import { AuthClientService } from '../../clients/auth/client.service';
 import { PermissionsClientService } from '../../clients/permissions/client.service';
 import { Permissions } from '../../authentication/permissions.enum';
-
+import { DadosferaLogger } from 'dadosfera-logs';
 import ErrorBuilder from '../../utils/ErrorBuilder';
-import { LoginDto } from './dtos/login';
 
 @ApiTags('Auth')
 @Controller('auth')
 export class AuthController implements OnApplicationBootstrap {
-  private readonly logger = new Logger(AuthController.name);
+  logger: any;
 
   constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
     private authClient: AuthClientService,
     private permissionsClient: PermissionsClientService,
-  ) {}
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   // internally used to send permissions to duc on microservice startup
   async onApplicationBootstrap() {
-    this.logger.log('sending permissions to DUC...');
+    this.logger.info('sending permissions to DUC...');
 
     const permissions = Object.values(Permissions).flatMap((namespace) =>
       Object.values(namespace),
@@ -53,7 +56,7 @@ export class AuthController implements OnApplicationBootstrap {
           err.code === 'No connection established' &&
           process.env.LOCAL_ENV === 'true'
         ) {
-          return this.logger.log(
+          return this.logger.info(
             "couldn't connect to DUC. suppresing in local env",
           );
         }
@@ -65,7 +68,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('sign-in')
   @HttpCode(HttpStatus.OK)
   async signIn(@Body() { username, password, totp }: AuthSignInRequest) {
-    this.logger.log(`/auth`, 'SignIn');
+    this.logger.info('/auth - SignIn');
 
     return this.authClient.signIn({ username, password, totp });
   }
@@ -75,7 +78,7 @@ export class AuthController implements OnApplicationBootstrap {
   async refreshAccessToken(
     @Body() { refreshToken }: AuthRefreshAccessTokenRequest,
   ) {
-    this.logger.log(`/auth`, 'RefreshAccessToken');
+    this.logger.info('/auth - RefreshAccessToken');
 
     return this.authClient.refreshAccessToken({ refreshToken });
   }
@@ -86,7 +89,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthChangePasswordRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'change-password');
+    this.logger.info('/auth - change-password');
 
     const { oldPassword, newPassword } = body;
     const { authorization: accessToken } = headers;
@@ -101,7 +104,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('reset-password')
   @HttpCode(HttpStatus.OK)
   async resetPassword(@Body() body: AuthResetPasswordRequest) {
-    this.logger.log(`/auth`, 'reset-password');
+    this.logger.info('/auth - reset-password');
 
     const { username } = body;
 
@@ -113,7 +116,7 @@ export class AuthController implements OnApplicationBootstrap {
   async verifyResetPasswordCode(
     @Body() body: AuthVerifyResetPasswordCodeRequest,
   ) {
-    this.logger.log(`/auth`, 'verify-reset-password-code');
+    this.logger.info('/auth - verify-reset-password-code');
 
     const { username, code } = body;
 
@@ -123,7 +126,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('confirm-reset-password')
   @HttpCode(HttpStatus.OK)
   async confirmResetPassword(@Body() body: AuthConfirmResetPasswordRequest) {
-    this.logger.log(`/auth`, 'confirm-reset-password');
+    this.logger.info('/auth - confirm-reset-password');
 
     const { username, code, newPassword } = body;
 
@@ -140,7 +143,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthEnableTotpMfaRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'enable-totp');
+    this.logger.info('/auth - enable-totp');
 
     const { password } = body;
     const { authorization: accessToken } = headers;
@@ -154,7 +157,7 @@ export class AuthController implements OnApplicationBootstrap {
     @Body() body: AuthDisableTotpMfaRequest,
     @Headers() headers,
   ) {
-    this.logger.log(`/auth`, 'disable-totp');
+    this.logger.info('/auth - disable-totp');
 
     const { password } = body;
     const { authorization: accessToken } = headers;
@@ -165,7 +168,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('dismiss-totp')
   @HttpCode(HttpStatus.OK)
   async dismissTotpMFA(@Headers() headers) {
-    this.logger.log(`/auth`, 'disable-totp');
+    this.logger.info('/auth - disable-totp');
 
     const { authorization: accessToken } = headers;
 
@@ -175,7 +178,7 @@ export class AuthController implements OnApplicationBootstrap {
   @Post('verify-totp')
   @HttpCode(HttpStatus.OK)
   async verifyTotp(@Body() body: AuthVerifyTotpMfaRequest, @Headers() headers) {
-    this.logger.log(`/auth`, 'enable-totp');
+    this.logger.info('/auth - enable-totp');
 
     const { totp } = body;
     const { authorization: accessToken } = headers;

src/modules/connector/connector.controller.ts

@@ -10,6 +10,7 @@ import {
   Query,
   UploadedFile,
   UseInterceptors,
+  Inject,
 } from '@nestjs/common';
 import { FileInterceptor } from '@nestjs/platform-express';
 import { ApiBearerAuth, ApiConsumes, ApiTags } from '@nestjs/swagger';
@@ -21,12 +22,20 @@ import { GetAllDto } from './dtos/get-all';
 import { RemoveTagDto } from './dtos/remove-tag';
 import { UpdateDto } from './dtos/update';
 import { UploadFileDto } from './dtos/upload-file';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('connectors')
 @ApiBearerAuth()
 @Controller('connectors')
 export class ConnectorController {
-  constructor(private connectorClientService: ConnectorClientService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private connectorClientService: ConnectorClientService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Post()
   @ApiConsumes('multipart/form-data')
@@ -35,7 +44,7 @@ export class ConnectorController {
     @UploadedFile() file,
     @Body() body: CreateConnectorDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response = await this.connectorClientService.uploadConnector({
       file,
@@ -49,7 +58,7 @@ export class ConnectorController {
   @ApiConsumes('multipart/form-data')
   @UseInterceptors(FileInterceptor('file'))
   async uploadFile(@UploadedFile() file, @Body() { name }: UploadFileDto) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response = await this.connectorClientService.uploadFile({
       file,
@@ -61,7 +70,7 @@ export class ConnectorController {
 
   @Get()
   async getAllConnectors(@Query() queries: GetAllDto) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { filters, search } = queries;
 
@@ -83,7 +92,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Query('version') version: string,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const pluginId = `${plugin}-${version}`;
 
@@ -102,7 +111,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Query('version') version: string,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const pluginId = `${plugin}-${version}`;
 
@@ -122,7 +131,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: UpdateDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const changes = body;
 
@@ -142,7 +151,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: AddTagDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { tags } = body;
 
@@ -168,7 +177,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() body: RemoveTagDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const { tags } = body;
     const remove = tags;
@@ -195,7 +204,7 @@ export class ConnectorController {
     @Param('plugin') plugin: string,
     @Body() { version }: DeleteConnectorDto,
   ) {
-    console.log(`/upload`, 'Upload Connector Route');
+    this.logger.info('/upload - Upload Connector Route');
 
     const response: any = await this.connectorClientService.deleteConnector(
       plugin,

src/modules/health/health.controller.ts

@@ -1,15 +1,23 @@
-import { Controller, Get } from '@nestjs/common';
+import { Controller, Get, Inject } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import { HealthService } from './health.service';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @ApiTags('Health')
 @Controller('health')
 export class HealthController {
-  constructor(private readonly healthService: HealthService) {}
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+    private readonly healthService: HealthService,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
 
   @Get()
   check() {
-    console.log(`/health`, 'check');
+    this.logger.info('/health - check');
     return this.healthService.check();
   }
 }

src/modules/health/health.service.ts

@@ -1,9 +1,17 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { DadosferaLogger } from 'dadosfera-logs';
 
 @Injectable()
 export class HealthService {
+  logger: any;
+  constructor(
+    @Inject(DadosferaLogger)
+    dadosferaLogger: DadosferaLogger,
+  ) {
+    this.logger = dadosferaLogger.logger;
+  }
   check() {
-    console.log('HEALTH');
+    this.logger.info('HEALTH');
     return { message: 'Ok' };
   }
 }

src/modules/inputs/inputs.controller.ts

@@ -126,7 +126,7 @@ export class InputsController {
   @ApiOkResponse({ type: Input })
   async reCreate(@Param('id') id: string, @Body() input: CreateInputReq) {
     if (!id) id = id;
-    console.log(`POST /${id}`, 'ON RECREATE ROUTE');
+    this.logger.info(`POST /${id}`, 'ON RECREATE ROUTE');
 
     const response = await this.inputService.reCreate(input);