Skip to content

Commit a81ab7c

Browse files
HristoStaykovreo101
authored andcommitted
refactor(sequencer/reorg_tracking): Create ReorgTracker object per network
1 parent bd7befb commit a81ab7c

File tree

2 files changed

+623
-503
lines changed

2 files changed

+623
-503
lines changed

apps/sequencer/src/providers/eth_send_utils.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ use crate::{
2424
parse_eth_address, HashValue, LatestRBIndex, ProviderStatus, ProviderType,
2525
ProvidersMetrics, RpcProvider, SharedRpcProviders,
2626
},
27-
reorg_tracking::loop_tracking_for_reorg_in_network,
27+
reorg_tracking::ReorgTracker,
2828
},
2929
sequencer_state::SequencerState,
3030
};
@@ -299,17 +299,17 @@ pub async fn create_per_network_reorg_trackers(
299299
panic!("Failed to spawn tracker for reorgs loop in network {net} because no updates sending relayer exists for it!");
300300
}
301301
};
302+
let mut reorg_tracker = ReorgTracker::new(
303+
net_clone,
304+
reorg_tracker_config,
305+
sequencer_state_providers_clone,
306+
relayer_send_channel,
307+
);
302308
collected_futures.push(
303309
tokio::task::Builder::new()
304310
.name(reorg_trackers_name.clone().as_str())
305311
.spawn(async move {
306-
loop_tracking_for_reorg_in_network(
307-
net_clone,
308-
sequencer_state_providers_clone,
309-
reorg_tracker_config,
310-
relayer_send_channel,
311-
)
312-
.await;
312+
reorg_tracker.loop_tracking_for_reorg_in_network().await;
313313
Ok(())
314314
})
315315
.expect("Failed to spawn tracker for reorgs loop in network {net}!"),

0 commit comments

Comments
 (0)