alloy_provider/provider/eth_call/
caller.rs

1use super::{EthCallManyParams, EthCallParams};
2use crate::ProviderCall;
3use alloy_json_rpc::RpcRecv;
4use alloy_network::Network;
5use alloy_rpc_client::WeakClient;
6use alloy_transport::{TransportErrorKind, TransportResult};
7
8/// Trait that helpes convert `EthCall` into a `ProviderCall`.
9pub trait Caller<N, Resp>: Send + Sync
10where
11    N: Network,
12    Resp: RpcRecv,
13{
14    /// Method that needs to be implemented to convert to a `ProviderCall`.
15    ///
16    /// This method sends the request to relevant data source and returns a `ProviderCall`.
17    fn call(
18        &self,
19        params: EthCallParams<N>,
20    ) -> TransportResult<ProviderCall<EthCallParams<N>, Resp>>;
21
22    /// Method that needs to be implemented for estimating gas using "eth_estimateGas" for the
23    /// transaction.
24    fn estimate_gas(
25        &self,
26        params: EthCallParams<N>,
27    ) -> TransportResult<ProviderCall<EthCallParams<N>, Resp>>;
28
29    /// Method that needs to be implemented for `"eth_callMany"` RPC requests.
30    fn call_many(
31        &self,
32        params: EthCallManyParams<'_>,
33    ) -> TransportResult<ProviderCall<EthCallManyParams<'static>, Resp>>;
34}
35
36impl<N, Resp> Caller<N, Resp> for WeakClient
37where
38    N: Network,
39    Resp: RpcRecv,
40{
41    fn call(
42        &self,
43        params: EthCallParams<N>,
44    ) -> TransportResult<ProviderCall<EthCallParams<N>, Resp>> {
45        provider_rpc_call(self, "eth_call", params)
46    }
47
48    fn estimate_gas(
49        &self,
50        params: EthCallParams<N>,
51    ) -> TransportResult<ProviderCall<EthCallParams<N>, Resp>> {
52        provider_rpc_call(self, "eth_estimateGas", params)
53    }
54
55    fn call_many(
56        &self,
57        params: EthCallManyParams<'_>,
58    ) -> TransportResult<ProviderCall<EthCallManyParams<'static>, Resp>> {
59        let client = self.upgrade().ok_or_else(TransportErrorKind::backend_gone)?;
60
61        let rpc_call = client.request("eth_callMany", params.into_owned());
62
63        Ok(ProviderCall::RpcCall(rpc_call))
64    }
65}
66
67/// Returns a [`ProviderCall::RpcCall`] from the provided method and [`EthCallParams`].
68fn provider_rpc_call<N: Network, Resp: RpcRecv>(
69    client: &WeakClient,
70    method: &'static str,
71    params: EthCallParams<N>,
72) -> TransportResult<ProviderCall<EthCallParams<N>, Resp>> {
73    let client = client.upgrade().ok_or_else(TransportErrorKind::backend_gone)?;
74
75    let rpc_call = client.request(method, params);
76
77    Ok(ProviderCall::RpcCall(rpc_call))
78}
alloy_provider/provider/eth_call/caller.rs

alloy_provider/provider/eth_call/
caller.rs
