From d2fa91df34fe4e79e9b80398af1c4309b45e98dd Mon Sep 17 00:00:00 2001
From: Bernardo Vieira <bernardo@impactmarket.com>
Date: Tue, 21 Nov 2023 11:03:06 +0000
Subject: [PATCH] [chore] new log on recover blocks and reduce to 10 blocks
 (#1048)

---
 packages/worker/src/chainSubscribers.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/worker/src/chainSubscribers.ts b/packages/worker/src/chainSubscribers.ts
index 20bcc12c..dc27f162 100644
--- a/packages/worker/src/chainSubscribers.ts
+++ b/packages/worker/src/chainSubscribers.ts
@@ -87,9 +87,9 @@ class ChainSubscribers {
             try {
                 const r = await this._getLogs(startFromBlock, provider);
                 rawLogs = r.logs;
+                utils.Logger.info(`Got logs from main provider! Start from block ${startFromBlock} to ${r.toBlock}.`);
                 startFromBlock = r.toBlock;
                 isLastBlock = r.isLastBlock;
-                utils.Logger.info('Got logs from main provider!');
             } catch (error) {
                 utils.Logger.error('Failed to get logs from main provider!', error);
                 const r = await this._getLogs(startFromBlock, fallbackProvider);
@@ -135,7 +135,7 @@ class ChainSubscribers {
      */
     async _getLogs(startFromBlock: number, provider: ethers.providers.JsonRpcProvider) {
         const lastBlock = await provider.getBlockNumber();
-        const toBlock = lastBlock - startFromBlock > 100 ? startFromBlock + 100 : lastBlock;
+        const toBlock = lastBlock - startFromBlock > 10 ? startFromBlock + 10 : lastBlock;
         const logs = await provider.getLogs({
             fromBlock: startFromBlock,
             toBlock,