EVM: Refactor FFI from rust strings to passing byte arrays

lib/ain-cpp-imports/src/bridge.rs

@@ -41,7 +41,7 @@ pub mod ffi {
         fn getPoolTransactions() -> Vec<TransactionData>;
         fn getNativeTxSize(data: Vec<u8>) -> u64;
         fn getMinRelayTxFee() -> u64;
-        fn getEthPrivKey(key: String) -> [u8; 32];
+        fn getEthPrivKey(key: [u8; 20]) -> [u8; 32];
         fn getStateInputJSON() -> String;
         fn getEthSyncStatus() -> [i64; 2];
         fn getAttributeValues(mnview_ptr: usize) -> Attributes;

lib/ain-cpp-imports/src/lib.rs

@@ -68,7 +68,7 @@ mod ffi {
     pub fn getMinRelayTxFee() -> u64 {
         unimplemented!("{}", UNIMPL_MSG)
     }
-    pub fn getEthPrivKey(_key: String) -> [u8; 32] {
+    pub fn getEthPrivKey(_key: [u8; 20]) -> [u8; 32] {
         unimplemented!("{}", UNIMPL_MSG)
     }
     pub fn getStateInputJSON() -> String {
@@ -207,7 +207,7 @@ pub fn get_min_relay_tx_fee() -> Result<u64, Box<dyn Error>> {
 }
 
 /// Gets the private key for the given pubkey string.
-pub fn get_eth_priv_key(key: String) -> Result<[u8; 32], Box<dyn Error>> {
+pub fn get_eth_priv_key(key: [u8; 20]) -> Result<[u8; 32], Box<dyn Error>> {
     let eth_key = ffi::getEthPrivKey(key);
     Ok(eth_key)
 }

lib/ain-evm/src/core.rs

@@ -43,7 +43,7 @@ use crate::{
     EVMError, Result,
 };
 
-pub type XHash = String;
+pub type XHash = [u8; 32];
 
 pub struct SignedTxCache {
     inner: spin::Mutex<LruCache<String, SignedTx>>,
@@ -159,9 +159,9 @@ pub struct ValidateTxInfo {
 }
 
 pub struct TransferDomainTxInfo {
-    pub from: String,
-    pub to: String,
-    pub native_address: String,
+    pub from: [u8; 20],
+    pub to: [u8; 20],
+    pub native_address: [u8; 20],
     pub direction: bool,
     pub value: u64,
     pub token_id: u32,
@@ -484,10 +484,7 @@ impl EVMCoreService {
             }
 
             // Validate tx sender with transferdomain sender
-            let sender = context
-                .from
-                .parse::<H160>()
-                .map_err(|_| "Invalid address")?;
+            let sender = H160::from(context.from);
             if signed_tx.sender != sender {
                 return Err(format_err!(
                     "[validate_raw_transferdomain_tx] invalid sender, signed_tx.sender : {:#?}, transferdomain sender : {:#?}",
@@ -535,19 +532,15 @@ impl EVMCoreService {
                 }
             }
 
+            let native_address = H160::from(context.native_address);
+            let native_address = format!("{native_address:?}");
             let (from_address, to_address) = if context.direction {
                 // EvmIn
-                let to_address = context
-                    .to
-                    .parse::<H160>()
-                    .map_err(|_| "failed to parse to address")?;
+                let to_address = H160::from(context.to);
                 (fixed_address, to_address)
             } else {
                 // EvmOut
-                let from_address = context
-                    .from
-                    .parse::<H160>()
-                    .map_err(|_| "failed to parse from address")?;
+                let from_address = H160::from(context.from);
                 (from_address, fixed_address)
             };
             let value = try_from_satoshi(U256::from(context.value))?.0;
@@ -591,7 +584,7 @@ impl EVMCoreService {
                 let ethabi::Token::String(ref input_native_address) = token_inputs[3] else {
                     return Err(format_err!("invalid native address input in evm tx").into());
                 };
-                if context.native_address != *input_native_address {
+                if native_address != *input_native_address {
                     return Err(format_err!("invalid native address input in evm tx").into());
                 }
             } else {
@@ -642,7 +635,7 @@ impl EVMCoreService {
                 let ethabi::Token::String(ref input_native_address) = token_inputs[4] else {
                     return Err(format_err!("invalid native address input in evm tx").into());
                 };
-                if context.native_address != *input_native_address {
+                if native_address != *input_native_address {
                     return Err(format_err!("invalid native address input in evm tx").into());
                 }
             }

lib/ain-evm/src/evm.rs

@@ -221,7 +221,7 @@ impl EVMServices {
                 .collect(),
             Vec::new(),
         );
-        let block_hash = format!("{:?}", block.header.hash());
+        let block_hash = block.header.hash().to_fixed_bytes();
         let receipts = self.receipt.generate_receipts(
             &all_transactions,
             receipts_v3.clone(),

lib/ain-grpc/src/lib.rs

@@ -72,9 +72,9 @@ pub fn init_services() {
     let _ = &*SERVICES;
 }
 
-pub fn init_network_json_rpc_service(addr: &str) -> Result<()> {
+pub fn init_network_json_rpc_service(addr: String) -> Result<()> {
     info!("Starting JSON RPC server at {}", addr);
-    let addr = addr.parse::<SocketAddr>()?;
+    let addr = addr.as_str().parse::<SocketAddr>()?;
     let max_connections = ain_cpp_imports::get_max_connections();
     let max_response_size = ain_cpp_imports::get_max_response_byte_size();
     let runtime = &SERVICES;
@@ -112,7 +112,7 @@ pub fn init_network_json_rpc_service(addr: &str) -> Result<()> {
     Ok(())
 }
 
-pub fn init_network_grpc_service(_addr: &str) -> Result<()> {
+pub fn init_network_grpc_service(_addr: String) -> Result<()> {
     // log::info!("Starting gRPC server at {}", addr);
     // Commented out for now as nothing to serve
     // let runtime = &SERVICES;
@@ -122,9 +122,9 @@ pub fn init_network_grpc_service(_addr: &str) -> Result<()> {
     Ok(())
 }
 
-pub fn init_network_subscriptions_service(addr: &str) -> Result<()> {
+pub fn init_network_subscriptions_service(addr: String) -> Result<()> {
     info!("Starting WebSockets server at {}", addr);
-    let addr = addr.parse::<SocketAddr>()?;
+    let addr = addr.as_str().parse::<SocketAddr>()?;
     let max_connections = ain_cpp_imports::get_max_connections();
     let max_response_size = ain_cpp_imports::get_max_response_byte_size();
     let runtime = &SERVICES;

lib/ain-grpc/src/rpc/eth.rs

@@ -1146,8 +1146,7 @@ fn sign(
     message: TransactionMessage,
 ) -> Result<TransactionV2, Box<dyn std::error::Error>> {
     debug!(target:"rpc", "sign address {:#x}", address);
-    let key = format!("{address:?}");
-    let priv_key = get_eth_priv_key(key).unwrap();
+    let priv_key = get_eth_priv_key(address.to_fixed_bytes()).unwrap();
     let secret_key = SecretKey::parse(&priv_key).unwrap();
 
     match message {

lib/ain-rs-exports/src/core.rs

@@ -20,21 +20,21 @@ pub fn ain_rs_stop_core_services(result: &mut CrossBoundaryResult) {
     cross_boundary_success(result);
 }
 
-pub fn ain_rs_init_network_json_rpc_service(result: &mut CrossBoundaryResult, addr: &str) {
+pub fn ain_rs_init_network_json_rpc_service(result: &mut CrossBoundaryResult, addr: String) {
     match ain_grpc::init_network_json_rpc_service(addr) {
         Ok(()) => cross_boundary_success(result),
         Err(e) => cross_boundary_error_return(result, e.to_string()),
     }
 }
 
-pub fn ain_rs_init_network_grpc_service(result: &mut CrossBoundaryResult, addr: &str) {
+pub fn ain_rs_init_network_grpc_service(result: &mut CrossBoundaryResult, addr: String) {
     match ain_grpc::init_network_grpc_service(addr) {
         Ok(()) => cross_boundary_success(result),
         Err(e) => cross_boundary_error_return(result, e.to_string()),
     }
 }
 
-pub fn ain_rs_init_network_subscriptions_service(result: &mut CrossBoundaryResult, addr: &str) {
+pub fn ain_rs_init_network_subscriptions_service(result: &mut CrossBoundaryResult, addr: String) {
     match ain_grpc::init_network_subscriptions_service(addr) {
         Ok(()) => cross_boundary_success(result),
         Err(e) => cross_boundary_error_return(result, e.to_string()),