From b55fe075117c0286a0aef7db5c5616b57a532d87 Mon Sep 17 00:00:00 2001
From: Henry Heng <henryheng@flowiseai.com>
Date: Sun, 4 May 2025 21:55:16 +0800
Subject: [PATCH] Feature/add enable bull dashboard env var (#4373)

add enable bull dashboard env var
---
 docker/.env.example                  | 3 ++-
 docker/docker-compose.yml            | 1 +
 docker/worker/docker-compose.yml     | 1 +
 packages/server/.env.example         | 1 +
 packages/server/src/commands/base.ts | 4 +++-
 packages/server/src/index.ts         | 2 +-
 6 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/docker/.env.example b/docker/.env.example
index 3f760e2de..3efdd7f03 100644
--- a/docker/.env.example
+++ b/docker/.env.example
@@ -100,4 +100,5 @@ BLOB_STORAGE_PATH=/root/.flowise/storage
 # REDIS_TLS=
 # REDIS_CERT=
 # REDIS_KEY=
-# REDIS_CA=
\ No newline at end of file
+# REDIS_CA=
+# ENABLE_BULLMQ_DASHBOARD=
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 3806af1d9..db689935b 100644
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -49,6 +49,7 @@ services:
             - REDIS_CERT=${REDIS_CERT}
             - REDIS_KEY=${REDIS_KEY}
             - REDIS_CA=${REDIS_CA}
+            - ENABLE_BULLMQ_DASHBOARD=${ENABLE_BULLMQ_DASHBOARD}
         ports:
             - '${PORT}:${PORT}'
         healthcheck:
diff --git a/docker/worker/docker-compose.yml b/docker/worker/docker-compose.yml
index 818bbb35b..6dbd20711 100644
--- a/docker/worker/docker-compose.yml
+++ b/docker/worker/docker-compose.yml
@@ -49,6 +49,7 @@ services:
             - REDIS_CERT=${REDIS_CERT}
             - REDIS_KEY=${REDIS_KEY}
             - REDIS_CA=${REDIS_CA}
+            - ENABLE_BULLMQ_DASHBOARD=${ENABLE_BULLMQ_DASHBOARD}
         ports:
             - '${PORT}:${PORT}'
         volumes:
diff --git a/packages/server/.env.example b/packages/server/.env.example
index e1bccc2d0..6ff339610 100644
--- a/packages/server/.env.example
+++ b/packages/server/.env.example
@@ -99,3 +99,4 @@ PORT=3000
 # REDIS_CERT=
 # REDIS_KEY=
 # REDIS_CA=
+# ENABLE_BULLMQ_DASHBOARD=
diff --git a/packages/server/src/commands/base.ts b/packages/server/src/commands/base.ts
index 1b1361446..8fe5dbfba 100644
--- a/packages/server/src/commands/base.ts
+++ b/packages/server/src/commands/base.ts
@@ -75,7 +75,8 @@ export abstract class BaseCommand extends Command {
         REDIS_TLS: Flags.string(),
         REDIS_CERT: Flags.string(),
         REDIS_KEY: Flags.string(),
-        REDIS_CA: Flags.string()
+        REDIS_CA: Flags.string(),
+        ENABLE_BULLMQ_DASHBOARD: Flags.string()
     }
 
     protected async stopProcess() {
@@ -210,5 +211,6 @@ export abstract class BaseCommand extends Command {
         if (flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN) process.env.QUEUE_REDIS_EVENT_STREAM_MAX_LEN = flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN
         if (flags.REMOVE_ON_AGE) process.env.REMOVE_ON_AGE = flags.REMOVE_ON_AGE
         if (flags.REMOVE_ON_COUNT) process.env.REMOVE_ON_COUNT = flags.REMOVE_ON_COUNT
+        if (flags.ENABLE_BULLMQ_DASHBOARD) process.env.ENABLE_BULLMQ_DASHBOARD = flags.ENABLE_BULLMQ_DASHBOARD
     }
 }
diff --git a/packages/server/src/index.ts b/packages/server/src/index.ts
index 40007677d..fb7618b5f 100644
--- a/packages/server/src/index.ts
+++ b/packages/server/src/index.ts
@@ -251,7 +251,7 @@ export class App {
             })
         })
 
-        if (process.env.MODE === MODE.QUEUE) {
+        if (process.env.MODE === MODE.QUEUE && process.env.ENABLE_BULLMQ_DASHBOARD === 'true') {
             this.app.use('/admin/queues', this.queueManager.getBullBoardRouter())
         }