pezkuwi-subxt/subxt/examples/block_decoding_dynamic.rs

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

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
	// Create a client that subscribes to blocks of the Pezkuwi network.
	let api = OnlineClient::<PezkuwiConfig>::from_url("wss://rpc.pezkuwi.io:443").await?;

	// Subscribe to all finalized blocks:
	let mut blocks_sub = api.blocks().subscribe_finalized().await?;
	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}  ({block_hash})");

		// Decode each signed extrinsic in the block dynamically
		let extrinsics = block.extrinsics().await?;
		for ext in extrinsics.iter() {
			let Some(transaction_extensions) = ext.transaction_extensions() else {
				continue; // we do not look at inherents in this example
			};

			// Decode the fields into our dynamic Value type to display:
			let fields = ext.decode_as_fields::<scale_value::Value>()?;

			println!("  {}/{}", ext.pallet_name(), ext.call_name());
			println!("    Transaction Extensions:");
			for signed_ext in transaction_extensions.iter() {
				// We only want to take a look at these 3 signed extensions, because the others all
				// just have unit fields.
				if ["CheckMortality", "CheckNonce", "ChargeTransactionPayment"]
					.contains(&signed_ext.name())
				{
					println!("      {}: {}", signed_ext.name(), signed_ext.value()?);
				}
			}
			println!("    Fields:");
			println!("      {fields}\n");
		}
	}

	Ok(())
}