ethrpc-rs 0.3.0

//! High-level [`Api`] wrapper with convenience methods for common calls.

use serde::de::DeserializeOwned;
use serde_json::Value;

use crate::decode::ValueExt;
use crate::error::Result;
use crate::rpc::Handler;

/// Wraps any [`Handler`] and provides convenience methods for common Ethereum
/// RPC calls.
pub struct Api<H: Handler> {
    /// The underlying handler.
    pub handler: H,
}

impl<H: Handler> Api<H> {
    /// Wraps `handler` in an [`Api`].
    pub fn new(handler: H) -> Api<H> {
        Api { handler }
    }

    /// Performs a JSON-RPC call with positional arguments.
    pub async fn call(&self, method: &str, params: Vec<Value>) -> Result<Value> {
        self.handler.call(method, params).await
    }

    /// Performs a call and deserializes the result into `T` via serde.
    pub async fn call_as<T: DeserializeOwned>(
        &self,
        method: &str,
        params: Vec<Value>,
    ) -> Result<T> {
        Ok(serde_json::from_value(
            self.handler.call(method, params).await?,
        )?)
    }

    /// Returns the current block number from the connected node.
    pub async fn block_number(&self) -> Result<u64> {
        self.handler.call("eth_blockNumber", vec![]).await?.to_u64()
    }

    /// Returns the chain id of the connected network.
    pub async fn chain_id(&self) -> Result<u64> {
        self.handler.call("eth_chainId", vec![]).await?.to_u64()
    }
}