fix(balancer): index PoolBalanceManaged balance changes
This commit is contained in:
2
substreams/Cargo.lock
generated
2
substreams/Cargo.lock
generated
@@ -222,7 +222,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ethereum-balancer"
|
name = "ethereum-balancer"
|
||||||
version = "0.2.1"
|
version = "0.2.2"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"bytes",
|
"bytes",
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "ethereum-balancer"
|
name = "ethereum-balancer"
|
||||||
version = "0.2.1"
|
version = "0.2.2"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[lib]
|
[lib]
|
||||||
|
|||||||
@@ -113,6 +113,17 @@ pub fn map_relative_balances(
|
|||||||
},
|
},
|
||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
} else if let Some(ev) =
|
||||||
|
abi::vault::events::PoolBalanceManaged::match_and_decode(vault_log.log)
|
||||||
|
{
|
||||||
|
let component_id = format!("0x{}", hex::encode(ev.pool_id));
|
||||||
|
deltas.extend_from_slice(&[BalanceDelta {
|
||||||
|
ord: vault_log.ordinal(),
|
||||||
|
tx: Some(vault_log.receipt.transaction.into()),
|
||||||
|
token: ev.token.to_vec(),
|
||||||
|
delta: ev.cash_delta.to_signed_bytes_be(),
|
||||||
|
component_id: component_id.as_bytes().to_vec(),
|
||||||
|
}]);
|
||||||
}
|
}
|
||||||
|
|
||||||
deltas
|
deltas
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
specVersion: v0.1.0
|
specVersion: v0.1.0
|
||||||
package:
|
package:
|
||||||
name: "ethereum_balancer"
|
name: "ethereum_balancer"
|
||||||
version: v0.2.1
|
version: v0.2.2
|
||||||
|
|
||||||
protobuf:
|
protobuf:
|
||||||
files:
|
files:
|
||||||
|
|||||||
Reference in New Issue
Block a user