use subxt::dynamic::Value;
use subxt::{Error, OnlineClient, PolkadotConfig};
#[tokio::main]
async fn main() -> Result<(), Error> {
let api = OnlineClient::<PolkadotConfig>::from_url("wss://rpc.polkadot.io").await?;
for block_number in 1234567u32.. {
let at_block = api.at_block(block_number).await?;
let block_number = at_block.block_number();
let block_hash = at_block.block_hash();
println!("Block #{block_number}:");
println!(" Hash: {block_hash}");
println!(" Extrinsics:");
let extrinsics = at_block.extrinsics().fetch().await?;
for ext in extrinsics.iter() {
let ext = ext?;
let idx = ext.index();
let pallet_name = ext.pallet_name();
let call_name = ext.call_name();
let bytes_hex = format!("0x{}", hex::encode(ext.bytes()));
let events = ext.events().await?;
let decoded_ext = ext.decode_call_data_fields_unchecked_as::<Value>()?;
println!(" #{idx}: {pallet_name}.{call_name}:");
println!(" Bytes: {bytes_hex}");
println!(" Decoded: {decoded_ext}");
for evt in events.iter() {
println!(" Events:");
let evt = evt?;
let event_idx = evt.event_index();
let pallet_name = evt.pallet_name();
let event_name = evt.event_name();
let event_values = evt.decode_fields_unchecked_as::<Value>()?;
println!(" #{event_idx}: {pallet_name}.{event_name}");
println!(" {event_values}");
}
}
}
Ok(())
}