Struct ibc_test_framework::chain::driver::ChainDriver

pub struct ChainDriver {

    pub chain_type: ChainType,
    pub command_path: String,
    pub chain_id: ChainId,
    pub home_path: String,
    pub account_prefix: String,
    pub rpc_port: u16,
    pub grpc_port: u16,
    pub grpc_web_port: u16,
    pub p2p_port: u16,
    pub pprof_port: u16,
    pub tx_config: TxConfig,
    pub runtime: Arc<Runtime>,
    pub compat_mode: Option<CompatMode>,
}

A driver for interacting with a chain full nodes through command line.

The name ChainDriver is inspired by WebDriver, which is the term used to describe programs that control spawning of the web browsers. In our case, the ChainDriver is used to spawn and manage chain full nodes.

Currently the ChainDriver is hardcoded to support only a single version of Gaia chain. In the future, we will want to turn this into one or more ChainDriver traits so that they can be used to spawn multiple chain implementations other than a single version of Gaia.

Fields

chain_type: ChainType

command_path: String

The filesystem path to the Gaia CLI. Defaults to gaiad.

chain_id: ChainId

The ID of the chain.

home_path: String

The home directory for the full node to store data files.

account_prefix: String

rpc_port: u16

The port used for RPC.

grpc_port: u16

The port used for GRPC.

grpc_web_port: u16

p2p_port: u16

The port used for P2P. (Currently unused other than for setup)

pprof_port: u16

The port used for pprof. (Currently unused other than for setup)

tx_config: TxConfig

runtime: Arc<Runtime>

compat_mode: Option<CompatMode>

Implementations

impl ChainDriver

pub fn create( chain_type: ChainType, command_path: String, chain_id: ChainId, home_path: String, account_prefix: String, rpc_port: u16, grpc_port: u16, grpc_web_port: u16, p2p_port: u16, pprof_port: u16, runtime: Arc<Runtime>, native_token: String, compat_mode: Option<CompatMode> ) -> Result<Self, Error>

Create a new ChainDriver

pub fn rpc_address(&self) -> String

Returns the full URL for the RPC address.

pub fn websocket_address(&self) -> String

Returns the full URL for the WebSocket address.

pub fn grpc_address(&self) -> String

Returns the full URL for the GRPC address.

pub fn rpc_listen_address(&self) -> String

Returns the full URL for the RPC address to listen to when starting the full node.

This is somehow different from rpc_address as it requires the "tcp://" scheme.

pub fn grpc_listen_address(&self) -> String

Returns the full URL for the GRPC address to listen to when starting the full node.

This is somehow different from grpc_address as it requires no scheme to be specified.

pub fn query_balance( &self, wallet_id: &WalletAddress, denom: &Denom ) -> Result<Amount, Error>

Query for the balances for a given wallet address and denomination

pub fn assert_eventual_wallet_amount( &self, wallet: &WalletAddress, token: &Token ) -> Result<(), Error>

Assert that a wallet should eventually have the expected amount in the given denomination.

Trait Implementations

impl ChainBootstrapMethodsExt for ChainDriver

fn read_file(&self, file_path: &str) -> Result<String, Error>

Read the content at a file path relative to the chain home directory, and return the result as a string.

fn write_file(&self, file_path: &str, content: &str) -> Result<(), Error>

Write the string content to a file path relative to the chain home directory.

fn update_chain_config( &self, file: &str, cont: impl FnOnce(&mut Value) -> Result<(), Error> ) -> Result<(), Error>

Modify the Gaia chain config which is saved in toml format.

fn initialize(&self) -> Result<(), Error>

Initialized the chain data stores.

fn update_genesis_file( &self, file: &str, cont: impl FnOnce(&mut Value) -> Result<(), Error> ) -> Result<(), Error>

Modify the Gaia genesis file.

fn add_wallet(&self, wallet_id: &str) -> Result<Wallet, Error>

Add a wallet with the given ID to the full node’s keyring.

fn add_genesis_account( &self, wallet: &WalletAddress, amounts: &[&Token] ) -> Result<(), Error>

Add a wallet address to the genesis account list for an uninitialized full node.

fn add_genesis_validator( &self, wallet_id: &WalletId, token: &Token ) -> Result<(), Error>

Add a wallet ID with the given stake amount to be the genesis validator for an uninitialized chain.

fn collect_gen_txs(&self) -> Result<(), Error>

Call gaiad collect-gentxs to generate the genesis transactions.

fn start(&self) -> Result<ChildProcess, Error>

Start a full node by running in the background gaiad start.

fn submit_consumer_chain_proposal( &self, consumer_chain_id: &str, _spawn_time: &str ) -> Result<(), Error>

Submit a consumer chain proposal.

fn assert_consumer_chain_proposal_submitted( &self, chain_id: &str, command_path: &str, home_path: &str, rpc_listen_address: &str ) -> Result<(), Error>

Assert that the consumer chain proposal is eventually submitted.

fn assert_consumer_chain_proposal_passed( &self, chain_id: &str, command_path: &str, home_path: &str, rpc_listen_address: &str ) -> Result<(), Error>

Assert that the consumer chain proposal eventually passes.

fn query_consumer_genesis( &self, consumer_chain_driver: &ChainDriver, consumer_chain_id: &str ) -> Result<(), Error>

Query a consumer chain’s genesis.

fn replace_genesis_state(&self) -> Result<(), Error>

Replace genesis state.

fn copy_validator_key_pair( &self, provider_chain_driver: &ChainDriver ) -> Result<(), Error>

Copy validator key pair.

impl Clone for ChainDriver

fn clone(&self) -> ChainDriver

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ChainDriver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ExportEnv for ChainDriver

fn export_env(&self, writer: &mut impl EnvWriter)

Export the environment variables using the given EnvWriter.