Expose subxt onclineclient / rpc

crates/examples/Cargo.toml

@@ -13,3 +13,5 @@ provider = { path = "../provider" }
 # to review the exports for neeeded types
 support = { path = "../support" }
 tokio = { workspace = true }
+futures = { workspace = true }
+subxt = { workspace = true }

crates/examples/examples/simple_network_example.rs

@@ -1,6 +1,7 @@
 // use std::time::Duration;
 
 use configuration::NetworkConfig;
+use futures::stream::StreamExt;
 use orchestrator::Orchestrator;
 use provider::NativeProvider;
 use support::{fs::local::LocalFileSystem, process::os::OsProcessManager};
@@ -14,11 +15,18 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let pm = OsProcessManager;
     let provider = NativeProvider::new(fs.clone(), pm);
     let orchestrator = Orchestrator::new(fs, provider);
-    orchestrator.spawn(config).await?;
+    let network = orchestrator.spawn(config).await?;
     println!("🚀🚀🚀🚀 network deployed");
-    // For now let just loop....
-    #[allow(clippy::empty_loop)]
-    loop {}
 
-    // Ok(())
+    let client = network
+        .get_node("alice")?
+        .client::<subxt::PolkadotConfig>()
+        .await?;
+    let mut blocks = client.blocks().subscribe_finalized().await?.take(3);
+
+    while let Some(block) = blocks.next().await {
+        println!("Block #{}", block?.header().number);
+    }
+
+    Ok(())
 }

crates/orchestrator/src/network/node.rs

@@ -3,6 +3,7 @@ use std::{sync::Arc, time::Duration};
 use anyhow::anyhow;
 use prom_metrics_parser::MetricMap;
 use provider::DynNode;
+use subxt::{backend::rpc::RpcClient, OnlineClient};
 use tokio::sync::RwLock;
 
 use crate::network_spec::node::NodeSpec;
@@ -45,6 +46,18 @@ impl NetworkNode {
         Ok(())
     }
 
+    /// Get the rpc client for the node
+    pub async fn rpc(&self) -> Result<RpcClient, subxt::Error> {
+        RpcClient::from_url(&self.ws_uri).await
+    }
+
+    /// Get the online client for the node
+    pub async fn client<Config: subxt::Config>(
+        &self,
+    ) -> Result<OnlineClient<Config>, subxt::Error> {
+        OnlineClient::from_url(&self.ws_uri).await
+    }
+
     /// Resume the node, this is implemented by resuming the
     /// actual process (e.g polkadot) with sendig `SIGCONT` signal
     pub async fn resume(&self) -> Result<(), anyhow::Error> {