From 986bfa412c65f083cf187d9d8977fa381c5893e2 Mon Sep 17 00:00:00 2001 From: Peilun Li Date: Wed, 17 Jan 2024 10:57:07 +0800 Subject: [PATCH] Add to start_recover. --- node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs b/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs index 4eaf410..d2cbb1f 100644 --- a/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs +++ b/node/log_entry_sync/src/sync_manager/log_entry_fetcher.rs @@ -71,6 +71,7 @@ impl LogEntryFetcher { .submit_filter() .from_block(progress) .to_block(end_block_number) + .address(contract.address().into()) .filter; let mut stream = LogQuery::new(&provider, &filter, log_query_delay) .with_page_size(log_page_size); @@ -116,7 +117,7 @@ impl LogEntryFetcher { } Err(e) => { error!("log query error: e={:?}", e); - filter = filter.from_block(progress); + filter = filter.from_block(progress).address(contract.address()); stream = LogQuery::new(&provider, &filter, log_query_delay) .with_page_size(log_page_size); tokio::time::sleep(Duration::from_millis(RETRY_WAIT_MS)).await;