Bullui #46 (#61)

* setup bull board and controller

* add panel

* basic bull board enabled

apps/api/src/api.controller.ts

@@ -1,6 +1,7 @@
 import { Body, Controller, Delete, Get, HttpCode, HttpStatus, Logger, Param, ParseFilePipeBuilder, Post, Put, UploadedFiles, UseInterceptors } from '@nestjs/common';
 import { FilesInterceptor } from '@nestjs/platform-express';
 import { ApiBody, ApiConsumes } from '@nestjs/swagger';
+import { BullBoardInstance, InjectBullBoard } from '@bull-board/nestjs';
 import { ApiService } from './api.service';
 import {
   AnnouncementResponseDto,
@@ -22,10 +23,18 @@ import {
 export class ApiController {
   private readonly logger: Logger;
 
-  constructor(private apiService: ApiService) {
+  constructor(
+    private apiService: ApiService,
+    @InjectBullBoard() private readonly bullBoard: BullBoardInstance,
+  ) {
     this.logger = new Logger(this.constructor.name);
   }
 
+  @Get('bull-board')
+  async getBullBoard() {
+    return this.bullBoard;
+  }
+
   // eslint-disable-next-line class-methods-use-this
   @Get('health')
   health() {

apps/api/src/api.module.ts

@@ -3,6 +3,9 @@ import { EventEmitterModule } from '@nestjs/event-emitter';
 import { BullModule } from '@nestjs/bullmq';
 import { ScheduleModule } from '@nestjs/schedule';
 import { RedisModule } from '@liaoliaots/nestjs-redis';
+import { BullBoardModule } from '@bull-board/nestjs';
+import { BullMQAdapter } from '@bull-board/api/bullMQAdapter';
+import { ExpressAdapter } from '@bull-board/express';
 import { ApiController } from './api.controller';
 import { DevelopmentController } from './development.controller';
 import { QueueConstants } from '../../../libs/common/src';
@@ -18,6 +21,10 @@ import { ConfigService } from '../../../libs/common/src/config/config.service';
         enableOfflineQueue: false,
       },
     }),
+    BullBoardModule.forRoot({
+      route: '/queues',
+      adapter: ExpressAdapter,
+    }),
     BullModule.registerQueue({
       name: QueueConstants.REQUEST_QUEUE_NAME,
     }),
@@ -42,6 +49,60 @@ import { ConfigService } from '../../../libs/common/src/config/config.service';
     BullModule.registerQueue({
       name: QueueConstants.PROFILE_QUEUE_NAME,
     }),
+    BullModule.registerQueue({
+      name: QueueConstants.BATCH_QUEUE_NAME,
+    }),
+    BullModule.registerQueue({
+      name: QueueConstants.STATUS_QUEUE_NAME,
+    }),
+    BullModule.registerQueue({
+      name: QueueConstants.TRANSACTION_RECEIPT_QUEUE_NAME,
+    }),
+
+    BullBoardModule.forFeature({
+      name: QueueConstants.REQUEST_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.ASSET_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.BROADCAST_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.REPLY_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.REACTION_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.TOMBSTONE_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.UPDATE_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.PROFILE_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.BATCH_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.STATUS_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
+    BullBoardModule.forFeature({
+      name: QueueConstants.TRANSACTION_RECEIPT_QUEUE_NAME,
+      adapter: BullMQAdapter,
+    }),
     ConfigModule,
     RedisModule.forRootAsync(
       {