feat(microservices-shared-rmq): create RMQ helper lib

getlarge · Dec 13, 2023 · 5b67f6b · 5b67f6b
1 parent 893452e
commit 5b67f6b
Show file tree

Hide file tree

Showing 26 changed files with 134 additions and 269 deletions.
diff --git a/apps/expiration/src/app/orders/orders.module.ts b/apps/expiration/src/app/orders/orders.module.ts
@@ -10,6 +10,7 @@ import {
   type AmqpOptions,
   AmqpClient,
 } from '@s1seven/nestjs-tools-amqp-transport';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { Services } from '@ticketing/shared/constants';
 
 import { AppConfigService } from '../env';
@@ -40,7 +41,10 @@ import { OrdersMSController } from './orders-ms.controller';
               exclusive: false,
               autoDelete: false,
             },
-            replyQueue: `${Services.ORDERS_SERVICE}_REPLY_${Services.EXPIRATION_SERVICE}_QUEUE`,
+            replyQueue: getReplyQueueName(
+              Services.ORDERS_SERVICE,
+              Services.EXPIRATION_SERVICE,
+            ),
             replyQueueOptions: {
               durable: true,
               exclusive: true,

diff --git a/apps/orders/src/app/orders/orders.module.ts b/apps/orders/src/app/orders/orders.module.ts
@@ -11,6 +11,7 @@ import { OryModule } from '@ticketing/microservices/ory-client';
 import { PassportModule } from '@ticketing/microservices/shared/fastify-passport';
 import { GlobalErrorFilter } from '@ticketing/microservices/shared/filters';
 import { JwtStrategy } from '@ticketing/microservices/shared/guards';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { CURRENT_USER_KEY, Services } from '@ticketing/shared/constants';
 
 import { AppConfigService } from '../env';
@@ -35,7 +36,7 @@ const clientFactory = (
     prefetchCount: configService.get('RMQ_PREFETCH_COUNT'),
     isGlobalPrefetchCount: false,
     queue: `${consumerService}_QUEUE`,
-    replyQueue: `${consumerService}_REPLY_${Services.TICKETS_SERVICE}_QUEUE`,
+    replyQueue: getReplyQueueName(consumerService, Services.TICKETS_SERVICE),
     queueOptions: {
       durable: true,
       exclusive: false,

diff --git a/apps/orders/test/tickets-ms.e2e-spec.ts b/apps/orders/test/tickets-ms.e2e-spec.ts
@@ -13,6 +13,7 @@ import { AmqpClient, AmqpServer } from '@s1seven/nestjs-tools-amqp-transport';
 import { loadEnv, validate } from '@ticketing/microservices/shared/env';
 import { Patterns } from '@ticketing/microservices/shared/events';
 import { GlobalErrorFilter } from '@ticketing/microservices/shared/filters';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { Services } from '@ticketing/shared/constants';
 import { Model, Types } from 'mongoose';
 import { delay, lastValueFrom } from 'rxjs';
@@ -63,7 +64,10 @@ describe('TicketsMSController (e2e)', () => {
       prefetchCount: 1,
       isGlobalPrefetchCount: false,
       queue: `${Services.ORDERS_SERVICE}_QUEUE`,
-      replyQueue: `${Services.ORDERS_SERVICE}_REPLY_${Services.TICKETS_SERVICE}_QUEUE`,
+      replyQueue: getReplyQueueName(
+        Services.ORDERS_SERVICE,
+        Services.TICKETS_SERVICE,
+      ),
       queueOptions: {
         durable: false,
         exclusive: false,

diff --git a/apps/payments/src/app/payments/payments.module.ts b/apps/payments/src/app/payments/payments.module.ts
@@ -12,6 +12,7 @@ import { OryModule } from '@ticketing/microservices/ory-client';
 import { PassportModule } from '@ticketing/microservices/shared/fastify-passport';
 import { GlobalErrorFilter } from '@ticketing/microservices/shared/filters';
 import { JwtStrategy } from '@ticketing/microservices/shared/guards';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { CURRENT_USER_KEY, Services } from '@ticketing/shared/constants';
 import { updateIfCurrentPlugin } from 'mongoose-update-if-current';
 
@@ -61,7 +62,10 @@ const MongooseFeatures = MongooseModule.forFeatureAsync([
             prefetchCount: configService.get('RMQ_PREFETCH_COUNT'),
             isGlobalPrefetchCount: false,
             queue: `${Services.ORDERS_SERVICE}_QUEUE`,
-            replyQueue: `${Services.ORDERS_SERVICE}_REPLY_${Services.PAYMENTS_SERVICE}_QUEUE`,
+            replyQueue: getReplyQueueName(
+              Services.ORDERS_SERVICE,
+              Services.PAYMENTS_SERVICE,
+            ),
             queueOptions: {
               durable: true,
               exclusive: false,

diff --git a/apps/tickets/src/app/tickets/tickets.module.ts b/apps/tickets/src/app/tickets/tickets.module.ts
@@ -12,6 +12,7 @@ import { OryModule } from '@ticketing/microservices/ory-client';
 import { PassportModule } from '@ticketing/microservices/shared/fastify-passport';
 import { GlobalErrorFilter } from '@ticketing/microservices/shared/filters';
 import { JwtStrategy } from '@ticketing/microservices/shared/guards';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { CURRENT_USER_KEY, Services } from '@ticketing/shared/constants';
 import { updateIfCurrentPlugin } from 'mongoose-update-if-current';
 
@@ -45,7 +46,10 @@ const OrdersClient = ClientsModule.registerAsync([
         prefetchCount: configService.get('RMQ_PREFETCH_COUNT'),
         isGlobalPrefetchCount: false,
         queue: `${Services.ORDERS_SERVICE}_QUEUE`,
-        replyQueue: `${Services.ORDERS_SERVICE}_REPLY_${Services.TICKETS_SERVICE}_QUEUE`,
+        replyQueue: getReplyQueueName(
+          Services.ORDERS_SERVICE,
+          Services.TICKETS_SERVICE,
+        ),
         queueOptions: {
           durable: true,
           exclusive: false,

diff --git a/apps/tickets/test/orders-ms.e2e-spec.ts b/apps/tickets/test/orders-ms.e2e-spec.ts
@@ -13,6 +13,7 @@ import { AmqpClient, AmqpServer } from '@s1seven/nestjs-tools-amqp-transport';
 import { loadEnv, validate } from '@ticketing/microservices/shared/env';
 import { Patterns } from '@ticketing/microservices/shared/events';
 import { GlobalErrorFilter } from '@ticketing/microservices/shared/filters';
+import { getReplyQueueName } from '@ticketing/microservices/shared/rmq';
 import { Services } from '@ticketing/shared/constants';
 import { Types } from 'mongoose';
 import { delay, lastValueFrom } from 'rxjs';
@@ -60,7 +61,10 @@ describe('OrdersMSController (e2e)', () => {
       prefetchCount: 1,
       isGlobalPrefetchCount: false,
       queue: `${Services.TICKETS_SERVICE}_QUEUE`,
-      replyQueue: `${Services.TICKETS_SERVICE}_REPLY_${Services.TICKETS_SERVICE}_QUEUE`,
+      replyQueue: getReplyQueueName(
+        Services.TICKETS_SERVICE,
+        Services.ORDERS_SERVICE,
+      ),
       queueOptions: {
         durable: false,
         exclusive: false,

diff --git a/libs/microservices/shared/nats-streaming/.babelrc b/libs/microservices/shared/nats-streaming/.babelrc
diff --git a/libs/microservices/shared/nats-streaming/README.md b/libs/microservices/shared/nats-streaming/README.md
diff --git a/libs/microservices/shared/nats-streaming/jest.config.ts b/libs/microservices/shared/nats-streaming/jest.config.ts
diff --git a/libs/microservices/shared/nats-streaming/project.json b/libs/microservices/shared/nats-streaming/project.json
diff --git a/libs/microservices/shared/nats-streaming/src/index.ts b/libs/microservices/shared/nats-streaming/src/index.ts
diff --git a/libs/microservices/shared/nats-streaming/src/nats-streaming.config.ts b/libs/microservices/shared/nats-streaming/src/nats-streaming.config.ts
diff --git a/libs/microservices/shared/nats-streaming/src/nats-streaming.healthcheck.ts b/libs/microservices/shared/nats-streaming/src/nats-streaming.healthcheck.ts
diff --git a/libs/microservices/shared/nats-streaming/src/nats-streaming.publisher.ts b/libs/microservices/shared/nats-streaming/src/nats-streaming.publisher.ts
diff --git a/libs/microservices/shared/nats-streaming/tsconfig.json b/libs/microservices/shared/nats-streaming/tsconfig.json
diff --git a/libs/microservices/shared/nats-streaming/tsconfig.lib.json b/libs/microservices/shared/nats-streaming/tsconfig.lib.json
diff --git a/...ices/shared/nats-streaming/.eslintrc.json → libs/microservices/shared/rmq/.eslintrc.json b/...ices/shared/nats-streaming/.eslintrc.json → libs/microservices/shared/rmq/.eslintrc.json
diff --git a/libs/microservices/shared/rmq/README.md b/libs/microservices/shared/rmq/README.md
@@ -0,0 +1,7 @@
+# microservices-shared-rmq
+
+This library was generated with [Nx](https://nx.dev).
+
+## Running unit tests
+
+Run `nx test microservices-shared-rmq` to execute the unit tests via [Jest](https://jestjs.io).