fix: remove concurrent block fetch in inputbox

CHANGELOG.md

@@ -27,6 +27,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Changed installation paths in the Docker image. Now all the binaries are installed in /usr/bin
   instead of /opt/cartesi/bin.
 - Changed the base Docker image to debian-bookworm instead cartesi/server-manager.
+- Removed concurrent block fetch in foldable `InputBox`.
 
 ## [1.2.0]
 

offchain/types/Cargo.toml

@@ -13,7 +13,6 @@ async-trait.workspace = true
 clap = { workspace = true, features = ["derive", "env"] }
 eth-state-fold-types = { workspace = true, features = ["ethers"] }
 eth-state-fold.workspace = true
-futures.workspace = true
 im = { workspace = true, features = ["serde"] }
 serde = { workspace = true, features = ["rc"] }
 serde_json.workspace = true

offchain/types/src/foldables/input_box.rs

@@ -157,23 +157,16 @@ async fn fetch_all_new_inputs<
     let contract = InputBox::new(*contract_address, Arc::clone(&provider));
 
     // Retrieve `InputAdded` events
-    let inputs_futures: Vec<_> = contract
+    let input_events = contract
         .input_added_filter()
         .query_with_meta()
         .await
-        .context("Error querying for input added events")?
-        .into_iter()
-        .map(|(e, meta)| Input::build_input(env, e, meta, &block_opt))
-        .collect();
+        .context("Error querying for input added events")?;
 
-    let inputs_results = futures::future::join_all(inputs_futures).await;
-
-    let inputs = {
-        let inputs: Result<Vec<Input>, _> =
-            inputs_results.into_iter().collect();
-
-        inputs?
-    };
+    let mut inputs = Vec::with_capacity(input_events.len());
+    for (event, meta) in input_events {
+        inputs.push(Input::build_input(env, event, meta, &block_opt).await?);
+    }
 
     Ok(inputs)
 }