add logger to RocketChatUser and to RocketChat Services for delete me…

…thods

apps/server/src/modules/rocketchat-user/rocketchat-user.module.ts

@@ -1,8 +1,10 @@
 import { Module } from '@nestjs/common';
+import { LoggerModule } from '@src/core/logger';
 import { RocketChatUserRepo } from './repo';
 import { RocketChatUserService } from './service/rocket-chat-user.service';
 
 @Module({
+	imports: [LoggerModule],
 	providers: [RocketChatUserRepo, RocketChatUserService],
 	exports: [RocketChatUserService],
 })

apps/server/src/modules/rocketchat-user/service/rocket-chat-user.service.spec.ts

@@ -2,6 +2,7 @@ import { createMock, DeepMocked } from '@golevelup/ts-jest';
 import { ObjectId } from '@mikro-orm/mongodb';
 import { Test, TestingModule } from '@nestjs/testing';
 import { setupEntities } from '@shared/testing';
+import { LegacyLogger } from '@src/core/logger';
 import { RocketChatUserService } from './rocket-chat-user.service';
 import { RocketChatUserRepo } from '../repo';
 import { rocketChatUserFactory } from '../domain/testing/rocket-chat-user.factory';
@@ -20,6 +21,10 @@ describe(RocketChatUserService.name, () => {
 					provide: RocketChatUserRepo,
 					useValue: createMock<RocketChatUserRepo>(),
 				},
+				{
+					provide: LegacyLogger,
+					useValue: createMock<LegacyLogger>(),
+				},
 			],
 		}).compile();
 

apps/server/src/modules/rocketchat-user/service/rocket-chat-user.service.ts

@@ -1,11 +1,14 @@
 import { Injectable } from '@nestjs/common';
 import { EntityId } from '@shared/domain/types';
+import { LegacyLogger } from '@src/core/logger';
 import { RocketChatUser } from '../domain';
 import { RocketChatUserRepo } from '../repo';
 
 @Injectable()
 export class RocketChatUserService {
-	constructor(private readonly rocketChatUserRepo: RocketChatUserRepo) {}
+	constructor(private readonly rocketChatUserRepo: RocketChatUserRepo, private readonly logger: LegacyLogger) {
+		this.logger.setContext(RocketChatUserService.name);
+	}
 
 	public async findByUserId(userId: EntityId): Promise<RocketChatUser> {
 		const user: RocketChatUser = await this.rocketChatUserRepo.findByUserId(userId);
@@ -14,6 +17,11 @@ export class RocketChatUserService {
 	}
 
 	public deleteByUserId(userId: EntityId): Promise<number> {
-		return this.rocketChatUserRepo.deleteByUserId(userId);
+		this.logger.log({ action: 'Deleting rocketChatUser ', userId });
+		const deletedRocketChatUser: Promise<number> = this.rocketChatUserRepo.deleteByUserId(userId);
+
+		this.logger.log({ action: 'Deleted rocketChatUser ', userId });
+
+		return deletedRocketChatUser;
 	}
 }

apps/server/src/modules/rocketchat/rocket-chat.module.ts

@@ -1,13 +1,14 @@
 import { HttpModule } from '@nestjs/axios';
 import { DynamicModule, Module } from '@nestjs/common';
+import { LoggerModule } from '@src/core/logger';
 import { RocketChatOptions, RocketChatService } from './rocket-chat.service';
 
 @Module({})
 export class RocketChatModule {
 	static forRoot(options: RocketChatOptions): DynamicModule {
 		return {
 			module: RocketChatModule,
-			imports: [HttpModule],
+			imports: [HttpModule, LoggerModule],
 			providers: [
 				RocketChatService,
 				{

apps/server/src/modules/rocketchat/rocket-chat.service.ts

@@ -1,6 +1,7 @@
 /* istanbul ignore file */
 import { HttpService } from '@nestjs/axios';
 import { Inject, Injectable } from '@nestjs/common';
+import { LegacyLogger } from '@src/core/logger';
 import { lastValueFrom } from 'rxjs';
 import { catchError } from 'rxjs/operators';
 
@@ -73,8 +74,11 @@ export class RocketChatService {
 
 	constructor(
 		@Inject('ROCKET_CHAT_OPTIONS') private readonly options: RocketChatOptions,
-		private readonly httpService: HttpService
-	) {}
+		private readonly httpService: HttpService,
+		private readonly logger: LegacyLogger
+	) {
+		this.logger.setContext(RocketChatService.name);
+	}
 
 	public async me(authToken: string, userId: string): Promise<GenericData> {
 		return this.get('/api/v1/me', authToken, userId);
@@ -181,9 +185,14 @@ export class RocketChatService {
 	}
 
 	public async deleteUser(username: string): Promise<GenericData> {
-		return this.postAsAdmin('/api/v1/users.delete', {
+		this.logger.log({ action: 'Deleting user Data from RocketChat Service for user ', username });
+		const deletedUser: Promise<GenericData> = this.postAsAdmin('/api/v1/users.delete', {
 			username,
 		});
+
+		this.logger.log({ action: 'Deleting user Data from RocketChat Service for user ', username });
+
+		return deletedUser;
 	}
 
 	private async postAsAdmin(path: string, body: GenericData): Promise<GenericData> {

apps/server/src/modules/user/service/user.service.spec.ts

@@ -13,10 +13,10 @@ import { UserRepo } from '@shared/repo';
 import { UserDORepo } from '@shared/repo/user/user-do.repo';
 import { roleFactory, setupEntities, userDoFactory, userFactory } from '@shared/testing';
 import { ObjectId } from '@mikro-orm/mongodb';
+import { LegacyLogger } from '@src/core/logger';
 import { UserDto } from '../uc/dto/user.dto';
 import { UserQuery } from './user-query.type';
 import { UserService } from './user.service';
-import { LegacyLogger } from '@src/core/logger';
 
 describe('UserService', () => {
 	let service: UserService;