feat: Added support for jwt based auth for NATS

Signed-off-by: RinkalBhojani <rinkal.bhojani@ayanworks.com>

Author: RinkalBhojani

.env.demo

@@ -246,4 +246,10 @@ AGGREGATE_STREAM=aggregate
 DID_STREAM=did-notify
 PULL_CONSUMER=hub-pull-consumer
 
-NATS_CREDS_FILE=
+NATS_CREDS_FILE=
+# 'nkey' | 'creds' | 'usernamePassword' | 'none'
+NATS_AUTH_TYPE=nkey 
+# 'nkey' | 'creds' | 'usernamePassword' | 'none'
+NOTIFICATION_NATS_AUTH_TYPE= 
+
+ENABLE_NATS_NOTIFICATION=false

.env.sample

@@ -274,4 +274,10 @@ AGGREGATE_STREAM=aggregate
 DID_STREAM=did-notify
 PULL_CONSUMER=hub-pull-consumer
 
-NATS_CREDS_FILE=/platform/app_user.creds
+NATS_CREDS_FILE=/platform/app_user.creds
+# 'nkey' | 'creds' | 'usernamePassword' | 'none'
+NATS_AUTH_TYPE=nkey 
+# 'nkey' | 'creds' | 'usernamePassword' | 'none'
+NOTIFICATION_NATS_AUTH_TYPE= 
+
+ENABLE_NATS_NOTIFICATION=false

apps/agent-provisioning/src/agent-provisioning.module.ts

@@ -20,7 +20,11 @@ import { ConfigModule as PlatformConfig } from '@credebl/config/config.module';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.AGENT_PROVISIONING, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.AGENT_PROVISIONING,
+          process.env.AGENT_PROVISIONING_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       }
     ])
   ],

apps/agent-provisioning/src/main.ts

@@ -11,7 +11,11 @@ const logger = new Logger();
 async function bootstrap(): Promise<void> {
   const app = await NestFactory.createMicroservice<MicroserviceOptions>(AgentProvisioningModule, {
     transport: Transport.NATS,
-    options: getNatsOptions(CommonConstants.AGENT_PROVISIONING, process.env.NATS_CREDS_FILE)
+    options: getNatsOptions(
+      CommonConstants.AGENT_PROVISIONING,
+      process.env.AGENT_PROVISIONING_NKEY_SEED,
+      process.env.NATS_CREDS_FILE
+    )
   });
   app.useLogger(app.get(NestjsLoggerServiceAdapter));
   app.useGlobalFilters(new HttpExceptionFilter());

apps/agent-service/src/agent-service.module.ts

@@ -30,7 +30,11 @@ import { APP_INTERCEPTOR } from '@nestjs/core';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.AGENT_SERVICE, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.AGENT_SERVICE,
+          process.env.AGENT_SERVICE_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       }
     ]),
     CommonModule,

apps/agent-service/src/main.ts

@@ -15,7 +15,11 @@ const logger = new Logger();
 async function bootstrap(): Promise<void> {
   const app = await NestFactory.createMicroservice<MicroserviceOptions>(AgentServiceModule, {
     transport: Transport.NATS,
-    options: getNatsOptions(CommonConstants.AGENT_SERVICE, process.env.NATS_CREDS_FILE)
+    options: getNatsOptions(
+      CommonConstants.AGENT_SERVICE,
+      process.env.AGENT_SERVICE_NKEY_SEED,
+      process.env.NATS_CREDS_FILE
+    )
   });
   app.useLogger(app.get(NestjsLoggerServiceAdapter));
   app.useGlobalFilters(new HttpExceptionFilter());

apps/api-gateway/src/agent-service/agent-service.module.ts

@@ -18,7 +18,11 @@ import { NATSClient } from '@credebl/common/NATSClient';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.AGENT_SERVICE, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.AGENT_SERVICE,
+          process.env.API_GATEWAY_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       },
       CommonModule
     ])

apps/api-gateway/src/app.module.ts

@@ -49,7 +49,11 @@ import { shouldLoadOidcModules } from '@credebl/common/common.utils';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.API_GATEWAY_SERVICE, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.API_GATEWAY_SERVICE,
+          process.env.API_GATEWAY_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       }
     ]),
     AgentModule,

apps/api-gateway/src/authz/authz.module.ts

@@ -36,7 +36,11 @@ import { getNatsOptions } from '@credebl/common/nats.config';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.AUTH_SERVICE, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.AUTH_SERVICE,
+          process.env.API_GATEWAY_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       },
       CommonModule
     ]),

apps/api-gateway/src/cloud-wallet/cloud-wallet.module.ts

@@ -12,7 +12,11 @@ import { NATSClient } from '@credebl/common/NATSClient';
       {
         name: 'NATS_CLIENT',
         transport: Transport.NATS,
-        options: getNatsOptions(CommonConstants.CLOUD_WALLET_SERVICE, process.env.NATS_CREDS_FILE)
+        options: getNatsOptions(
+          CommonConstants.CLOUD_WALLET_SERVICE,
+          process.env.API_GATEWAY_NKEY_SEED,
+          process.env.NATS_CREDS_FILE
+        )
       }
     ])
   ],