Merge pull request #81 from propeller-heads/zz/fix-balancer-balance-bug

fix(balancer-susbtreams): fix a bug with pool id in case of `Swap` event

substreams/Cargo.lock

@@ -210,7 +210,7 @@ dependencies = [
 
 [[package]]
 name = "ethereum-balancer"
-version = "0.2.0"
+version = "0.2.1"
 dependencies = [
  "anyhow",
  "bytes",

substreams/crates/tycho-substreams/src/lib.rs

@@ -4,6 +4,7 @@ pub mod balances;
 pub mod contract;
 mod mock_store;
 pub mod models;
+#[allow(clippy::too_long_first_doc_paragraph)]
 mod pb;
 
 pub mod prelude {

substreams/ethereum-balancer/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ethereum-balancer"
-version = "0.2.0"
+version = "0.2.1"
 edition = "2021"
 
 [lib]

substreams/ethereum-balancer/src/modules.rs

@@ -90,10 +90,10 @@ pub fn map_relative_balances(
                     }
                 }
             } else if let Some(ev) = abi::vault::events::Swap::match_and_decode(vault_log.log) {
-                let component_id = format!("0x{}", hex::encode(&ev.pool_id[..20]));
+                let component_id = format!("0x{}", hex::encode(ev.pool_id));
 
                 if store
-                    .get_last(format!("pool:{}", component_id))
+                    .get_last(format!("pool:{}", &component_id[..42]))
                     .is_some()
                 {
                     deltas.extend_from_slice(&[

substreams/ethereum-balancer/substreams.yaml

@@ -1,7 +1,7 @@
 specVersion: v0.1.0
 package:
   name: "ethereum_balancer"
-  version: v0.2.0
+  version: v0.2.1
 
 protobuf:
   files: