diff --git a/crates/audit/src/types.rs b/crates/audit/src/types.rs index fce2a2b..74866ef 100644 --- a/crates/audit/src/types.rs +++ b/crates/audit/src/types.rs @@ -121,7 +121,7 @@ impl BundleEvent { block_hash, .. } => { - format!("{}-{}", bundle_id, block_hash) + format!("{bundle_id}-{block_hash}") } BundleEvent::FlashblockIncluded { bundle_id, @@ -129,7 +129,7 @@ impl BundleEvent { flashblock_index, .. } => { - format!("{}-{}-{}", bundle_id, block_number, flashblock_index) + format!("{bundle_id}-{block_number}-{flashblock_index}") } _ => { format!("{}-{}", self.bundle_id(), Uuid::new_v4()) diff --git a/crates/datastore/src/postgres.rs b/crates/datastore/src/postgres.rs index 1852eda..9250801 100644 --- a/crates/datastore/src/postgres.rs +++ b/crates/datastore/src/postgres.rs @@ -446,19 +446,20 @@ impl BundleDatastore for PostgresDatastore { match (row.latest_block_number, row.latest_block_hash) { (Some(block_number), Some(hash_str)) => { let hash = B256::from_hex(&hash_str) - .map_err(|e| anyhow::anyhow!("Failed to parse latest block hash: {}", e))?; + .map_err(|e| anyhow::anyhow!("Failed to parse latest block hash: {e}"))?; (block_number as u64, hash) } _ => return Ok(None), }; - let latest_finalized_block_hash = if let Some(hash_str) = row.latest_finalized_block_hash { - Some(B256::from_hex(&hash_str).map_err(|e| { - anyhow::anyhow!("Failed to parse latest finalized block hash: {}", e) - })?) - } else { - None - }; + let latest_finalized_block_hash = + if let Some(hash_str) = row.latest_finalized_block_hash { + Some(B256::from_hex(&hash_str).map_err(|e| { + anyhow::anyhow!("Failed to parse latest finalized block hash: {e}") + })?) + } else { + None + }; Ok(Some(BlockInfo { latest_block_number, diff --git a/crates/ingress-rpc/src/service.rs b/crates/ingress-rpc/src/service.rs index 1cda9d9..a48841d 100644 --- a/crates/ingress-rpc/src/service.rs +++ b/crates/ingress-rpc/src/service.rs @@ -94,8 +94,6 @@ where .await?; validate_tx(account, &transaction, &data, &mut l1_block_info).await?; - // TODO: parallelize DB and mempool setup - let expiry_timestamp = SystemTime::now() .duration_since(UNIX_EPOCH) .unwrap() diff --git a/crates/maintenance/src/job.rs b/crates/maintenance/src/job.rs index 835f1a7..3d00e34 100644 --- a/crates/maintenance/src/job.rs +++ b/crates/maintenance/src/job.rs @@ -69,7 +69,7 @@ impl, K: BundleEventPublisher> Mainten ))) .full() .await? - .ok_or_else(|| anyhow::anyhow!("Failed to get block {}", block_num))?; + .ok_or_else(|| anyhow::anyhow!("Failed to get block {block_num}"))?; self.on_new_block(block).await?; }