evm.node: Respect http.batch_size when fetching events and transactions.

Author: Wizard1209

CHANGELOG.md

@@ -12,6 +12,7 @@ Releases prior to 7.0 has been removed from this file to declutter search result
 
 - demos: Use Etherscan v2 API endpoints in EVM templates.
 - mcp: Fixed crash when using `mcp.tool` decorator.
+- evm.node: Respect `http.batch_size` when fetching events and transactions.
 
 ### Changed
 

src/dipdup/indexes/evm_events/fetcher.py

@@ -65,7 +65,7 @@ async def _fetch_by_level(self) -> AsyncIterator[tuple[EvmEventData, ...]]:
 
         while batch_first_level <= self._last_level:
             node = self.random_datasource
-            batch_size = self.get_next_batch_size(batch_size, ratelimited)
+            batch_size = min(node._http_config.batch_size - 1, self.get_next_batch_size(batch_size, ratelimited))
             ratelimited = False
 
             started = time.time()

src/dipdup/indexes/evm_transactions/fetcher.py

@@ -52,7 +52,7 @@ async def _fetch_by_level(self) -> AsyncIterator[tuple[EvmTransactionData, ...]]
 
         while batch_first_level <= self._last_level:
             node = random.choice(self._datasources)
-            batch_size = self.get_next_batch_size(batch_size, ratelimited)
+            batch_size = min(node._http_config.batch_size - 1, self.get_next_batch_size(batch_size, ratelimited))
             ratelimited = False
 
             started = time.time()