Skip to content

Commit e96f970

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

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
};
@@ -349,17 +349,17 @@ pub async fn create_per_network_reorg_trackers(
349349
panic!("Failed to spawn tracker for reorgs loop in network {net} because no updates sending relayer exists for it!");
350350
}
351351
};
352+
let mut reorg_tracker = ReorgTracker::new(
353+
net_clone,
354+
reorg_tracker_config,
355+
sequencer_state_providers_clone,
356+
relayer_send_channel,
357+
);
352358
collected_futures.push(
353359
tokio::task::Builder::new()
354360
.name(reorg_trackers_name.clone().as_str())
355361
.spawn(async move {
356-
loop_tracking_for_reorg_in_network(
357-
net_clone,
358-
sequencer_state_providers_clone,
359-
reorg_tracker_config,
360-
relayer_send_channel,
361-
)
362-
.await;
362+
reorg_tracker.loop_tracking_for_reorg_in_network().await;
363363
Ok(())
364364
})
365365
.expect("Failed to spawn tracker for reorgs loop in network {net}!"),

0 commit comments

Comments
 (0)