[FEATURE/CROW-308] Add connection to new queue to receive mint data

src/common/constants/index.ts

@@ -4,3 +4,5 @@ export const DEFAULT_PAGE_SIZE = 20;
 export const DEFAULT_PAGE = 1;
 
 export const TOKEN_EXPIRATION_TIME = '30d';
+
+export const MINT_MANAGEMENT_QUEUE = 'mint_management';

src/common/rabbitmq/index.ts

@@ -1,6 +1,12 @@
 import { ConfigService } from '@nestjs/config';
-import { ClientsProviderAsyncOptions, Transport } from '@nestjs/microservices';
+import { NestFactory } from '@nestjs/core';
+import {
+  ClientsProviderAsyncOptions,
+  MicroserviceOptions,
+  Transport,
+} from '@nestjs/microservices';
 
+import { AppModule } from 'src/app.module';
 import {
   NFT_GENERATION_QUEUE,
   RABBITMQ_SERVICE_NAME,
@@ -22,3 +28,15 @@ export const rabbitmqConnectionFactory = {
   }),
   inject: [ConfigService],
 } as ClientsProviderAsyncOptions;
+
+export const createRMQMicroservice = (queueName: string) => {
+  return NestFactory.createMicroservice<MicroserviceOptions>(AppModule, {
+    transport: Transport.RMQ,
+    options: {
+      urls: ['amqp://admin:admin@localhost:5672'], // TODO: Change path
+      queue: queueName,
+      prefetchCount: 1,
+      queueOptions: { durable: false },
+    },
+  });
+};

src/features/campaigns/controllers/campaign-pledge/campaigns-pledge.controller.ts

@@ -1,9 +1,11 @@
 import { Controller, Get, Query } from '@nestjs/common';
+import { EventPattern } from '@nestjs/microservices';
 
 import { CampaignPledgeService } from '../../services/campaign-pledge/campaign-pledge.service';
 import { APIResponse } from 'src/common/types';
 import { CampaignPledgeQueryDto } from '../../dto/campaigns-pledge-query-dto';
 import { CurrentUser } from 'src/decorators/currentUser.decorator';
+import { MINT_MANAGEMENT_QUEUE } from 'src/common/constants';
 
 @Controller('campaigns-pledge')
 export class CampaignsPledgeController {
@@ -25,4 +27,9 @@ export class CampaignsPledgeController {
     });
     return { data: campaigns };
   }
+
+  @EventPattern(MINT_MANAGEMENT_QUEUE)
+  async handleNftGeneration(data) {
+    console.log('Received data: ', data);
+  }
 }

src/main.ts

@@ -7,13 +7,18 @@ import mongoose from 'mongoose';
 import { AppModule } from './app.module';
 import { AllExceptionsFilter } from './middlewares/filters/exception.filter';
 import { JwtAuthGuard } from './features/auth/guards/auth.guard';
+import { createRMQMicroservice } from './common/rabbitmq';
+import { MINT_MANAGEMENT_QUEUE } from './common/constants';
 
 const { API_PORT, NODE_ENV } = process.env;
 
 async function bootstrap() {
   const isProductionEnv = NODE_ENV === 'production';
   const app = await NestFactory.create(AppModule);
   const adapterHost = app.get(HttpAdapterHost);
+  const mintManagementChannel = await createRMQMicroservice(
+    MINT_MANAGEMENT_QUEUE,
+  );
 
   app.use(helmet());
   app.use(morgan('combined'));
@@ -39,6 +44,9 @@ async function bootstrap() {
 
     await app.listen(API_PORT);
     console.log(`NestJS API listening on port ${API_PORT}`);
+
+    await mintManagementChannel.listen();
+    console.log('Listening to mint management channel');
   } catch (err) {
     console.log('Error starting app!', err);
     process.exit(1);