Integrate RabbitMQWrapperModule into deletion-console and files-stora…

…ge-client modules
hpi-schul-cloud · Feb 5, 2025 · 988adde · 988adde
1 parent 0958e65
commit 988adde
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 1 deletion.
diff --git a/apps/server/src/modules/deletion-console/deletion-console.app.module.ts b/apps/server/src/modules/deletion-console/deletion-console.app.module.ts
@@ -1,5 +1,6 @@
 import { DB_PASSWORD, DB_URL, DB_USERNAME } from '@imports-from-feathers';
 import { ConsoleWriterModule } from '@infra/console';
+import { RabbitMQWrapperModule } from '@infra/rabbitmq';
 import { MikroOrmModule } from '@mikro-orm/nestjs';
 import { AccountModule } from '@modules/account';
 import { UserModule } from '@modules/user';
@@ -33,6 +34,7 @@ import { BatchDeletionUc, DeletionExecutionUc } from './uc';
 			entities: ENTITIES,
 			// debug: true, // use it for locally debugging of queries
 		}),
+		RabbitMQWrapperModule,
 		AccountModule,
 		HttpModule,
 	],

diff --git a/apps/server/src/modules/deletion-console/deletion-execution.console.spec.ts b/apps/server/src/modules/deletion-console/deletion-execution.console.spec.ts
@@ -1,5 +1,6 @@
 import { DeepMocked } from '@golevelup/ts-jest';
 import { MongoMemoryDatabaseModule } from '@infra/database';
+import { RabbitMQWrapperTestModule } from '@infra/rabbitmq';
 import { Test, TestingModule } from '@nestjs/testing';
 import { defaultMikroOrmOptions } from '@shared/common/defaultMikroOrmOptions';
 import { DeletionExecutionTriggerResultBuilder, TriggerDeletionExecutionOptionsBuilder } from './builder';
@@ -18,6 +19,7 @@ describe(DeletionExecutionConsole.name, () => {
 			imports: [
 				DeletionConsoleModule,
 				MongoMemoryDatabaseModule.forRoot({ ...defaultMikroOrmOptions, entities: TEST_ENTITIES }),
+				RabbitMQWrapperTestModule,
 			],
 		}).compile();
 

diff --git a/apps/server/src/modules/deletion-console/deletion-queue.console.spec.ts b/apps/server/src/modules/deletion-console/deletion-queue.console.spec.ts
@@ -1,4 +1,5 @@
 import { MongoMemoryDatabaseModule } from '@infra/database';
+import { RabbitMQWrapperTestModule } from '@infra/rabbitmq';
 import { Test, TestingModule } from '@nestjs/testing';
 import { defaultMikroOrmOptions } from '@shared/common/defaultMikroOrmOptions';
 import { ObjectId } from 'bson';
@@ -20,6 +21,7 @@ describe(DeletionQueueConsole.name, () => {
 			imports: [
 				DeletionConsoleModule,
 				MongoMemoryDatabaseModule.forRoot({ ...defaultMikroOrmOptions, entities: TEST_ENTITIES }),
+				RabbitMQWrapperTestModule,
 			],
 		}).compile();
 

diff --git a/apps/server/src/modules/files-storage-client/files-storage-client.module.ts b/apps/server/src/modules/files-storage-client/files-storage-client.module.ts
@@ -1,11 +1,12 @@
 import { LoggerModule } from '@core/logger';
 import { Module } from '@nestjs/common';
 // The files-storage-client should not know the copy-helper
+import { RabbitMQWrapperModule } from '@infra/rabbitmq';
 import { CopyHelperModule } from '@modules/copy-helper/copy-helper.module';
 import { CopyFilesService, FilesStorageClientAdapterService, FilesStorageProducer } from './service';
 
 @Module({
-	imports: [LoggerModule, CopyHelperModule],
+	imports: [LoggerModule, CopyHelperModule, RabbitMQWrapperModule],
 	providers: [FilesStorageClientAdapterService, CopyFilesService, FilesStorageProducer],
 	exports: [FilesStorageClientAdapterService, CopyFilesService],
 })