Struct DaemonBase 

pub struct DaemonBase<Sender> {
    pub daemon: DaemonAsyncBase<Sender>,
    pub rt_handle: Handle,
}

Represents a blockchain node. Is constructed with the DaemonBuilder.

Usage

use cw_orch_daemon::{Daemon, networks};
use tokio::runtime::Runtime;

let rt = Runtime::new().unwrap();
let daemon: Daemon = Daemon::builder(networks::JUNO_1)
    .build()
    .unwrap();

Environment Execution

The Daemon implements TxHandler which allows you to perform transactions on the chain.

Querying

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

Fields

daemon: DaemonAsyncBase<Sender>

rt_handle: Handle

Runtime handle to execute async tasks

Implementations

impl<Sender> DaemonBase<Sender>

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

Get the daemon builder

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

Get the mutable Sender object

pub fn sender(&self) -> &Sender

Get a read-only Sender

pub fn new_sender<T: SenderBuilder>( self, sender_options: T, ) -> DaemonBase<<T as SenderBuilder>::Sender>

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

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

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

pub fn chain_info(&self) -> &ChainInfoOwned

Return the chain info for this daemon

impl<Sender: QuerySender> DaemonBase<Sender>

pub fn channel(&self) -> Channel

Get the channel configured for this Daemon

pub fn rebuild(&self) -> DaemonBuilder

Returns a new DaemonBuilder with the current configuration. Does not copy the Sender Does not consume the original Daemon.

impl DaemonBase<CosmosSender<All>>

pub fn authz_granter(&mut self, granter: &Addr) -> &mut Self

👎Deprecated:

Use self.sender_mut().set_authz_granter(granter) or change the sender builder options instead

Specifies wether authz should be used with this daemon

pub fn fee_granter(&mut self, granter: &Addr) -> &mut Self

👎Deprecated:

Use self.sender_mut().set_fee_granter(granter) or change the sender builder options instead

Specifies wether feegrant should be used with this daemon

Trait Implementations

impl<Sender> ChainState for DaemonBase<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 DaemonBase<Sender>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Sender: QuerySender> DefaultQueriers for DaemonBase<Sender>

type Bank = Bank

type Wasm = CosmWasmBase<Sender>

type Node = Node

fn bank_querier(&self) -> Self::Bank

fn wasm_querier(&self) -> Self::Wasm

fn node_querier(&self) -> Self::Node

impl<Sender: QuerySender> EnvironmentQuerier for DaemonBase<Sender>

fn env_info(&self) -> EnvironmentInfo

Get some details about the environment.

impl<Sender: QuerySender> QuerierGetter<Bank> for DaemonBase<Sender>

fn querier(&self) -> Bank

impl<Sender: QuerySender> QuerierGetter<CosmWasmBase<Sender>> for DaemonBase<Sender>

fn querier(&self) -> CosmWasmBase<Sender>

impl<Sender: QuerySender> QuerierGetter<Node> for DaemonBase<Sender>

fn querier(&self) -> Node

impl<Sender: QuerySender> QueryHandler for DaemonBase<Sender>

type Error = DaemonError

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

Wait for an amount of blocks.

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

Wait for an amount of seconds.

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

Wait for next block.

fn block_info(&self) -> Result<BlockInfo, <Self::Node as Querier>::Error>

Return current block info see BlockInfo.

fn balance( &self, address: &Addr, denom: Option<String>, ) -> Result<Vec<Coin>, <Self::Bank as Querier>::Error>

fn query<Q, T>( &self, query_msg: &Q, contract_address: &Addr, ) -> Result<T, <Self::Wasm as Querier>::Error>

where Q: Serialize + Debug, T: DeserializeOwned,

Send a QueryMsg to a contract.

impl<Sender: TxSender> Stargate for DaemonBase<Sender>

fn commit_any( &self, msgs: Vec<Any>, memo: Option<&str>, ) -> Result<Self::Response, Self::Error>

Execute a custom abci/starship message on the environment The message should already be encoded as protobuf any

impl<Sender: TxSender> TxHandler for DaemonBase<Sender>

fn set_sender(&mut self, sender: Self::Sender)

Overwrite the sender manually, could result in unexpected behavior. Use native Daemon::new_sender instead!

type Response = CosmTxResponse

Response type for transactions on an environment.

type Error = DaemonError

Error type for transactions on an environment.

type ContractSource = WasmPath

Source type for uploading to the environment.

type Sender = Sender

fn sender(&self) -> &Self::Sender

Get a read-only Sender

fn sender_addr(&self) -> Addr

Gets the address of the current wallet used to sign transactions.

fn upload<T: Uploadable>( &self, uploadable: &T, ) -> Result<Self::Response, DaemonError>

Uploads a contract to the chain.

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

Send a ExecMsg to a contract.

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

Send a InstantiateMsg to a contract.

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

Send a MigrateMsg to a contract.

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

Send a Instantiate2Msg to a contract.

fn upload_with_access_config<T: Uploadable>( &self, contract_source: &T, access_config: Option<AccessConfig>, ) -> Result<Self::Response, Self::Error>

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

fn bank_send( &self, receiver: &Addr, amount: &[Coin], ) -> Result<Self::Response, Self::Error>

fn call_as(&self, sender: &Self::Sender) -> Self

Clones the chain with a different sender. Usually used to call a contract as a different sender.