Feat/support multiple nats url (#805)

* wip: nats configuration Signed-off-by: bhavanakarwade <[email protected]> * refactor: nats config function Signed-off-by: bhavanakarwade <[email protected]> * wip: implemented nats queue functionality Signed-off-by: bhavanakarwade <[email protected]> * wip: implemented nats queue functionality Signed-off-by: bhavanakarwade <[email protected]> * wip: nats queue configurations Signed-off-by: bhavanakarwade <[email protected]> * feat: support nats queue Signed-off-by: bhavanakarwade <[email protected]> * fix: add logger Signed-off-by: bhavanakarwade <[email protected]> * refactor: added logger Signed-off-by: bhavanakarwade <[email protected]> * fix: remove unnecessary logs Signed-off-by: bhavanakarwade <[email protected]> * fix: added optional parameter Signed-off-by: bhavanakarwade <[email protected]> * feat: implement nats queue Signed-off-by: bhavanakarwade <[email protected]> * refactor: added geo-service queue Signed-off-by: bhavanakarwade <[email protected]> --------- Signed-off-by: bhavanakarwade <[email protected]> Signed-off-by: KulkarniShashank <[email protected]>
credebl · Sep 11, 2024 · 3bf3a5e · 3bf3a5e
1 parent 3a99d28
commit 3bf3a5e
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/apps/api-gateway/src/geo-location/geo-location.module.ts b/apps/api-gateway/src/geo-location/geo-location.module.ts
@@ -8,6 +8,7 @@ import { getNatsOptions } from '@credebl/common/nats.config';
 import { CommonModule } from '@credebl/common';
 import { RateLimiterModule, RateLimiterGuard } from 'nestjs-rate-limiter';
 import { APP_GUARD } from '@nestjs/core';
+import { CommonConstants } from '@credebl/common/common.constant';
 
 @Module({
   imports: [
@@ -17,7 +18,7 @@ import { APP_GUARD } from '@nestjs/core';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(process.env.API_GATEWAY_NKEY_SEED)
+        options: getNatsOptions(CommonConstants.GEO_LOCATION_SERVICE, process.env.API_GATEWAY_NKEY_SEED)
       },
       CommonModule
     ]),

diff --git a/apps/geo-location/src/geo-location.module.ts b/apps/geo-location/src/geo-location.module.ts
@@ -7,14 +7,15 @@ import { CacheModule } from '@nestjs/cache-manager';
 import { getNatsOptions } from '@credebl/common/nats.config';
 import { PrismaService } from '@credebl/prisma-service';
 import { GeoLocationRepository } from './geo-location.repository';
+import { CommonConstants } from '@credebl/common/common.constant';
 
 @Module({
   imports: [
     ClientsModule.register([
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(process.env.GEOLOCATION_NKEY_SEED)
+        options: getNatsOptions(CommonConstants.GEO_LOCATION_SERVICE, process.env.GEOLOCATION_NKEY_SEED)
       }
     ]),
     CommonModule,

diff --git a/apps/geo-location/src/main.ts b/apps/geo-location/src/main.ts
@@ -4,13 +4,14 @@ import { NestFactory } from '@nestjs/core';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { getNatsOptions } from '@credebl/common/nats.config';
 import { GeoLocationModule } from './geo-location.module';
+import { CommonConstants } from '@credebl/common/common.constant';
 
 const logger = new Logger();
 
 async function bootstrap(): Promise<void> {
   const app = await NestFactory.createMicroservice<MicroserviceOptions>(GeoLocationModule, {
     transport: Transport.NATS,
-    options: getNatsOptions(process.env.GEOLOCATION_NKEY_SEED)
+    options: getNatsOptions(CommonConstants.GEO_LOCATION_SERVICE, process.env.GEOLOCATION_NKEY_SEED)
   });
   app.useGlobalFilters(new HttpExceptionFilter());
 

diff --git a/libs/common/src/common.constant.ts b/libs/common/src/common.constant.ts
@@ -338,7 +338,8 @@ ISSUANCE_SERVICE = 'issuance',
 VERIFICATION_SERVICE = 'verification',
 ECOSYSTEM_SERVICE = 'ecosystem',
 WEBHOOK_SERVICE = 'webhook',
-NOTIFICATION_SERVICE = 'notification'
+NOTIFICATION_SERVICE = 'notification',
+GEO_LOCATION_SERVICE = 'geo-location'
 }
 
 export const postgresqlErrorCodes = [];