fix(experimental): log invalid dapp addresses

cartesi · Aug 23, 2024 · 931e258 · 931e258
1 parent 545e56e
commit 931e258
Showing 1 changed file with 18 additions and 6 deletions.
diff --git a/offchain/rollups-events/src/broker/mod.rs b/offchain/rollups-events/src/broker/mod.rs
@@ -376,12 +376,24 @@ impl Broker {
             let mut dapp_addresses: Vec<Address> = vec![];
             for value in reply {
                 let normalized = value.to_lowercase();
-                let dapp_address = Address::from_str(&normalized).unwrap();
-                if dapp_addresses.contains(&dapp_address) {
-                    let _: () =
-                        self.connection.clone().srem(DAPPS_KEY, value).await?;
-                } else {
-                    dapp_addresses.push(dapp_address);
+                let dapp_address = Address::from_str(&normalized);
+                match dapp_address {
+                    Ok(dapp_address) => {
+                        if dapp_addresses.contains(&dapp_address) {
+                            let _: () = self
+                                .connection
+                                .clone()
+                                .srem(DAPPS_KEY, value)
+                                .await?;
+                        } else {
+                            dapp_addresses.push(dapp_address);
+                        }
+                    }
+                    Err(message) => tracing::info!(
+                        "Error while parsing DApp address {:?}: {}",
+                        normalized,
+                        message,
+                    ),
                 }
             }