Merge branch 'main' into fk/overrides-backend-wallet

Author: farhanW3

src/worker/index.ts

@@ -1,5 +1,3 @@
-import { logger } from "../utils/logger";
-import { redis } from "../utils/redis/redis";
 import { chainIndexerListener } from "./listeners/chainIndexerListener";
 import {
   newConfigurationListener,
@@ -38,13 +36,5 @@ export const initWorker = async () => {
   await newWebhooksListener();
   await updatedWebhooksListener();
 
-  if (redis) {
-    await chainIndexerListener();
-  } else {
-    logger({
-      service: "worker",
-      level: "warn",
-      message: `Chain Indexer Listener not started, Redis not available`,
-    });
-  }
+  await chainIndexerListener();
 };

src/worker/listeners/chainIndexerListener.ts

@@ -1,12 +1,22 @@
 import cron from "node-cron";
 import { getConfig } from "../../utils/cache/getConfig";
 import { logger } from "../../utils/logger";
+import { redis } from "../../utils/redis/redis";
 import { manageChainIndexers } from "../tasks/manageChainIndexers";
 
 let processChainIndexerStarted = false;
 let task: cron.ScheduledTask;
 
 export const chainIndexerListener = async (): Promise<void> => {
+  if (!redis) {
+    logger({
+      service: "worker",
+      level: "warn",
+      message: `Chain Indexer Listener not started, Redis not available`,
+    });
+    return;
+  }
+
   logger({
     service: "worker",
     level: "info",