pezkuwi-subxt/subxt/examples/blocks_subscribing.rs

#![allow(missing_docs)]
use pezkuwi_subxt::{OnlineClient, PezkuwiConfig};

#[pezkuwi_subxt::subxt(runtime_metadata_path = "../artifacts/pezkuwi_metadata_small.scale")]
pub mod pezkuwi {}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Create a client to use:
	let api = OnlineClient::<PezkuwiConfig>::new().await?;

	// Subscribe to all finalized blocks:
	let mut blocks_sub = api.blocks().subscribe_finalized().await?;

	// For each block, print a bunch of information about it:
	while let Some(block) = blocks_sub.next().await {
		let block = block?;

		let block_number = block.header().number;
		let block_hash = block.hash();

		println!("Block #{block_number}:");
		println!("  Hash: {block_hash}");
		println!("  Extrinsics:");

		// Log each of the extrinsic with it's associated events:
		let extrinsics = block.extrinsics().await?;
		for ext in extrinsics.iter() {
			let idx = ext.index();
			let events = ext.events().await?;
			let bytes_hex = format!("0x{}", hex::encode(ext.bytes()));

			// See the API docs for more ways to decode extrinsics:
			let decoded_ext = ext.as_root_extrinsic::<pezkuwi::Call>();

			println!("    Extrinsic #{idx}:");
			println!("      Bytes: {bytes_hex}");
			println!("      Decoded: {decoded_ext:?}");

			println!("      Events:");
			for evt in events.iter() {
				let evt = evt?;
				let pallet_name = evt.pallet_name();
				let event_name = evt.variant_name();
				let event_values = evt.decode_as_fields::<scale_value::Value>()?;

				println!("        {pallet_name}_{event_name}");
				println!("          {event_values}");
			}

			println!("      Transaction Extensions:");
			if let Some(transaction_extensions) = ext.transaction_extensions() {
				for transaction_extension in transaction_extensions.iter() {
					let name = transaction_extension.name();
					let value = transaction_extension.value()?.to_string();
					println!("        {name}: {value}");
				}
			}
		}
	}

	Ok(())
}