Add eth proof generation utilities

eth2near/Cargo.toml

@@ -7,6 +7,7 @@ members = [
     "eth_rpc_client",
     "finality-update-verify",
     "logger",
+    "utilities",
 ]
 
 [workspace.dependencies]

eth2near/utilities/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+name = "utilities"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+reqwest = { version = "0.11", features = ["blocking", "json"] }
+serde_json = "1.0.74"
+serde = { version = "1.0", features = ["derive"] }
+hex = { version="0.4", features = ["serde"] }
+num-traits = "0.2"
+cita_trie = "5.0.1"
+hasher = "0.1.4"
+rlp = "0.5.2"

eth2near/utilities/src/eth_rpc_client.rs

@@ -0,0 +1,88 @@
+use crate::{
+    primitives::U256,
+    types::{BlockHeader, TransactionReceipt},
+};
+use reqwest::blocking::Client;
+use serde::Deserialize;
+use serde_json::{json, Value};
+use std::error::Error;
+
+pub struct EthRPCClient {
+    endpoint_url: String,
+    client: Client,
+}
+
+impl EthRPCClient {
+    pub fn new(endpoint_url: &str) -> Self {
+        Self {
+            endpoint_url: endpoint_url.to_string(),
+            client: reqwest::blocking::Client::new(),
+        }
+    }
+
+    pub fn get_transaction_receipt_by_hash(&self, tx_hash: &U256,) -> Result<TransactionReceipt, Box<dyn Error>> {
+        let json_value = json!({
+            "id": 1,
+            "jsonrpc": "2.0",
+            "method": "eth_getTransactionReceipt",
+            "params": [tx_hash.0]
+        });
+
+        let res = self
+            .client
+            .post(&self.endpoint_url)
+            .json(&json_value)
+            .send()?
+            .text()?;
+
+        let val: Value = serde_json::from_str(&res)?;
+        let receipt = TransactionReceipt::deserialize(&val["result"])?;
+
+        Ok(receipt)
+    }
+
+    pub fn get_block_by_number(&self, block_number: u64) -> Result<BlockHeader, Box<dyn Error>> {
+        let json_value = json!({
+            "id": 1,
+            "jsonrpc": "2.0",
+            "method": "eth_getBlockByNumber",
+            "params": [format!("0x{:x}", block_number), false]
+        });
+
+        let res = self
+            .client
+            .post(&self.endpoint_url)
+            .json(&json_value)
+            .send()?
+            .text()?;
+
+        let val: Value = serde_json::from_str(&res)?;
+        let header = BlockHeader::deserialize(&val["result"])?;
+
+        Ok(header)
+    }
+
+    pub fn get_block_receipts(
+        &self,
+        block_number: u64,
+    ) -> Result<Vec<TransactionReceipt>, Box<dyn Error>> {
+        let json_value = json!({
+            "id": 1,
+            "jsonrpc": "2.0",
+            "method": "eth_getBlockReceipts",
+            "params": [format!("0x{:x}", block_number)]
+        });
+
+        let res = self
+            .client
+            .post(&self.endpoint_url)
+            .json(&json_value)
+            .send()?
+            .text()?;
+
+        let val: Value = serde_json::from_str(&res)?;
+        let receipts = Vec::<TransactionReceipt>::deserialize(&val["result"])?;
+
+        Ok(receipts)
+    }
+}

eth2near/utilities/src/lib.rs

@@ -0,0 +1,5 @@
+pub mod eth_rpc_client;
+pub mod eth_proof_generator;
+mod primitives;
+mod types;
+mod serde;

eth2near/utilities/src/primitives.rs

@@ -0,0 +1,10 @@
+#[derive(Debug, Clone)]
+pub struct FixedBytes<const N: usize>(pub [u8; N]);
+#[derive(Debug, Clone)]
+pub struct Bytes(pub Vec<u8>);
+#[derive(Debug, Clone)]
+pub struct Byte(pub u8);
+
+pub type U256 = FixedBytes<32>;
+pub type Address = FixedBytes<20>;
+pub type Bloom = FixedBytes<256>;