mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-05-07 18:58:01 +00:00
James Wilson
33a9ec91af
* First pass adding functions to get blocks and extrinsics * cargo fmt and cache block events * prefix block hash with 0x * pin streams for better ergonomics and add an example of subscribing to blocks * remove unused var * standardise on _all, _best and _finalized for different block header subs * WIP center subscribing around blocks * Remove the event filtering/subscribing stuff * clippy * we need tokio, silly clippy * add extrinsic_index() call * Update subxt/src/blocks/block_types.rs Co-authored-by: Andrew Jones <ascjones@gmail.com> Co-authored-by: Andrew Jones <ascjones@gmail.com>
97 lines
3.2 KiB
Rust
97 lines
3.2 KiB
Rust
// Copyright 2019-2022 Parity Technologies (UK) Ltd.
|
|
// This file is dual-licensed as Apache-2.0 or GPL-3.0.
|
|
// see LICENSE for license details.
|
|
|
|
//! To run this example, a local polkadot node should be running. Example verified against polkadot v0.9.28-9ffe6e9e3da.
|
|
//!
|
|
//! E.g.
|
|
//! ```bash
|
|
//! curl "https://github.com/paritytech/polkadot/releases/download/v0.9.28/polkadot" --output /usr/local/bin/polkadot --location
|
|
//! polkadot --dev --tmp
|
|
//! ```
|
|
|
|
use futures::StreamExt;
|
|
use sp_keyring::AccountKeyring;
|
|
use std::time::Duration;
|
|
use subxt::{
|
|
tx::PairSigner,
|
|
OnlineClient,
|
|
PolkadotConfig,
|
|
};
|
|
|
|
#[subxt::subxt(runtime_metadata_path = "../artifacts/polkadot_metadata.scale")]
|
|
pub mod polkadot {}
|
|
|
|
/// Subscribe to all events, and then manually look through them and
|
|
/// pluck out the events that we care about.
|
|
#[tokio::main]
|
|
async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|
tracing_subscriber::fmt::init();
|
|
|
|
// Create a client to use:
|
|
let api = OnlineClient::<PolkadotConfig>::new().await?;
|
|
|
|
// Subscribe to (in this case, finalized) blocks.
|
|
let mut block_sub = api.blocks().subscribe_finalized().await?;
|
|
|
|
// While this subscription is active, balance transfers are made somewhere:
|
|
tokio::task::spawn({
|
|
let api = api.clone();
|
|
async move {
|
|
let signer = PairSigner::new(AccountKeyring::Alice.pair());
|
|
let mut transfer_amount = 1_000_000_000;
|
|
|
|
// Make small balance transfers from Alice to Bob in a loop:
|
|
loop {
|
|
let transfer_tx = polkadot::tx().balances().transfer(
|
|
AccountKeyring::Bob.to_account_id().into(),
|
|
transfer_amount,
|
|
);
|
|
api.tx()
|
|
.sign_and_submit_default(&transfer_tx, &signer)
|
|
.await
|
|
.unwrap();
|
|
|
|
tokio::time::sleep(Duration::from_secs(10)).await;
|
|
transfer_amount += 100_000_000;
|
|
}
|
|
}
|
|
});
|
|
|
|
// Get each finalized block as it arrives.
|
|
while let Some(block) = block_sub.next().await {
|
|
let block = block?;
|
|
|
|
// Ask for the events for this block.
|
|
let events = block.events().await?;
|
|
|
|
let block_hash = block.hash();
|
|
|
|
// We can dynamically decode events:
|
|
println!(" Dynamic event details: {block_hash:?}:");
|
|
for event in events.iter() {
|
|
let event = event?;
|
|
let is_balance_transfer = event
|
|
.as_event::<polkadot::balances::events::Transfer>()?
|
|
.is_some();
|
|
let pallet = event.pallet_name();
|
|
let variant = event.variant_name();
|
|
println!(
|
|
" {pallet}::{variant} (is balance transfer? {is_balance_transfer})"
|
|
);
|
|
}
|
|
|
|
// Or we can find the first transfer event, ignoring any others:
|
|
let transfer_event =
|
|
events.find_first::<polkadot::balances::events::Transfer>()?;
|
|
|
|
if let Some(ev) = transfer_event {
|
|
println!(" - Balance transfer success: value: {:?}", ev.amount);
|
|
} else {
|
|
println!(" - No balance transfer event found in this block");
|
|
}
|
|
}
|
|
|
|
Ok(())
|
|
}
|