cosm-utils 0.1.2

Simple utility traits and functions for tendermint_rpc and cosmrs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use async_trait::async_trait;
use cosmrs::proto::cosmos::base::tendermint::v1beta1::{
    GetLatestBlockRequest, GetLatestBlockResponse, GetLatestValidatorSetRequest,
    GetLatestValidatorSetResponse, GetValidatorSetByHeightRequest, GetValidatorSetByHeightResponse,
};
use tendermint_rpc::Client;

use crate::{chain::request::PaginationRequest, prelude::ClientUtils};

use super::{error::TendermintError, model::ValidatorSetResponse};

impl<T> Tendermint for T where T: Client {}

#[async_trait]
pub trait Tendermint: Client + Sized {
    async fn tendermint_query_latest_block(&self) -> Result<BlockResponse, TendermintError> {
        let req = GetLatestBlockRequest {};

        let res = self
            .query::<_, GetLatestBlockResponse>(
                req,
                "/cosmos.base.tendermint.v1beta1.Service/GetLatestBlock",
            )
            .await?;

        res.try_into()
    }

    async fn tendermint_query_latest_validator_set(
        &self,
        pagination: Option<PaginationRequest>,
    ) -> Result<ValidatorSetResponse, TendermintError> {
        let req = GetLatestValidatorSetRequest {
            pagination: pagination.map(Into::into),
        };

        let res = self
            .query::<_, GetLatestValidatorSetResponse>(
                req,
                "/cosmos.base.tendermint.v1beta1.Service/GetLatestValidatorSet",
            )
            .await?;

        res.try_into()
    }

    async fn tendermint_query_validator_set_at_height(
        &self,
        block_height: u64,
        pagination: Option<PaginationRequest>,
    ) -> Result<ValidatorSetResponse, TendermintError> {
        let req = GetValidatorSetByHeightRequest {
            height: block_height as i64,
            pagination: pagination.map(Into::into),
        };

        let res = self
            .query::<_, GetValidatorSetByHeightResponse>(
                req,
                "/cosmos.base.tendermint.v1beta1.Service/GetValidatorSetByHeight",
            )
            .await?;

        res.try_into()
    }
}