@@ -128,6 +128,10 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
128128 startBlockNumber,
129129 endBlockNumber,
130130 } : FetchCursorRangeArgs ) : Promise < BlockInfo [ ] > {
131+ console . log (
132+ `[EVM] fetchCursorRange: start=${ startBlockNumber } end=${ endBlockNumber } ` ,
133+ ) ;
134+
131135 const requestCount = Number ( endBlockNumber - startBlockNumber + 1n ) ;
132136 return await Promise . all (
133137 Array . from ( { length : requestCount } , async ( _ , i ) => {
@@ -153,7 +157,7 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
153157 { start : startBlock , end : maxBlock } ,
154158 ) ;
155159
156- // console.log("Fetching block range", fromBlock, toBlock, filter );
160+ console . log ( `[EVM] fetchBlockRange: start= ${ fromBlock } end= ${ toBlock } ` ) ;
157161
158162 const { logs : logsByBlockNumber , blockNumbers } =
159163 await this . fetchLogsForRangeWithRetry ( {
@@ -214,6 +218,7 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
214218 isAtHead,
215219 filter,
216220 } : FetchBlockByHashArgs < Filter > ) : Promise < FetchBlockByHashResult < Block > > {
221+ console . log ( `[EVM] fetchBlockByHash: hash=${ blockHash } ` ) ;
217222 // Fetch block header and check it matches the expected parent block hash.
218223 const { header } = await this . fetchBlockHeaderByHashWithRetry ( {
219224 blockHash,
0 commit comments