pezkuwi-subxt 0.44.0

Submit extrinsics (transactions) to a Pezkuwi/Bizinikiwi node via RPC
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

#![allow(missing_docs)]
use futures::StreamExt;
use pezkuwi_subxt::{client::OnlineClient, lightclient::LightClient, PezkuwiConfig};

// Generate an interface that we can use from the node's metadata.
#[pezkuwi_subxt::subxt(runtime_metadata_path = "../artifacts/polkadot_metadata_small.scale")]
pub mod pezkuwi {}

const POLKADOT_SPEC: &str = include_str!("../../artifacts/demo_chain_specs/polkadot.json");
const ASSET_HUB_SPEC: &str =
	include_str!("../../artifacts/demo_chain_specs/polkadot_asset_hub.json");

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
	// The lightclient logs are informative:
	tracing_subscriber::fmt::init();

	// Instantiate a light client with the Pezkuwi relay chain,
	// and connect it to Asset Hub, too.
	let (lightclient, pezkuwi_rpc) = LightClient::relay_chain(POLKADOT_SPEC)?;
	let asset_hub_rpc = lightclient.parachain(ASSET_HUB_SPEC)?;

	// Create Subxt clients from these Smoldot backed RPC clients.
	let pezkuwi_api = OnlineClient::<PezkuwiConfig>::from_rpc_client(pezkuwi_rpc).await?;
	let asset_hub_api = OnlineClient::<PezkuwiConfig>::from_rpc_client(asset_hub_rpc).await?;

	// Use them!
	let pezkuwi_sub = pezkuwi_api
		.blocks()
		.subscribe_finalized()
		.await?
		.map(|block| ("Pezkuwi", block));
	let parachain_sub = asset_hub_api
		.blocks()
		.subscribe_finalized()
		.await?
		.map(|block| ("AssetHub", block));

	let mut stream_combinator = futures::stream::select(pezkuwi_sub, parachain_sub);

	while let Some((chain, block)) = stream_combinator.next().await {
		let block = block?;
		println!("     Chain {:?} hash={:?}", chain, block.hash());
	}

	Ok(())
}