Fix warn logs

across-protocol · Nov 26, 2024 · b59aa5c · b59aa5c
1 parent 8acc261
commit b59aa5c
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 7 deletions.
diff --git a/packages/indexer-api/src/main.ts b/packages/indexer-api/src/main.ts
@@ -19,7 +19,7 @@ async function initializeRedis(
   return new Promise<Redis>((resolve, reject) => {
     redis.on("ready", () => {
       logger.debug({
-        at: "IndexerAPI",
+        at: "IndexerAPI#initializeRedis",
         message: "Redis connection established",
         config,
       });
@@ -28,7 +28,7 @@ async function initializeRedis(
 
     redis.on("error", (err) => {
       logger.error({
-        at: "IndexerAPI",
+        at: "IndexerAPI#initializeRedis",
         message: "Redis connection failed",
         notificationPath: "across-indexer-error",
         error: err,

diff --git a/packages/indexer/src/data-indexing/service/AcrossIndexerManager.ts b/packages/indexer/src/data-indexing/service/AcrossIndexerManager.ts
@@ -55,7 +55,10 @@ export class AcrossIndexerManager {
 
   private startHubPoolIndexer() {
     if (!this.config.enableHubPoolIndexer) {
-      this.logger.warn("Hub pool indexer is disabled");
+      this.logger.warn({
+        at: "Indexer#AcrossIndexerManager#startHubPoolIndexer",
+        message: "Hub pool indexer is disabled",
+      });
       return;
     }
     const hubPoolIndexerDataHandler = new HubPoolIndexerDataHandler(
@@ -113,7 +116,10 @@ export class AcrossIndexerManager {
     this.spokePoolIndexers = spokePoolIndexers;
 
     if (this.spokePoolIndexers.length === 0) {
-      this.logger.warn("No spoke pool indexers to start");
+      this.logger.warn({
+        at: "Indexer#AcrossIndexerManager#startSpokePoolIndexers",
+        message: "No spoke pool indexers to start",
+      });
       return;
     }
     return Promise.all(

diff --git a/packages/indexer/src/services/BundleServicesManager.ts b/packages/indexer/src/services/BundleServicesManager.ts
@@ -45,7 +45,10 @@ export class BundleServicesManager {
 
   private startBundleIncludedEventsService() {
     if (!this.config.enableBundleIncludedEventsService) {
-      this.logger.warn("Bundle included events service is disabled");
+      this.logger.warn({
+        at: "Indexer#BundleServicesManager#startBundleIncludedEventsService",
+        message: "Bundle included events service is disabled",
+      });
       return;
     }
     this.bundleIncludedEventsService = new BundleIncludedEventsService({
@@ -62,7 +65,10 @@ export class BundleServicesManager {
 
   private startBundleEventsProcessor() {
     if (!this.config.enableBundleEventsProcessor) {
-      this.logger.warn("Bundle events processor is disabled");
+      this.logger.warn({
+        at: "Indexer#BundleServicesManager#startBundleEventsProcessor",
+        message: "Bundle events processor is disabled",
+      });
       return;
     }
     this.bundleEventsProcessor = new BundleEventsProcessor({
@@ -76,7 +82,10 @@ export class BundleServicesManager {
 
   private startBundleBuilderService() {
     if (!this.config.enableBundleBuilder) {
-      this.logger.warn("Bundle builder service is disabled");
+      this.logger.warn({
+        at: "Indexer#BundleServicesManager#startBundleBuilderService",
+        message: "Bundle builder service is disabled",
+      });
       return;
     }