Add forest api test-stateful subcommand

src/eth/mod.rs

@@ -4,7 +4,7 @@
 mod eip_1559_transaction;
 mod eip_155_transaction;
 mod homestead_transaction;
-mod transaction;
+pub mod transaction;
 
 pub use eip_155_transaction::*;
 pub use eip_1559_transaction::*;

src/eth/transaction.rs

@@ -60,6 +60,7 @@ pub enum EVMMethod {
 
 /// Ethereum transaction which can be of different types.
 /// The currently supported types are defined in [FIP-0091](https://github.com/filecoin-project/FIPs/blob/020bcb412ee20a2879b4a710337959c51b938d3b/FIPS/fip-0091.md).
+#[derive(Debug)]
 pub enum EthTx {
     Homestead(Box<EthLegacyHomesteadTxArgs>),
     Eip1559(Box<EthEip1559TxArgs>),
@@ -155,7 +156,7 @@ impl EthTx {
         }
     }
 
-    fn rlp_signed_message(&self) -> anyhow::Result<Vec<u8>> {
+    pub fn rlp_signed_message(&self) -> anyhow::Result<Vec<u8>> {
         match self {
             Self::Homestead(tx) => (*tx).rlp_signed_message(),
             Self::Eip1559(tx) => (*tx).rlp_signed_message(),

src/rpc/client.rs

@@ -89,6 +89,9 @@ impl Client {
     pub fn base_url(&self) -> &Url {
         &self.base_url
     }
+    pub fn token(&self) -> Option<&String> {
+        self.token.as_ref()
+    }
     pub async fn call<T: crate::lotus_json::HasLotusJson + std::fmt::Debug>(
         &self,
         req: Request<T>,

src/rpc/methods/eth.rs

@@ -211,6 +211,10 @@ impl EthUint64 {
                 .try_into()?,
         )))
     }
+
+    pub fn to_hex_string(&self) -> String {
+        format!("0x{:x}", self.0)
+    }
 }
 
 #[derive(
@@ -2977,14 +2981,16 @@ fn eth_filter_result_from_events<DB: Blockstore>(
 }
 
 fn eth_filter_result_from_tipsets(events: &[CollectedEvent]) -> anyhow::Result<EthFilterResult> {
-    Ok(EthFilterResult::Txs(eth_filter_logs_from_tipsets(events)?))
+    Ok(EthFilterResult::Hashes(eth_filter_logs_from_tipsets(
+        events,
+    )?))
 }
 
 fn eth_filter_result_from_messages<DB: Blockstore>(
     ctx: &Ctx<DB>,
     events: &[CollectedEvent],
 ) -> anyhow::Result<EthFilterResult> {
-    Ok(EthFilterResult::Txs(eth_filter_logs_from_messages(
+    Ok(EthFilterResult::Hashes(eth_filter_logs_from_messages(
         ctx, events,
     )?))
 }

src/rpc/methods/eth/types.rs

@@ -500,17 +500,15 @@ lotus_json_with_self!(EthFilterSpec);
 #[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
 #[serde(untagged)]
 pub enum EthFilterResult {
-    Blocks(Vec<EthHash>),
-    Txs(Vec<EthHash>),
+    Hashes(Vec<EthHash>),
     Logs(Vec<EthLog>),
 }
 lotus_json_with_self!(EthFilterResult);
 
 impl EthFilterResult {
     pub fn is_empty(&self) -> bool {
         match self {
-            Self::Blocks(v) => v.is_empty(),
-            Self::Txs(v) => v.is_empty(),
+            Self::Hashes(v) => v.is_empty(),
             Self::Logs(v) => v.is_empty(),
         }
     }
@@ -519,8 +517,7 @@ impl EthFilterResult {
 impl PartialEq for EthFilterResult {
     fn eq(&self, other: &Self) -> bool {
         match (self, other) {
-            (Self::Blocks(a), Self::Blocks(b)) => a == b,
-            (Self::Txs(a), Self::Txs(b)) => a == b,
+            (Self::Hashes(a), Self::Hashes(b)) => a == b,
             (Self::Logs(a), Self::Logs(b)) => a == b,
             _ => self.is_empty() && other.is_empty(),
         }

src/tool/subcommands/api_cmd.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0, MIT
 
 mod api_compare_tests;
+mod api_run_tests;
 mod generate_test_snapshot;
 mod report;
 mod test_snapshot;
@@ -177,6 +178,17 @@ pub enum ApiCommands {
         #[arg(num_args = 1.., required = true)]
         files: Vec<PathBuf>,
     },
+    Run {
+        /// Forest address
+        #[clap(long, default_value = "/ip4/127.0.0.1/tcp/2345/http")]
+        forest: UrlFromMultiAddr,
+        /// Lotus address
+        #[clap(long, default_value = "/ip4/127.0.0.1/tcp/1234/http")]
+        lotus: UrlFromMultiAddr,
+        /// Filter which tests to run according to method name. Case sensitive.
+        #[arg(long, default_value = "")]
+        filter: String,
+    },
 }
 
 impl ApiCommands {
@@ -323,6 +335,17 @@ impl ApiCommands {
                     };
                 }
             }
+            Self::Run {
+                forest: UrlFromMultiAddr(forest),
+                lotus: UrlFromMultiAddr(lotus),
+                filter,
+            } => {
+                let forest = Arc::new(rpc::Client::from_url(forest));
+                let lotus = Arc::new(rpc::Client::from_url(lotus));
+
+                let tests = api_run_tests::create_tests().await;
+                api_run_tests::run_tests(tests, forest.clone(), lotus.clone(), filter).await?;
+            }
             Self::DumpTests {
                 create_tests_args,
                 path,