Struct DaemonAsyncBase 

pub struct DaemonAsyncBase<Sender = Wallet> { /* private fields */ }

Represents a blockchain node. It’s constructed using DaemonAsyncBuilder.

Usage

use cw_orch_daemon::{DaemonAsync, networks};

let daemon: DaemonAsync = DaemonAsync::builder(networks::JUNO_1)
    .build()
    .await.unwrap();

Environment Execution

The DaemonAsync implements async methods of TxHandler which allows you to perform transactions on the chain.

Querying

Different Cosmos SDK modules can be queried through the daemon by calling the [DaemonAsync::query_client<Querier>] method with a specific querier. See Querier for examples.

Warning

This daemon is thread safe and can be used between threads. However, please make sure that you are not trying to broadcast multiple transactions at once when using this Daemon on different threads. If you do so, you will get account sequence errors and your transactions won’t get broadcasted.

Implementations

impl<Sender> DaemonAsyncBase<Sender>

pub fn chain_info(&self) -> &ChainInfoOwned

pub fn builder(chain: impl Into<ChainInfoOwned>) -> DaemonAsyncBuilder

Get the daemon builder

pub async fn new_sender<T: SenderBuilder>( self, sender_options: T, ) -> DaemonAsyncBase<T::Sender>

Set the Sender for use with this Daemon The sender will be configured with the chain’s data.

pub fn sender_mut(&mut self) -> &mut Sender

Get a mutable Sender

pub fn sender(&self) -> &Sender

pub fn flush_state(&mut self) -> Result<(), DaemonError>

Flushes all the state related to the current chain Only works on Local networks

pub fn rebuild(&self) -> DaemonAsyncBuilder

Returns a new DaemonAsyncBuilder with the current configuration. Does not consume the original DaemonAsync.

impl<Sender: QuerySender> DaemonAsyncBase<Sender>

pub fn channel(&self) -> Channel

Get the channel configured for this DaemonAsync.

pub async fn query<Q: Serialize + Debug, T: Serialize + DeserializeOwned>( &self, query_msg: &Q, contract_address: &Addr, ) -> Result<T, DaemonError>

Query a contract.

pub async fn wait_blocks(&self, amount: u64) -> Result<(), DaemonError>

Wait for a given amount of blocks.

pub async fn wait_seconds(&self, secs: u64) -> Result<(), DaemonError>

Wait for a given amount of seconds.

pub async fn next_block(&self) -> Result<(), DaemonError>

Wait for the next block.

pub async fn block_info(&self) -> Result<BlockInfo, DaemonError>

Get the current block info.

impl<Sender: TxSender> DaemonAsyncBase<Sender>

pub fn sender_addr(&self) -> Addr

Get the sender address

pub async fn execute<E: Serialize>( &self, exec_msg: &E, coins: &[Coin], contract_address: &Addr, ) -> Result<CosmTxResponse, DaemonError>

Execute a message on a contract.

pub async fn instantiate<I: Serialize + Debug>( &self, code_id: u64, init_msg: &I, label: Option<&str>, admin: Option<&Addr>, coins: &[Coin], ) -> Result<CosmTxResponse, DaemonError>

Instantiate a contract.

pub async fn instantiate2<I: Serialize + Debug>( &self, code_id: u64, init_msg: &I, label: Option<&str>, admin: Option<&Addr>, coins: &[Coin], salt: Binary, ) -> Result<CosmTxResponse, DaemonError>

Instantiate a contract.

pub async fn migrate<M: Serialize + Debug>( &self, migrate_msg: &M, new_code_id: u64, contract_address: &Addr, ) -> Result<CosmTxResponse, DaemonError>

Migration a contract.

pub async fn upload<T: Uploadable>( &self, uploadable: &T, ) -> Result<CosmTxResponse, DaemonError>

Upload a contract to the chain.

pub async fn upload_with_access_config<T: Uploadable>( &self, _uploadable: &T, access: Option<AccessConfig>, ) -> Result<CosmTxResponse, DaemonError>

Upload a contract to the chain and specify the permissions for instantiating

Trait Implementations

impl<Sender> ChainState for DaemonAsyncBase<Sender>

type Out = DaemonState

The type of the underlying state.

fn state(&self) -> Self::Out

Get the underlying state.

fn can_load_state_from_state_file(&self) -> bool

Returns wether this environment can load state from the state file.

impl<Sender: Clone> Clone for DaemonAsyncBase<Sender>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.