fix: filter out chains with invalid chain_id

blockscout · Dec 12, 2024 · bf0df8b · bf0df8b
1 parent 959019c
commit bf0df8b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/multichain-aggregator/Cargo.lock b/multichain-aggregator/Cargo.lock
diff --git a/multichain-aggregator/Cargo.toml b/multichain-aggregator/Cargo.toml
@@ -55,7 +55,7 @@ alloy-primitives = "0.8"
 anyhow = "1.0"
 async-std = { version = "1", features = ["attributes", "tokio1"] }
 async-trait = "0.1"
-blockscout-chains = { git = "https://github.com/blockscout/blockscout-rs", version = "0.1.0" }
+blockscout-chains = { git = "https://github.com/blockscout/blockscout-rs", version = "0.2.0" }
 config = "0.13"
 env-collector = { git = "https://github.com/blockscout/blockscout-rs", version = "0.1.1" }
 pretty_assertions = "1.3"

diff --git a/multichain-aggregator/multichain-aggregator-server/src/server.rs b/multichain-aggregator/multichain-aggregator-server/src/server.rs
@@ -65,7 +65,10 @@ pub async fn run(settings: Settings) -> Result<(), anyhow::Error> {
         .fetch_all()
         .await?
         .into_iter()
-        .map(|(id, chain)| (id as i64, chain).into())
+        .filter_map(|(id, chain)| {
+            let id = id.parse::<i64>().ok()?;
+            Some((id, chain).into())
+        })
         .collect::<Vec<_>>();
     repository::chains::upsert_many(&db, blockscout_chains.clone()).await?;