Add Bull queue and board for listing module

- Integrate BullModule and BullBoardModule in QueueModule
- Set up Redis connection for Bull queues
- Add ListingProducer and ListingConsumer in ListingModule
- Configure BullBoardModule for listing queue monitoring
- Update LoggerMiddleware to skip logging for queue routes
- Add new dependencies for Bull and Bull Board in package.json

Author: jfjuanmiguel

package.json

@@ -29,6 +29,9 @@
     "db:studio": "npx prisma studio"
   },
   "dependencies": {
+    "@bull-board/api": "^5.21.4",
+    "@bull-board/express": "^5.21.4",
+    "@bull-board/nestjs": "^5.21.4",
     "@nestjs/bull": "^10.2.1",
     "@nestjs/cache-manager": "^2.2.2",
     "@nestjs/common": "^10.0.0",

pnpm-lock.yaml

@@ -12,7 +12,8 @@ export class LoggerMiddleware implements NestMiddleware {
 
   use(req: Request, res: Response, next: NextFunction) {
     const environment = this.configService.get(`environment`);
-    if (environment === `test`) {
+    const isQueueRoute = req.url.startsWith('/queues');
+    if (environment === `test` || isQueueRoute) {
       return next();
     }
     const start = Date.now();

src/core/logger/logger.middleware.ts

@@ -1,6 +1,8 @@
 import { Module } from '@nestjs/common';
 import { BullModule } from '@nestjs/bull';
 import { ConfigModule, ConfigService } from '@nestjs/config';
+import { BullBoardModule } from '@bull-board/nestjs';
+import { ExpressAdapter } from '@bull-board/express';
 
 @Module({
   imports: [
@@ -20,6 +22,10 @@ import { ConfigModule, ConfigService } from '@nestjs/config';
       },
       inject: [ConfigService],
     }),
+    BullBoardModule.forRoot({
+      route: `/queues`,
+      adapter: ExpressAdapter,
+    }),
   ],
 })
 export class QueueModule {}

src/core/queue/queue.module.ts

@@ -2,12 +2,20 @@ import { Module } from '@nestjs/common';
 import { ListingService } from './listing.service';
 import { ListingController } from './listing.controller';
 import { BullModule } from '@nestjs/bull';
-import { ListingConsumer } from './queue/listing.consumer';
 import { ListingProducer } from './queue/listing.producer';
+import { ListingConsumer } from './queue/listing.consumer';
 import { LISTING_QUEUE } from '../../core/queue/queue.constants';
+import { BullBoardModule } from '@bull-board/nestjs';
+import { BullAdapter } from '@bull-board/api/bullAdapter';
 
 @Module({
-  imports: [BullModule.registerQueue({ name: LISTING_QUEUE })],
+  imports: [
+    BullModule.registerQueue({ name: LISTING_QUEUE }),
+    BullBoardModule.forFeature({
+      name: LISTING_QUEUE,
+      adapter: BullAdapter,
+    }),
+  ],
   controllers: [ListingController],
   providers: [ListingService, ListingProducer, ListingConsumer],
 })