use ethers::{ abi::AbiEncode, types::{Address, Filter, Log, Transaction, TransactionReceipt, H256}, }; use eyre::Result; use log::info; use std::{fmt::Display, net::SocketAddr, str::FromStr, sync::Arc}; use tokio::sync::RwLock; use jsonrpsee::{ core::{async_trait, server::rpc_module::Methods, Error}, http_server::{HttpServerBuilder, HttpServerHandle}, proc_macros::rpc, }; use crate::{errors::NodeError, node::Node}; use common::{ types::BlockTag, utils::{hex_str_to_bytes, u64_to_hex_string}, }; use execution::types::{CallOpts, ExecutionBlock}; pub struct Rpc { node: Arc>, handle: Option, port: u16, } impl Rpc { pub fn new(node: Arc>, port: u16) -> Self { Rpc { node, handle: None, port, } } pub async fn start(&mut self) -> Result { let rpc_inner = RpcInner { node: self.node.clone(), port: self.port, }; let (handle, addr) = start(rpc_inner).await?; self.handle = Some(handle); info!("rpc server started at {}", addr); Ok(addr) } } #[rpc(server, namespace = "eth")] trait EthRpc { #[method(name = "getBalance")] async fn get_balance(&self, address: &str, block: BlockTag) -> Result; #[method(name = "getTransactionCount")] async fn get_transaction_count(&self, address: &str, block: BlockTag) -> Result; #[method(name = "getCode")] async fn get_code(&self, address: &str, block: BlockTag) -> Result; #[method(name = "call")] async fn call(&self, opts: CallOpts, block: BlockTag) -> Result; #[method(name = "estimateGas")] async fn estimate_gas(&self, opts: CallOpts) -> Result; #[method(name = "chainId")] async fn chain_id(&self) -> Result; #[method(name = "gasPrice")] async fn gas_price(&self) -> Result; #[method(name = "maxPriorityFeePerGas")] async fn max_priority_fee_per_gas(&self) -> Result; #[method(name = "blockNumber")] async fn block_number(&self) -> Result; #[method(name = "getBlockByNumber")] async fn get_block_by_number( &self, block: BlockTag, full_tx: bool, ) -> Result, Error>; #[method(name = "getBlockByHash")] async fn get_block_by_hash( &self, hash: &str, full_tx: bool, ) -> Result, Error>; #[method(name = "sendRawTransaction")] async fn send_raw_transaction(&self, bytes: &str) -> Result; #[method(name = "getTransactionReceipt")] async fn get_transaction_receipt( &self, hash: &str, ) -> Result, Error>; #[method(name = "getTransactionByHash")] async fn get_transaction_by_hash(&self, hash: &str) -> Result, Error>; #[method(name = "getLogs")] async fn get_logs(&self, filter: Filter) -> Result, Error>; } #[rpc(client, server, namespace = "net")] trait NetRpc { #[method(name = "version")] async fn version(&self) -> Result; } #[derive(Clone)] struct RpcInner { node: Arc>, port: u16, } #[async_trait] impl EthRpcServer for RpcInner { async fn get_balance(&self, address: &str, block: BlockTag) -> Result { let address = convert_err(Address::from_str(address))?; let node = self.node.read().await; let balance = convert_err(node.get_balance(&address, block).await)?; Ok(balance.encode_hex()) } async fn get_transaction_count(&self, address: &str, block: BlockTag) -> Result { let address = convert_err(Address::from_str(address))?; let node = self.node.read().await; let nonce = convert_err(node.get_nonce(&address, block).await)?; Ok(nonce.encode_hex()) } async fn get_code(&self, address: &str, block: BlockTag) -> Result { let address = convert_err(Address::from_str(address))?; let node = self.node.read().await; let code = convert_err(node.get_code(&address, block).await)?; Ok(hex::encode(code)) } async fn call(&self, opts: CallOpts, block: BlockTag) -> Result { let node = self.node.read().await; let res = node .call(&opts, block) .await .map_err(NodeError::to_json_rpsee_error)?; Ok(format!("0x{}", hex::encode(res))) } async fn estimate_gas(&self, opts: CallOpts) -> Result { let node = self.node.read().await; let gas = node .estimate_gas(&opts) .await .map_err(NodeError::to_json_rpsee_error)?; Ok(u64_to_hex_string(gas)) } async fn chain_id(&self) -> Result { let node = self.node.read().await; let id = node.chain_id(); Ok(u64_to_hex_string(id)) } async fn gas_price(&self) -> Result { let node = self.node.read().await; let gas_price = convert_err(node.get_gas_price())?; Ok(gas_price.encode_hex()) } async fn max_priority_fee_per_gas(&self) -> Result { let node = self.node.read().await; let tip = convert_err(node.get_priority_fee())?; Ok(tip.encode_hex()) } async fn block_number(&self) -> Result { let node = self.node.read().await; let num = convert_err(node.get_block_number())?; Ok(u64_to_hex_string(num)) } async fn get_block_by_number( &self, block: BlockTag, full_tx: bool, ) -> Result, Error> { let node = self.node.read().await; let block = convert_err(node.get_block_by_number(block, full_tx).await)?; Ok(block) } async fn get_block_by_hash( &self, hash: &str, full_tx: bool, ) -> Result, Error> { let hash = convert_err(hex_str_to_bytes(hash))?; let node = self.node.read().await; let block = convert_err(node.get_block_by_hash(&hash, full_tx).await)?; Ok(block) } async fn send_raw_transaction(&self, bytes: &str) -> Result { let node = self.node.read().await; let bytes = convert_err(hex_str_to_bytes(bytes))?; let tx_hash = convert_err(node.send_raw_transaction(&bytes).await)?; Ok(hex::encode(tx_hash)) } async fn get_transaction_receipt( &self, hash: &str, ) -> Result, Error> { let node = self.node.read().await; let hash = H256::from_slice(&convert_err(hex_str_to_bytes(hash))?); let receipt = convert_err(node.get_transaction_receipt(&hash).await)?; Ok(receipt) } async fn get_transaction_by_hash(&self, hash: &str) -> Result, Error> { let node = self.node.read().await; let hash = H256::from_slice(&convert_err(hex_str_to_bytes(hash))?); convert_err(node.get_transaction_by_hash(&hash).await) } async fn get_logs(&self, filter: Filter) -> Result, Error> { let node = self.node.read().await; convert_err(node.get_logs(&filter).await) } } #[async_trait] impl NetRpcServer for RpcInner { async fn version(&self) -> Result { let node = self.node.read().await; Ok(node.chain_id().to_string()) } } async fn start(rpc: RpcInner) -> Result<(HttpServerHandle, SocketAddr)> { let addr = format!("127.0.0.1:{}", rpc.port); let server = HttpServerBuilder::default().build(addr).await?; let addr = server.local_addr()?; let mut methods = Methods::new(); let eth_methods: Methods = EthRpcServer::into_rpc(rpc.clone()).into(); let net_methods: Methods = NetRpcServer::into_rpc(rpc).into(); methods.merge(eth_methods)?; methods.merge(net_methods)?; let handle = server.start(methods)?; Ok((handle, addr)) } fn convert_err(res: Result) -> Result { res.map_err(|err| Error::Custom(err.to_string())) }