Struct GrpcClient 

pub struct GrpcClient { /* private fields */ }

gRPC client for the Celestia network

Under the hood, this struct wraps tonic and does type conversion

Implementations

impl GrpcClient

pub fn builder() -> GrpcClientBuilder

Create a builder for GrpcClient connected to url

pub fn get_auth_params(&self) -> AsyncGrpcCall<AuthParams>

Get auth params

pub fn get_account(&self, account: &AccAddress) -> AsyncGrpcCall<Account>

Get account

pub fn get_accounts(&self) -> AsyncGrpcCall<Vec<Account>>

Get accounts

pub fn get_verified_balance( &self, address: &Address, header: &ExtendedHeader, ) -> AsyncGrpcCall<Coin>

Retrieves the verified Celestia coin balance for the address.

Notes

This returns the verified balance which is the one that was reported by the previous network block. In other words, if you transfer some coins, you need to wait 1 more block in order to see the new balance. If you want something more immediate then use GrpcClient::get_balance.

pub fn get_balance( &self, address: &Address, denom: impl Into<String>, ) -> AsyncGrpcCall<Coin>

Retrieves the Celestia coin balance for the given address.

pub fn get_all_balances(&self, address: &Address) -> AsyncGrpcCall<Vec<Coin>>

Get balance of all coins

pub fn get_spendable_balances( &self, address: &Address, ) -> AsyncGrpcCall<Vec<Coin>>

Get balance of all spendable coins

pub fn get_total_supply(&self) -> AsyncGrpcCall<Vec<Coin>>

Get total supply

pub fn get_node_config(&self) -> AsyncGrpcCall<ConfigResponse>

Get node configuration

pub fn get_latest_block(&self) -> AsyncGrpcCall<Block>

Get latest block

pub fn get_block_by_height(&self, height: i64) -> AsyncGrpcCall<Block>

Get block by height

pub fn abci_query( &self, data: impl AsRef<[u8]>, path: impl Into<String>, height: u64, prove: bool, ) -> AsyncGrpcCall<AbciQueryResponse>

Issue a direct ABCI query to the application

pub fn broadcast_tx( &self, tx_bytes: Vec<u8>, mode: BroadcastMode, ) -> AsyncGrpcCall<TxResponse>

Broadcast prepared and serialised transaction

pub fn get_tx(&self, hash: Hash) -> AsyncGrpcCall<GetTxResponse>

Get Tx

pub fn simulate(&self, tx_bytes: Vec<u8>) -> AsyncGrpcCall<GasInfo>

Broadcast prepared and serialised transaction

pub fn query_delegation( &self, delegator_address: &AccAddress, validator_address: &ValAddress, ) -> AsyncGrpcCall<QueryDelegationResponse>

Retrieves the delegation information between a delegator and a validator

pub fn query_unbonding( &self, delegator_address: &AccAddress, validator_address: &ValAddress, ) -> AsyncGrpcCall<QueryUnbondingDelegationResponse>

Retrieves the unbonding status between a delegator and a validator

pub fn query_redelegations( &self, delegator_address: &AccAddress, src_validator_address: &ValAddress, dest_validator_address: &ValAddress, pagination: Option<PageRequest>, ) -> AsyncGrpcCall<QueryRedelegationsResponse>

Retrieves the status of the redelegations between a delegator and a validator

pub fn get_blob_params(&self) -> AsyncGrpcCall<BlobParams>

Get blob params

pub fn tx_status(&self, hash: Hash) -> AsyncGrpcCall<TxStatusResponse>

Get status of the transaction

pub fn estimate_gas_price(&self, priority: TxPriority) -> AsyncGrpcCall<f64>

Estimate gas price for given transaction priority based on the gas prices of the transactions in the last five blocks.

If no transaction is found in the last five blocks, return the network min gas price.

pub fn estimate_gas_price_and_usage( &self, priority: TxPriority, tx_bytes: Vec<u8>, ) -> AsyncGrpcCall<GasEstimate>

Estimate gas price for transaction with given priority and estimate gas usage for the provided serialised transaction.

The gas price estimation is based on the gas prices of the transactions in the last five blocks. If no transaction is found in the last five blocks, return the network min gas price.

The gas used is estimated using the state machine simulation.

pub fn submit_message<M>( &self, message: M, cfg: TxConfig, ) -> AsyncGrpcCall<TxInfo>

where M: IntoProtobufAny + Send + 'static,

Submit given message to celestia network.

Example

use celestia_grpc::{GrpcClient, TxConfig};
use celestia_proto::cosmos::bank::v1beta1::MsgSend;
use celestia_types::state::{Address, Coin};
use tendermint::crypto::default::ecdsa_secp256k1::SigningKey;

let signing_key = SigningKey::random(&mut rand::rngs::OsRng);
let address = Address::from_account_verifying_key(*signing_key.verifying_key());
let grpc_url = "public-celestia-mocha4-consensus.numia.xyz:9090";

let tx_client = GrpcClient::builder()
    .url(grpc_url)
    .signer_keypair(signing_key)
    .build()
    .unwrap();

let msg = MsgSend {
    from_address: address.to_string(),
    to_address: "celestia169s50psyj2f4la9a2235329xz7rk6c53zhw9mm".to_string(),
    amount: vec![Coin::utia(12345).into()],
};

tx_client
    .submit_message(msg.clone(), TxConfig::default())
    .await
    .unwrap();

pub fn submit_blobs( &self, blobs: &[Blob], cfg: TxConfig, ) -> AsyncGrpcCall<TxInfo>

Submit given blobs to celestia network.

Example

use celestia_grpc::{GrpcClient, TxConfig};
use celestia_types::state::{Address, Coin};
use celestia_types::{AppVersion, Blob};
use celestia_types::nmt::Namespace;
use tendermint::crypto::default::ecdsa_secp256k1::SigningKey;

let signing_key = SigningKey::random(&mut rand::rngs::OsRng);
let address = Address::from_account_verifying_key(*signing_key.verifying_key());
let grpc_url = "public-celestia-mocha4-consensus.numia.xyz:9090";

let tx_client = GrpcClient::builder()
    .url(grpc_url)
    .signer_keypair(signing_key)
    .build()
    .unwrap();

let ns = Namespace::new_v0(b"abcd").unwrap();
let blob = Blob::new(ns, "some data".into(), None, AppVersion::V3).unwrap();

tx_client
    .submit_blobs(&[blob], TxConfig::default())
    .await
    .unwrap();

pub fn app_version(&self) -> AsyncGrpcCall<AppVersion>

Get client’s app version

pub fn chain_id(&self) -> AsyncGrpcCall<Id>

Get client’s chain id

pub fn get_account_pubkey(&self) -> Option<VerifyingKey>

Get client’s account public key if the signer is set

pub fn get_account_address(&self) -> Option<AccAddress>

Get client’s account address if the signer is set

Trait Implementations

impl Clone for GrpcClient

fn clone(&self) -> GrpcClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcClient

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

Formats the value using the given formatter.