diff --git a/substreams/ethereum-balancer/build.rs b/substreams/ethereum-balancer/build.rs index ceabf48..90e1f1e 100644 --- a/substreams/ethereum-balancer/build.rs +++ b/substreams/ethereum-balancer/build.rs @@ -8,6 +8,7 @@ fn main() -> Result<()> { let files = fs::read_dir(abi_folder)?; let mut mod_rs_content = String::new(); + mod_rs_content.push_str("#![allow(clippy::all)]\n"); for file in files { let file = file?; diff --git a/substreams/ethereum-balancer/src/abi/mod.rs b/substreams/ethereum-balancer/src/abi/mod.rs index ef6622d..0f60dc0 100644 --- a/substreams/ethereum-balancer/src/abi/mod.rs +++ b/substreams/ethereum-balancer/src/abi/mod.rs @@ -1,3 +1,4 @@ +#![allow(clippy::all)] pub mod yearn_linear_pool_factory; pub mod composable_stable_pool_factory; pub mod vault; diff --git a/substreams/ethereum-balancer/src/modules.rs b/substreams/ethereum-balancer/src/modules.rs index e741fb3..7d666cc 100644 --- a/substreams/ethereum-balancer/src/modules.rs +++ b/substreams/ethereum-balancer/src/modules.rs @@ -102,7 +102,7 @@ pub fn map_balance_deltas( ) -> Result { Ok(tycho::BalanceDeltas { balance_deltas: block - .events::(&[&VAULT_ADDRESS]) + .events::(&[VAULT_ADDRESS]) .flat_map(|(event, log)| { event .tokens @@ -111,12 +111,7 @@ pub fn map_balance_deltas( .filter_map(|(token, delta)| { let component_id: Vec<_> = event.pool_id.into(); - if store - .get_last(format!("pool:{0}", hex::encode(&component_id))) - .is_none() - { - return None; - } + store.get_last(format!("pool:{0}", hex::encode(&component_id)))?; Some(tycho::BalanceDelta { ord: log.log.ordinal, @@ -253,7 +248,7 @@ pub fn map_changes( }), changes: transaction_contract_changes .drain() - .sorted_unstable_by_key(|(index, _)| index.clone()) + .sorted_unstable_by_key(|(index, _)| *index) .filter_map(|(_, change)| { if change.contract_changes.is_empty() && change.component_changes.is_empty()