celestia-grpc 0.8.0

A client for interacting with Celestia validator nodes gRPC
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
67
68
69
70
71
72

use celestia_proto::celestia::core::v1::gas_estimation::{
    EstimateGasPriceAndUsageRequest, EstimateGasPriceAndUsageResponse, EstimateGasPriceRequest,
    EstimateGasPriceResponse,
};
use serde::{Deserialize, Serialize};

use crate::grpc::{FromGrpcResponse, IntoGrpcParam};
use crate::Result;

/// TxPriority is the priority level of the requested gas price.
#[derive(Debug, Default, Clone, Copy, PartialEq, Serialize, Deserialize)]
#[cfg_attr(feature = "uniffi", derive(uniffi::Enum))]
#[cfg_attr(
    all(feature = "wasm-bindgen", target_arch = "wasm32"),
    wasm_bindgen::prelude::wasm_bindgen
)]
#[repr(i32)]
pub enum TxPriority {
    /// Estimated gas price is the value at the end of the lowest 10% of gas prices from the last 5 blocks.
    Low = 1,
    /// Estimated gas price is the mean of all gas prices from the last 5 blocks.
    #[default]
    Medium = 2,
    /// Estimated gas price is the price at the start of the top 10% of transactions’ gas prices from the last 5 blocks.
    High = 3,
}

/// Result of gas price and usage estimation
#[derive(Debug, Clone, Copy, PartialEq, Serialize, Deserialize)]
#[cfg_attr(feature = "uniffi", derive(uniffi::Record))]
#[cfg_attr(
    all(feature = "wasm-bindgen", target_arch = "wasm32"),
    wasm_bindgen::prelude::wasm_bindgen
)]
pub struct GasEstimate {
    /// Gas price estimated based on last 5 blocks
    pub price: f64,
    /// Simulated transaction gas usage
    pub usage: u64,
}

impl IntoGrpcParam<EstimateGasPriceRequest> for TxPriority {
    fn into_parameter(self) -> EstimateGasPriceRequest {
        EstimateGasPriceRequest {
            tx_priority: self as i32,
        }
    }
}

impl FromGrpcResponse<f64> for EstimateGasPriceResponse {
    fn try_from_response(self) -> Result<f64> {
        Ok(self.estimated_gas_price)
    }
}

impl IntoGrpcParam<EstimateGasPriceAndUsageRequest> for (TxPriority, Vec<u8>) {
    fn into_parameter(self) -> EstimateGasPriceAndUsageRequest {
        EstimateGasPriceAndUsageRequest {
            tx_priority: self.0 as i32,
            tx_bytes: self.1,
        }
    }
}

impl FromGrpcResponse<GasEstimate> for EstimateGasPriceAndUsageResponse {
    fn try_from_response(self) -> Result<GasEstimate> {
        Ok(GasEstimate {
            price: self.estimated_gas_price,
            usage: self.estimated_gas_used,
        })
    }
}