feat: allow to set redis username

NezuChan · Jul 23, 2022 · 6ba2157 · 6ba2157
1 parent 6adad65
commit 6ba2157
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 3 deletions.
diff --git a/.env_example b/.env_example
@@ -2,6 +2,7 @@ TOTAL_CLUSTERS = 6
 QUEUE_NAME = "scheduled-tasks"
 REDIS_HOST = "localhost"
 REDIS_PORT = 6379
+REDIS_USERNAME = 
 REDIS_PASSWORD =
 AMQP_HOST = "amqp://guest:guest@localhost"
 AMQP_QUEUE_NAME = "scheduled-tasks"
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nezuchan/scheduled-tasks",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "A Standalone scheduled tasks service for microserviced \"Discord\" bot.",
   "main": "dist/index.js",
   "scripts": {

diff --git a/src/Structures/TaskManager.ts b/src/Structures/TaskManager.ts
@@ -23,6 +23,7 @@ export class TaskManager extends EventEmitter {
         redis: {
             host: process.env.REDIS_HOST!,
             port: parseInt(process.env.REDIS_PORT!),
+            username: process.env.REDIS_USERNAME,
             password: process.env.REDIS_PASSWORD
         },
         defaultJobOptions: {

diff --git a/src/Utilities/handleJob.ts b/src/Utilities/handleJob.ts
@@ -193,8 +193,10 @@ export async function handleJob(message: Record<string, any>, bull: Bull.Queue,
             return JSON.stringify({ message: "Jobs found !", jobs, fromCluster: clusterId });
         }
         default: {
-            manager.logger.warn(message, `Unhandled job type ${message.type}`);
-            return JSON.stringify({ message: "Unhandled job, please open issue if you need this to be handled  or this is missing from the implementation !" });
+            if (message.type) {
+                manager.logger.warn(message, `Unhandled job type ${message.type}`);
+                return JSON.stringify({ message: "Unhandled job, please open issue if you need this to be handled  or this is missing from the implementation !" });
+            }
         }
     }
 }