feat(providers): add connect_builtin example

examples/providers/Cargo.toml

@@ -13,15 +13,21 @@ repository.workspace = true
 [dev-dependencies]
 alloy.workspace = true
 # Temp dependency fix to enable relevant features - Ref: https://github.com/alloy-rs/examples/pull/3#discussion_r1537842062
-alloy-rpc-client = { git = "https://github.com/alloy-rs/alloy", rev = "f7333c4", features = [
+alloy-rpc-client = { git = "https://github.com/alloy-rs/alloy", rev = "68952c0", features = [
     "pubsub",
+    "ipc",
+    "ws",
 ] }
-alloy-provider = { git = "https://github.com/alloy-rs/alloy", rev = "f7333c4", features = [
+alloy-provider = { git = "https://github.com/alloy-rs/alloy", rev = "68952c0", features = [
     "pubsub",
     "ws",
+    "ipc",
 ] }
 
+alloy-network = { git = "https://github.com/alloy-rs/alloy", rev = "68952c0" }
 
+alloy-transport = { git = "https://github.com/alloy-rs/alloy", rev = "68952c0" }
+alloy-transport-ipc = { git = "https://github.com/alloy-rs/alloy", rev = "68952c0" }
 eyre.workspace = true
 futures-util = "0.3"
 tokio = { workspace = true, features = ["rt-multi-thread", "macros"] }

examples/providers/examples/connect_builtin.rs

@@ -0,0 +1,52 @@
+//! Example of using the `RootProvider<N, T: BoxTransport>::connect_builtin` to create a provider
+//! from a connection string. The connection string can be a HTTP, WS or IPC endpoint.
+
+use alloy::node_bindings::Anvil;
+use alloy_network::Ethereum;
+use alloy_provider::{Provider, RootProvider};
+use alloy_transport::BoxTransport;
+use eyre::Result;
+use futures_util::StreamExt;
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let anvil = Anvil::new().block_time(1).try_spawn()?;
+    let http = anvil.endpoint();
+    let ws = anvil.ws_endpoint();
+
+    // Instantiate a HTTP transport provider by passing the http endpoint url
+    let http_provider =
+        RootProvider::<Ethereum, BoxTransport>::connect_builtin(http.as_str()).await?;
+
+    // Get latest block number
+    let block_number = http_provider.get_block_number().await?;
+
+    println!("Latest block number: {:?}", block_number);
+
+    // This requires the `pubsub` and `ws` features to be enabled on alloy-provider
+    let ws_provider = RootProvider::<Ethereum, BoxTransport>::connect_builtin(ws.as_str()).await?;
+
+    let sub = ws_provider.subscribe_blocks().await?;
+
+    let mut stream = sub.into_stream().take(2);
+
+    println!("Awaiting blocks...");
+
+    let handle = tokio::spawn(async move {
+        while let Some(block) = stream.next().await {
+            println!("{:?}", block.header.number);
+        }
+    });
+
+    handle.await?;
+
+    let ipc_path = "/tmp/reth.ipc";
+
+    // This requires the `pubsub` and `ipc` features to be enabled on alloy-provider
+    // This would throw a runtime error if the ipc does not exist
+    let ipc_provider = RootProvider::<Ethereum, BoxTransport>::connect_builtin(ipc_path).await?;
+
+    let _block_number = ipc_provider.get_block_number().await?;
+
+    Ok(())
+}

examples/providers/examples/ipc.rs

@@ -1,11 +1,9 @@
 //! Example of using the IPC provider to get the latest block number.
 
-use alloy::{
-    network::Ethereum,
-    providers::{Provider, RootProvider},
-    transports::ipc::IpcConnect,
-};
+use alloy_network::Ethereum;
+use alloy_provider::{Provider, RootProvider};
 use alloy_rpc_client::RpcClient;
+use alloy_transport_ipc::IpcConnect;
 use eyre::Result;
 
 #[tokio::main]

examples/providers/examples/ws.rs

@@ -1,7 +1,7 @@
 //! Example of using the WS provider to subscribe to new blocks.
 
-use alloy::network::Ethereum;
 // Temp Fix
+use alloy_network::Ethereum;
 use alloy_provider::{Provider, RootProvider};
 use alloy_rpc_client::{RpcClient, WsConnect};
 //

examples/providers/examples/ws_with_auth.rs

@@ -1,9 +1,10 @@
 //! Example of using the WS provider with auth to subscribe to new blocks.
 
-use alloy::{network::Ethereum, transports::Authorization};
 // Temp Fix
+use alloy_network::Ethereum;
 use alloy_provider::{Provider, RootProvider};
 use alloy_rpc_client::{RpcClient, WsConnect};
+use alloy_transport::Authorization;
 //
 use eyre::Result;
 use futures_util::StreamExt;