Merge pull request #298 from umbrella-network/hotfix/5.12.3

added more logs to tx fetcher

CHANGELOG.md

@@ -6,6 +6,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## Unreleased
 
+## [5.12.3] - 2024-11-03
+### Added
+- added more logs to tx fetcher
+
 ## [5.12.2] - 2024-07-25
 ### Fixed
 - in `EvmTxsFetcher` fix case when we get error on first block and we checkpoint all blocks

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sanctuary",
-  "version": "5.12.2",
+  "version": "5.12.3",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/umbrella-network/sanctuary.git"

src/services/on-chain-stats/EvmTxsFetcher.ts

@@ -30,7 +30,7 @@ export class EvmTxsFetcher {
       arr.push(i);
     }
 
-    this.logger.debug(`[EvmTxsFetcher] fetching txs for ${arr.length} blocks`);
+    this.logger.debug(`${chainId}[EvmTxsFetcher] fetching txs for ${arr.length} blocks`);
 
     const allTxsSettled = await Promise.allSettled(
       arr.sort().map((i) => promiseWithTimeout(provider.getBlockWithTransactions(i), 15000))

src/services/on-chain-stats/KeysUpdateService.ts

@@ -50,7 +50,7 @@ export class KeysUpdateService {
 
   private async downloadFile(feedFile: string): Promise<string | undefined> {
     if (!feedFile) {
-      this.logger.warn('${this.logPrefix} Skipping, no URL configured');
+      this.logger.warn(`${this.logPrefix} Skipping, no URL configured`);
       return;
     }
 

src/services/on-chain-stats/OnChainTxFetcher.ts

@@ -55,6 +55,8 @@ export class OnChainTxFetcher {
 
     const feedsMap = await this.umbrellaFeedsMap(chainId);
 
+    this.logger.debug(`[OnChainTxFetcher][${chainId}] feedsMap: ${feedsMap.keys()}`);
+
     this.logger.info(
       `[OnChainTxFetcher][${chainId}] blocks to sync: ${rangeTo - rangeFrom} blocks, starting from ${rangeFrom}`
     );
@@ -87,7 +89,9 @@ export class OnChainTxFetcher {
         continue;
       }
 
-      this.logger.info(`${logPrefix} found ${filteredTx.length} 'update()' txs`);
+      this.logger.info(
+        `${logPrefix} found ${filteredTx.length} 'update()' txs ${filteredTx.map((tx) => tx.blockNumber).sort()}`
+      );
 
       const receipts = await this.txReceiptFetcher.call(
         chainId,