eth_call

Author: F3kilo

src/ethereum-json-rpc-client/src/lib.rs

@@ -4,7 +4,8 @@ use std::pin::Pin;
 use anyhow::Context;
 use did::transaction::StorableExecutionResult;
 use ethers_core::types::{
-    Block, BlockNumber, Log, Transaction, TransactionReceipt, H160, H256, U256, U64,
+    Block, BlockNumber, Log, Transaction, TransactionReceipt, TransactionRequest, H160, H256, U256,
+    U64,
 };
 use itertools::Itertools;
 use jsonrpc_core::{Call, Id, MethodCall, Output, Params, Request, Response, Version};
@@ -27,6 +28,7 @@ const ETH_GET_TRANSACTION_COUNT_METHOD: &str = "eth_getTransactionCount";
 const ETH_GET_BLOCK_BY_NUMBER_METHOD: &str = "eth_getBlockByNumber";
 const ETH_BLOCK_NUMBER_METHOD: &str = "eth_blockNumber";
 const ETH_GET_TRANSACTION_RECEIPT_METHOD: &str = "eth_getTransactionReceipt";
+const ETH_CALL_METHOD: &str = "eth_call";
 const ETH_SEND_RAW_TRANSACTION_METHOD: &str = "eth_sendRawTransaction";
 const ETH_GET_LOGS_METHOD: &str = "eth_getLogs";
 const IC_GET_TX_EXECUTION_RESULT_BY_HASH_METHOD: &str = "ic_getExeResultByHash";
@@ -186,12 +188,26 @@ impl<C: Client> EthJsonRpcClient<C> {
         .map(|v| v.as_u64())
     }
 
+    /// Performs eth call and return the result.
+    pub async fn eth_call(
+        &self,
+        params: TransactionRequest,
+        block: BlockNumber,
+    ) -> anyhow::Result<String> {
+        self.single_request(
+            ETH_CALL_METHOD.to_string(),
+            make_params_array!(params, block),
+            Id::Str("eth_call".to_string()),
+        )
+        .await
+    }
+
     /// Sends raw transaction and returns transaction hash
     pub async fn send_raw_transaction(&self, transaction: Transaction) -> anyhow::Result<H256> {
         let bytes = transaction.rlp();
         let transaction = format!("0x{}", hex::encode(bytes));
 
-        self.single_request::<H256>(
+        self.single_request(
             ETH_SEND_RAW_TRANSACTION_METHOD.to_string(),
             make_params_array!(transaction),
             Id::Str("send_rawTransaction".to_string()),

src/ethereum-json-rpc-client/tests/reqwest/mod.rs

@@ -1,6 +1,7 @@
 use ethereum_json_rpc_client::reqwest::ReqwestClient;
 use ethereum_json_rpc_client::{EthGetLogsParams, EthJsonRpcClient};
-use ethers_core::types::{BlockNumber, Log, H256};
+use ethers_core::abi::{Function, Param, ParamType, StateMutability, Token};
+use ethers_core::types::{BlockNumber, Log, TransactionRequest, H160, H256};
 
 const ETHEREUM_JSON_API_URL: &str = "https://cloudflare-eth.com/";
 const MAX_BATCH_SIZE: usize = 5;
@@ -47,6 +48,65 @@ async fn should_get_code() {
     assert_eq!(result, ERC_1820_EXPECTED_CODE);
 }
 
+/// Calls the funtction of ERC-1820:
+///
+///```solidity
+///     function getManager(address _addr) public view returns(address)
+///```
+#[tokio::test]
+async fn should_perform_eth_call() {
+    let erc_1820_address = "0x1820a4B7618BdE71Dce8cdc73aAB6C95905faD24"
+        .parse::<H160>()
+        .unwrap();
+
+    let caller = "0xf990077c3205cbDf861e17Fa532eeB069cE9fF96"
+        .parse()
+        .unwrap();
+
+    #[allow(deprecated)]
+    let func = Function {
+        name: "getManager".to_string(),
+        inputs: vec![Param {
+            name: "getManager".to_string(),
+            kind: ParamType::Address,
+            internal_type: None,
+        }],
+        outputs: vec![Param {
+            name: "".to_string(),
+            kind: ParamType::Address,
+            internal_type: None,
+        }],
+        constant: None,
+        state_mutability: StateMutability::View,
+    };
+
+    let params = TransactionRequest {
+        from: Some(caller),
+        to: Some(erc_1820_address.into()),
+        gas: Some(1000000u64.into()),
+        gas_price: None,
+        value: None,
+        data: Some(func.encode_input(&[Token::Address(caller)]).unwrap().into()),
+        ..Default::default()
+    };
+
+    let result = reqwest_client()
+        .eth_call(params, BlockNumber::Latest)
+        .await
+        .unwrap();
+
+    let result_address = func
+        .decode_output(&hex::decode(result.trim_start_matches("0x")).unwrap())
+        .unwrap()
+        .first()
+        .cloned()
+        .unwrap()
+        .into_address()
+        .unwrap();
+
+    assert_eq!(result_address, caller);
+}
+
 #[tokio::test]
 async fn should_get_transaction_count() {
     let erc_1820_deployer_address = "0xa990077c3205cbDf861e17Fa532eeB069cE9fF96"