utils.rs

use crate::*;
use sea_orm::DbErr;

/// track progress of transaction on the network
/// until it is in block with success or failure
pub async fn track_progress(
	mut progress: TxProgress,
) -> Result<ExtrinsicEvents<Runtime>, subxt::Error> {
	loop {
		if let Some(status) = progress.next().await {
			match status? {
				TxStatus::Validated => {
					println!("transaction submitted to the network, waiting 6 seconds...");
				}
				TxStatus::InBestBlock(in_block) => break in_block,
				TxStatus::Invalid { message } => {
					println!("Invalid {message}");
				}
				_ => continue,
			}
		}
	}
	.wait_for_success()
	.await
}

/// generic extrinsic submitter
pub async fn submit_call_and_look_event<
	E: std::fmt::Debug + StaticEvent + DisplayEvent,
	TxPayload: Payload,
>(
	data: &Data,
	payload: &TxPayload,
) -> Result<(), subxt::Error> {
	// submit call
	let progress = submit_call(data, payload).await?;
	// if no wait, return immediately
	if data.args.no_wait {
		return Ok(());
	}
	// collect events
	let events = track_progress(progress).await?;
	// print given event if there
	look_event::<E>(data, &events)
}

/// submit call
pub async fn submit_call<TxPayload: Payload>(
	data: &Data,
	payload: &TxPayload,
) -> Result<TxProgress, subxt::Error> {
	// get account nonce manually to be based on last block and not last finalized
	let nonce = data
		.legacy_rpc_methods() // see issue #32
		.await
		.system_account_next_index(&data.address())
		.await?;

	// sign and submit
	match data.keypair().await {
		// sr25519 key pair
		KeyPair::Sr25519(keypair) => data.client().tx().create_signed_offline(
			payload,
			&PairSigner::<Runtime, sp_core::sr25519::Pair>::new(keypair),
			DefaultExtrinsicParamsBuilder::new().nonce(nonce).build(),
		),
		KeyPair::Ed25519(keypair) => data.client().tx().create_signed_offline(
			payload,
			&PairSigner::<Runtime, sp_core::ed25519::Pair>::new(keypair),
			DefaultExtrinsicParamsBuilder::new().nonce(nonce).build(),