From 436d1d9dc550e374f17205eac9bcd1bfc668c851 Mon Sep 17 00:00:00 2001 From: DaniPopes <57450786+DaniPopes@users.noreply.github.com> Date: Tue, 28 Feb 2023 01:12:22 +0100 Subject: [PATCH 1/2] fix: examples --- examples/contracts/examples/events.rs | 2 +- examples/contracts/examples/events_with_meta.rs | 4 +++- examples/events/examples/filtering.rs | 2 +- examples/providers/examples/ws.rs | 2 +- examples/queries/examples/paginated_logs.rs | 4 +++- examples/subscriptions/examples/subscribe_events_by_type.rs | 4 +++- examples/subscriptions/examples/subscribe_logs.rs | 4 +++- examples/subscriptions/examples/watch_blocks.rs | 5 ++--- 8 files changed, 17 insertions(+), 10 deletions(-) diff --git a/examples/contracts/examples/events.rs b/examples/contracts/examples/events.rs index a0deb71e4..4039d8835 100644 --- a/examples/contracts/examples/events.rs +++ b/examples/contracts/examples/events.rs @@ -14,7 +14,7 @@ abigen!( ]"#, ); -const WSS_URL: &str = "wss://eth.llamarpc.com"; +const WSS_URL: &str = "wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27"; const WETH_ADDRESS: &str = "0xC02aaA39b223FE8D0A0e5C4F27eAD9083C756Cc2"; #[tokio::main] diff --git a/examples/contracts/examples/events_with_meta.rs b/examples/contracts/examples/events_with_meta.rs index 6d6df1f6a..ceb0c68e2 100644 --- a/examples/contracts/examples/events_with_meta.rs +++ b/examples/contracts/examples/events_with_meta.rs @@ -17,7 +17,9 @@ abigen!( #[tokio::main] async fn main() -> Result<()> { - let client = Provider::::connect("wss://eth.llamarpc.com").await?; + let client = + Provider::::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27") + .await?; let client = Arc::new(client); diff --git a/examples/events/examples/filtering.rs b/examples/events/examples/filtering.rs index a968cf104..0e23baae0 100644 --- a/examples/events/examples/filtering.rs +++ b/examples/events/examples/filtering.rs @@ -5,7 +5,7 @@ use ethers::{ use eyre::Result; use std::sync::Arc; -const HTTP_URL: &str = "https://eth.llamarpc.com"; +const HTTP_URL: &str = "https://rpc.flashbots.net"; const V3FACTORY_ADDRESS: &str = "0x1F98431c8aD98523631AE4a59f267346ea31F984"; const DAI_ADDRESS: &str = "0x6B175474E89094C44Da98b954EedeAC495271d0F"; const USDC_ADDRESS: &str = "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48"; diff --git a/examples/providers/examples/ws.rs b/examples/providers/examples/ws.rs index 87d42f672..d1c339dc9 100644 --- a/examples/providers/examples/ws.rs +++ b/examples/providers/examples/ws.rs @@ -6,7 +6,7 @@ use ethers::prelude::*; -const WSS_URL: &str = "wss://eth.llamarpc.com"; +const WSS_URL: &str = "wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27"; #[tokio::main] async fn main() -> eyre::Result<()> { diff --git a/examples/queries/examples/paginated_logs.rs b/examples/queries/examples/paginated_logs.rs index f3cd63b85..563b90f14 100644 --- a/examples/queries/examples/paginated_logs.rs +++ b/examples/queries/examples/paginated_logs.rs @@ -10,7 +10,9 @@ use std::sync::Arc; #[tokio::main] async fn main() -> Result<()> { - let client: Provider = Provider::::connect("wss://eth.llamarpc.com").await?; + let client: Provider = + Provider::::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27") + .await?; let client = Arc::new(client); let last_block = client.get_block(BlockNumber::Latest).await?.unwrap().number.unwrap(); diff --git a/examples/subscriptions/examples/subscribe_events_by_type.rs b/examples/subscriptions/examples/subscribe_events_by_type.rs index 4de7e05eb..8f935c0b1 100644 --- a/examples/subscriptions/examples/subscribe_events_by_type.rs +++ b/examples/subscriptions/examples/subscribe_events_by_type.rs @@ -46,5 +46,7 @@ async fn main() -> Result<(), Box> { } async fn get_client() -> Provider { - Provider::::connect("wss://eth.llamarpc.com").await.unwrap() + Provider::::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27") + .await + .unwrap() } diff --git a/examples/subscriptions/examples/subscribe_logs.rs b/examples/subscriptions/examples/subscribe_logs.rs index 501bb4a4f..3ee71259e 100644 --- a/examples/subscriptions/examples/subscribe_logs.rs +++ b/examples/subscriptions/examples/subscribe_logs.rs @@ -10,7 +10,9 @@ use std::sync::Arc; #[tokio::main] async fn main() -> Result<()> { - let client = Provider::::connect("wss://eth.llamarpc.com").await?; + let client = + Provider::::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27") + .await?; let client = Arc::new(client); let last_block = client.get_block(BlockNumber::Latest).await?.unwrap().number.unwrap(); diff --git a/examples/subscriptions/examples/watch_blocks.rs b/examples/subscriptions/examples/watch_blocks.rs index 2e38661a2..3f36822df 100644 --- a/examples/subscriptions/examples/watch_blocks.rs +++ b/examples/subscriptions/examples/watch_blocks.rs @@ -4,12 +4,11 @@ use std::time::Duration; #[tokio::main] async fn main() -> Result<()> { - let ws_endpoint = "wss://eth.llamarpc.com"; + let ws_endpoint = "wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27"; let ws = Ws::connect(ws_endpoint).await?; let provider = Provider::new(ws).interval(Duration::from_millis(2000)); - let mut stream = provider.watch_blocks().await?.take(1); + let mut stream = provider.subscribe_blocks().await?.take(1); while let Some(block) = stream.next().await { - let block = provider.get_block(block).await?.unwrap(); println!( "Ts: {:?}, block number: {} -> {:?}", block.timestamp, From 6326108fd2e50c80cf3a6f8e8a035790a4a54c37 Mon Sep 17 00:00:00 2001 From: DaniPopes <57450786+DaniPopes@users.noreply.github.com> Date: Tue, 28 Feb 2023 01:16:23 +0100 Subject: [PATCH 2/2] fix: subscribe instead of watch --- .../examples/{watch_blocks.rs => subscribe_blocks.rs} | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) rename examples/subscriptions/examples/{watch_blocks.rs => subscribe_blocks.rs} (65%) diff --git a/examples/subscriptions/examples/watch_blocks.rs b/examples/subscriptions/examples/subscribe_blocks.rs similarity index 65% rename from examples/subscriptions/examples/watch_blocks.rs rename to examples/subscriptions/examples/subscribe_blocks.rs index 3f36822df..2d18cd64b 100644 --- a/examples/subscriptions/examples/watch_blocks.rs +++ b/examples/subscriptions/examples/subscribe_blocks.rs @@ -1,12 +1,11 @@ use ethers::providers::{Middleware, Provider, StreamExt, Ws}; use eyre::Result; -use std::time::Duration; #[tokio::main] async fn main() -> Result<()> { - let ws_endpoint = "wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27"; - let ws = Ws::connect(ws_endpoint).await?; - let provider = Provider::new(ws).interval(Duration::from_millis(2000)); + let provider = + Provider::::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27") + .await?; let mut stream = provider.subscribe_blocks().await?.take(1); while let Some(block) = stream.next().await { println!(