Corrections after rebase.

Author: MathieuDutSik

linera-base/src/vm.rs

@@ -80,17 +80,20 @@ pub struct EvmOperation {
 }
 
 impl EvmOperation {
+    /// An EVM transaction with a specified amount and function input.
     pub fn new(amount: Amount, argument: Vec<u8>) -> Self {
         Self {
             value: amount.into(),
             argument,
         }
     }
 
+    /// Convert the input to a `Vec<u8>` if possible.
     pub fn to_bytes(&self) -> Result<Vec<u8>, bcs::Error> {
         bcs::to_bytes(&self)
     }
 
+    /// Creates an `EvmQuery` from the input.
     pub fn to_evm_query(&self) -> Result<EvmQuery, bcs::Error> {
         Ok(EvmQuery::Operation(self.to_bytes()?))
     }

linera-execution/src/evm/revm.rs

@@ -1532,7 +1532,7 @@ where
                 runtime.schedule_operation(operation)?;
                 return Ok(Vec::new());
             }
-            EvmQuery::Mutations(operations) => {
+            EvmQuery::Operations(operations) => {
                 let mut runtime = self.db.runtime.lock().unwrap();
                 for operation in operations {
                     runtime.schedule_operation(operation)?;

linera-service/tests/linera_net_tests.rs

@@ -444,6 +444,16 @@ fn get_zero_operation(operation: impl alloy_sol_types::SolCall) -> Result<EvmQue
     operation.to_evm_query()
 }
 
+#[cfg(with_revm)]
+fn get_zero_operations(
+    operation: impl alloy_sol_types::SolCall,
+    num_operations: usize,
+) -> Result<EvmQuery, bcs::Error> {
+    let operation = EvmOperation::new(Amount::ZERO, operation.abi_encode());
+    let operations = vec![operation.to_bytes()?; num_operations];
+    Ok(EvmQuery::Operations(operations))
+}
+
 #[cfg(with_revm)]
 #[cfg_attr(feature = "storage-service", test_case(LocalNetConfig::new_test(Database::Service, Network::Grpc) ; "storage_test_service_grpc"))]
 #[cfg_attr(feature = "scylladb", test_case(LocalNetConfig::new_test(Database::ScyllaDb, Network::Grpc) ; "scylladb_grpc"))]
@@ -773,15 +783,9 @@ async fn test_evm_end_to_end_balance_and_transfer(config: impl LineraNetConfig)
     assert_eq!(balance_a_2, Amount::from_tokens(50));
     assert_eq!(balance_a_app, Amount::from_tokens(4));
 
-    let app_a = node_service_a
-        .make_application(&chain_a, &application_id)
-        .await?;
-    let app_b = node_service_b
-        .make_application(&chain_b, &application_id)
-        .await?;
-    let app_c = node_service_c
-        .make_application(&chain_c, &application_id)
-        .await?;
+    let app_a = node_service_a.make_application(&chain_a, &application_id)?;
+    let app_b = node_service_b.make_application(&chain_b, &application_id)?;
+    let app_c = node_service_c.make_application(&chain_c, &application_id)?;
 
     // Checking the balances on input
 
@@ -868,8 +872,7 @@ async fn test_evm_end_to_end_balance_and_transfer(config: impl LineraNetConfig)
 #[cfg_attr(feature = "storage-service", test_case(LocalNetConfig::new_test(Database::Service, Network::Grpc) ; "storage_test_service_grpc"))]
 #[cfg_attr(feature = "scylladb", test_case(LocalNetConfig::new_test(Database::ScyllaDb, Network::Grpc) ; "scylladb_grpc"))]
 #[cfg_attr(feature = "dynamodb", test_case(LocalNetConfig::new_test(Database::DynamoDb, Network::Grpc) ; "aws_grpc"))]
-#[cfg_attr(feature = "kubernetes", test_case(SharedLocalKubernetesNetTestingConfig::new(Network::Grpc, BuildArg::Build) ; "kubernetes_grpc"))]
-#[cfg_attr(feature = "remote-net", test_case(RemoteNetTestingConfig::new(None) ; "remote_net_grpc"))]
+#[cfg_attr(feature = "remote-net", test_case(RemoteNetTestingConfig::new(CloseChains) ; "remote_net_grpc"))]
 #[test_log::test(tokio::test)]
 async fn test_evm_event(config: impl LineraNetConfig) -> Result<()> {
     use alloy_primitives::{Bytes, Log, U256};
@@ -1939,9 +1942,7 @@ async fn test_evm_erc20_shared(config: impl LineraNetConfig) -> Result<()> {
         to: address2,
         value: transfer1,
     };
-    let operation = get_zero_operation(operation)?;
-    let operations = vec![operation; num_operations];
-    let query = EvmQuery::Operations(operations);
+    let query = get_zero_operations(operation, num_operations)?;
     let time_start = Instant::now();
     application1.run_json_query(query).await?;
     let average_time = (time_start.elapsed().as_millis() as f64) / (num_operations as f64);