fix: examples (#2207)

* fix: examples

* fix: subscribe instead of watch

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]

examples/contracts/examples/events_with_meta.rs

@@ -17,7 +17,9 @@ abigen!(
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    let client = Provider::<Ws>::connect("wss://eth.llamarpc.com").await?;
+    let client =
+        Provider::<Ws>::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27")
+            .await?;
 
     let client = Arc::new(client);
 

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";

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<()> {

examples/queries/examples/paginated_logs.rs

@@ -10,7 +10,9 @@ use std::sync::Arc;
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    let client: Provider<Ws> = Provider::<Ws>::connect("wss://eth.llamarpc.com").await?;
+    let client: Provider<Ws> =
+        Provider::<Ws>::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();

examples/subscriptions/examples/subscribe_blocks.rs

@@ -1,15 +1,13 @@
 use ethers::providers::{Middleware, Provider, StreamExt, Ws};
 use eyre::Result;
-use std::time::Duration;
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    let ws_endpoint = "wss://eth.llamarpc.com";
-    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 provider =
+        Provider::<Ws>::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 {
-        let block = provider.get_block(block).await?.unwrap();
         println!(
             "Ts: {:?}, block number: {} -> {:?}",
             block.timestamp,

examples/subscriptions/examples/subscribe_events_by_type.rs

@@ -46,5 +46,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
 }
 
 async fn get_client() -> Provider<Ws> {
-    Provider::<Ws>::connect("wss://eth.llamarpc.com").await.unwrap()
+    Provider::<Ws>::connect("wss://mainnet.infura.io/ws/v3/c60b0bb42f8a4c6481ecd229eddaca27")
+        .await
+        .unwrap()
 }

examples/subscriptions/examples/subscribe_logs.rs

@@ -10,7 +10,9 @@ use std::sync::Arc;
 
 #[tokio::main]
 async fn main() -> Result<()> {
-    let client = Provider::<Ws>::connect("wss://eth.llamarpc.com").await?;
+    let client =
+        Provider::<Ws>::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();