cargo fmt

Author: sslivkoff

crates/freeze/src/datasets/transactions.rs

@@ -150,7 +150,7 @@ impl CollectByBlock for Transactions {
                 schema,
                 exclude_failed,
                 block.header.timestamp as u32,
-                gas_price
+                gas_price,
             )?;
         }
         Ok(())
@@ -199,7 +199,7 @@ impl CollectByTransaction for Transactions {
             schema,
             exclude_failed,
             timestamp,
-            gas_price
+            gas_price,
         )?;
         Ok(())
     }
@@ -287,7 +287,9 @@ fn get_max_fee_per_gas(tx: &Transaction) -> Option<u64> {
 pub(crate) fn get_gas_price(block: &Block, tx: &Transaction) -> Option<u64> {
     match &tx.inner {
         alloy::consensus::TxEnvelope::Legacy(_) => tx.gas_price().map(|gas_price| gas_price as u64),
-        alloy::consensus::TxEnvelope::Eip2930(_) => tx.gas_price().map(|gas_price| gas_price as u64),
+        alloy::consensus::TxEnvelope::Eip2930(_) => {
+            tx.gas_price().map(|gas_price| gas_price as u64)
+        }
         _ => {
             let base_fee_per_gas = block.header.inner.base_fee_per_gas.unwrap();
             let priority_fee = std::cmp::min(

crates/freeze/src/multi_datasets/blocks_and_transactions.rs

@@ -65,7 +65,7 @@ impl CollectByTransaction for BlocksAndTransactions {
             schema,
             exclude_failed,
             timestamp,
-            gas_price
+            gas_price,
         )?;
         Ok(())
     }

crates/freeze/src/types/sources.rs

@@ -259,13 +259,16 @@ impl Source {
 
         // get transactions
         let txs = if include_transaction_hashes {
-            let transactions = self.get_block(block as u64, BlockTransactionsKind::Hashes)
+            let transactions = self
+                .get_block(block as u64, BlockTransactionsKind::Hashes)
                 .await?
                 .ok_or(CollectError::CollectError("could not find block".to_string()))?
                 .transactions;
             match transactions {
-                BlockTransactions::Hashes(hashes) => hashes.into_iter().map(|tx| Some(tx.to_vec())).collect(),
-                _ => return Err(CollectError::CollectError("wrong transaction format".to_string()))
+                BlockTransactions::Hashes(hashes) => {
+                    hashes.into_iter().map(|tx| Some(tx.to_vec())).collect()
+                }
+                _ => return Err(CollectError::CollectError("wrong transaction format".to_string())),
             }
         } else {
             vec![None; result.len()]