From d98c2c2cf5660d22e79ca36faac71b6f544fef55 Mon Sep 17 00:00:00 2001
From: Jackson Harper <jacksonh@gmail.com>
Date: Fri, 12 Jan 2024 11:51:55 +0800
Subject: [PATCH] Redis config

---
 pkg/bull-queue-admin/index.js | 31 ++++++++++++++++++++-----------
 1 file changed, 20 insertions(+), 11 deletions(-)

diff --git a/pkg/bull-queue-admin/index.js b/pkg/bull-queue-admin/index.js
index 2b598ddf3..016bc26c3 100644
--- a/pkg/bull-queue-admin/index.js
+++ b/pkg/bull-queue-admin/index.js
@@ -41,18 +41,27 @@ passport.deserializeUser((user, cb) => {
   cb(null, user)
 })
 
-const sleep = (t) => new Promise((resolve) => setTimeout(resolve, t * 1000))
-
-const redisOptions = {
-  port: 6379,
-  host: 'localhost',
-  password: '',
-  tls: false,
-}
-
-const createQueueMQ = (name) => new QueueMQ(name, { connection: redisOptions })
-
 const run = async () => {
+  const secrets = readYamlFile(process.env.SECRETS_FILE)
+  const redisOptions = () => {
+    if (secrets.REDIS_URL?.startsWith('rediss://') && secrets.REDIS_CERT) {
+      return {
+        tls: {
+          cert: secrets.REDIS_CERT?.replace(/\\n/g, '\n'),
+          rejectUnauthorized: false,
+        },
+        maxRetriesPerRequest: null,
+      }
+    }
+    return {
+      maxRetriesPerRequest: null,
+    }
+  }
+  const createQueueMQ = (name) =>
+    new QueueMQ(secrets.REDIS_URL, {
+      connection: redisOptions,
+    })
+
   const rssRefreshFeed = createQueueMQ('rssRefreshFeed')
 
   const serverAdapter = new ExpressAdapter()