From 6ba21579467b4a2d97c0d746afd9b7bf88d5f0d9 Mon Sep 17 00:00:00 2001
From: KagChi <yonuxbot@gmail.com>
Date: Sat, 23 Jul 2022 18:27:33 +0700
Subject: [PATCH] feat: allow to set redis username

---
 .env_example                  | 1 +
 package.json                  | 2 +-
 src/Structures/TaskManager.ts | 1 +
 src/Utilities/handleJob.ts    | 6 ++++--
 4 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/.env_example b/.env_example
index f841e65..3e9dc9a 100644
--- 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"
\ No newline at end of file
diff --git a/package.json b/package.json
index 0dfa7b6..938bc80 100644
--- 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
index 3bc65c4..4c52d2e 100644
--- 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
index 2ec724c..f9eca6f 100644
--- 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 !" });
+            }
         }
     }
 }