configuration module

.env.dist

@@ -1,6 +1,7 @@
 # SERVICE
 SERVICE_URL=0.0.0.0
 SERVICE_PORT=5001
+SERVICE_CONFIGURATION_DOMAIN=USER
 
 # PRISMA
 DATABASE_URL="postgresql://user:user@v3-user-db:5432/user?schema=public"
@@ -13,3 +14,5 @@ POSTGRES_IMAGE=postgres:15.0
 
 # REDIS
 REDIS_IMAGE=redis/redis-stack:latest
+REDIS_HOST=v3-user-redis
+REDIS_PORT=6379

.env.test

@@ -1,6 +1,7 @@
 # SERVICE
 SERVICE_URL=0.0.0.0
 SERVICE_PORT=5001
+SERVICE_CONFIGURATION_DOMAIN=USER
 
 # PRISMA
 DATABASE_URL="postgresql://user:user@localhost:5601/user?schema=public"
@@ -13,3 +14,5 @@ POSTGRES_IMAGE=postgres:15.0
 
 # REDIS
 REDIS_IMAGE=redis/redis-stack:latest
+REDIS_HOST=v3-user-redis
+REDIS_PORT=6379

package.json

@@ -21,6 +21,7 @@
     "test:integration:ci": "npm run migrate:test:ci && dotenv -e ci/.env.ci -- jest --testPathPattern 'tests/integration/'",
     "test:cov": "jest --testPathPattern 'tests/unit/' --coverage",
     "test:e2e": "jest --config ./test/jest-e2e.json",
+    "generate": "docker exec v3-user sh -c 'npx prisma generate'",
     "migrate": "docker exec v3-user sh -c 'npx prisma migrate dev'",
     "migrate:test": "dotenv -e .env.test -- npx prisma migrate deploy",
     "migrate:test:ci": "dotenv -e ci/.env.ci -- npx prisma migrate deploy"

src/modules/configuration/adapters/primaries/configuration-messager.controller.ts

@@ -21,6 +21,10 @@ export class ConfigurationMessagerController {
   })
   public async setConfigurationHandler(message: string) {
     const configuration = JSON.parse(message);
+    if (
+      configuration.domain ==
+      this._configService.get<string>('SERVICE_CONFIGURATION_DOMAIN')
+    ) {
       const setConfigurationRequest: SetConfigurationRequest =
         new SetConfigurationRequest();
       setConfigurationRequest.domain = configuration.domain;
@@ -30,6 +34,7 @@ export class ConfigurationMessagerController {
         new SetConfigurationCommand(setConfigurationRequest),
       );
     }
+  }
 
   @RabbitSubscribe({
     exchange: 'configuration',
@@ -38,6 +43,10 @@ export class ConfigurationMessagerController {
   })
   public async configurationDeletedHandler(message: string) {
     const deletedConfiguration = JSON.parse(message);
+    if (
+      deletedConfiguration.domain ==
+      this._configService.get<string>('SERVICE_CONFIGURATION_DOMAIN')
+    ) {
       const deleteConfigurationRequest = new DeleteConfigurationRequest();
       deleteConfigurationRequest.domain = deletedConfiguration.domain;
       deleteConfigurationRequest.key = deletedConfiguration.key;
@@ -45,4 +54,5 @@ export class ConfigurationMessagerController {
         new DeleteConfigurationCommand(deleteConfigurationRequest),
       );
     }
+  }
 }

src/modules/configuration/configuration.module.ts

@@ -1,8 +1,11 @@
+import { RabbitMQModule } from '@golevelup/nestjs-rabbitmq';
 import { RedisModule, RedisModuleOptions } from '@liaoliaots/nestjs-redis';
 import { Module } from '@nestjs/common';
 import { ConfigModule, ConfigService } from '@nestjs/config';
 import { CqrsModule } from '@nestjs/cqrs';
+import { ConfigurationMessagerController } from './adapters/primaries/configuration-messager.controller';
 import { RedisConfigurationRepository } from './adapters/secondaries/redis-configuration.repository';
+import { DeleteConfigurationUseCase } from './domain/usecases/delete-configuration.usecase';
 import { GetConfigurationUseCase } from './domain/usecases/get-configuration.usecase';
 import { SetConfigurationUseCase } from './domain/usecases/set-configuration.usecase';
 
@@ -23,11 +26,27 @@ import { SetConfigurationUseCase } from './domain/usecases/set-configuration.use
         };
       },
     }),
+    RabbitMQModule.forRootAsync(RabbitMQModule, {
+      imports: [ConfigModule],
+      useFactory: async (configService: ConfigService) => ({
+        exchanges: [
+          {
+            name: 'configuration',
+            type: 'topic',
+          },
         ],
-  controllers: [],
+        uri: configService.get<string>('RMQ_URI'),
+        connectionInitOptions: { wait: false },
+        enableControllerDiscovery: true,
+      }),
+      inject: [ConfigService],
+    }),
+  ],
+  controllers: [ConfigurationMessagerController],
   providers: [
     GetConfigurationUseCase,
     SetConfigurationUseCase,
+    DeleteConfigurationUseCase,
     RedisConfigurationRepository,
   ],
 })