Merge pull request #129 from NethermindEth/mu/events-monitoring

Improve event monitoring
NethermindEth · Sep 19, 2024 · 58f33ea · 58f33ea
2 parents 0f88573 + 71f92ab
commit 58f33ea
Show file tree

Hide file tree

Showing 9 changed files with 186 additions and 114 deletions.
diff --git a/Node/src/ethereum_l1/block_proposed.rs b/Node/src/ethereum_l1/block_proposed.rs
@@ -1,4 +1,4 @@
-use alloy::{contract::EventPoller, sol};
+use alloy::{contract::EventPoller, pubsub::PubSubFrontend, sol};
 use anyhow::Error;
 
 sol!(
@@ -30,6 +30,4 @@ impl BlockProposed {
     }
 }
 
-pub struct EventPollerBlockProposed(
-    pub EventPoller<alloy::transports::http::Http<reqwest::Client>, TaikoEvents::BlockProposed>,
-);
+pub struct EventPollerBlockProposed(pub EventPoller<PubSubFrontend, TaikoEvents::BlockProposed>);
diff --git a/Node/src/ethereum_l1/el_with_cl_tests.rs b/Node/src/ethereum_l1/el_with_cl_tests.rs
@@ -14,8 +14,9 @@ mod tests {
 
         let anvil = Anvil::new().try_spawn().unwrap();
         let rpc_url: reqwest::Url = anvil.endpoint().parse().unwrap();
+        let ws_rpc_url = anvil.ws_endpoint();
         let private_key = anvil.keys()[0].clone();
-        let el = ExecutionLayer::new_from_pk(rpc_url, private_key)
+        let el = ExecutionLayer::new_from_pk(ws_rpc_url, rpc_url, private_key)
             .await
             .unwrap();