chore: run just fix and just ci locally (#9)

Author: wlawt

crates/audit/src/publisher.rs

@@ -50,7 +50,7 @@ impl KafkaMempoolEventPublisher {
                     error = %err,
                     "Failed to publish event"
                 );
-                Err(anyhow::anyhow!("Failed to publish event: {}", err))
+                Err(anyhow::anyhow!("Failed to publish event: {err}"))
             }
         }
     }

crates/audit/src/reader.rs

@@ -110,7 +110,7 @@ impl MempoolEventReader for KafkaMempoolReader {
                 Ok(event_result)
             }
             Err(e) => {
-                println!("received error {:?}", e);
+                println!("received error {e:?}");
                 error!(error = %e, "Error receiving message from Kafka");
                 sleep(Duration::from_secs(1)).await;
                 Err(e.into())

crates/audit/src/storage.rs

@@ -22,8 +22,8 @@ pub enum S3Key {
 impl fmt::Display for S3Key {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         match self {
-            S3Key::Bundle(bundle_id) => write!(f, "bundles/{}", bundle_id),
-            S3Key::TransactionByHash(hash) => write!(f, "transactions/by_hash/{}", hash),
+            S3Key::Bundle(bundle_id) => write!(f, "bundles/{bundle_id}"),
+            S3Key::TransactionByHash(hash) => write!(f, "transactions/by_hash/{hash}"),
         }
     }
 }
@@ -291,9 +291,7 @@ impl S3MempoolEventReaderWriter {
                                 tokio::time::sleep(tokio::time::Duration::from_millis(delay)).await;
                             } else {
                                 return Err(anyhow::anyhow!(
-                                    "Failed to write after {} attempts: {}",
-                                    MAX_RETRIES,
-                                    e
+                                    "Failed to write after {MAX_RETRIES} attempts: {e}"
                                 ));
                             }
                         }
@@ -334,7 +332,7 @@ impl S3MempoolEventReaderWriter {
             Err(e) => match &e {
                 SdkError::ServiceError(service_err) => match service_err.err() {
                     GetObjectError::NoSuchKey(_) => Ok((None, None)),
-                    _ => Err(anyhow::anyhow!("Failed to get object: {}", e)),
+                    _ => Err(anyhow::anyhow!("Failed to get object: {e}")),
                 },
                 _ => {
                     let error_string = e.to_string();
@@ -344,7 +342,7 @@ impl S3MempoolEventReaderWriter {
                     {
                         Ok((None, None))
                     } else {
-                        Err(anyhow::anyhow!("Failed to get object: {}", e))
+                        Err(anyhow::anyhow!("Failed to get object: {e}"))
                     }
                 }
             },

crates/audit/tests/common/mod.rs

@@ -19,7 +19,7 @@ impl TestHarness {
     pub async fn new() -> Result<Self, Box<dyn std::error::Error + Send + Sync>> {
         let minio_container = MinIO::default().start().await?;
         let s3_port = minio_container.get_host_port_ipv4(9000).await?;
-        let s3_endpoint = format!("http://127.0.0.1:{}", s3_port);
+        let s3_endpoint = format!("http://127.0.0.1:{s3_port}");
 
         let config = aws_config::defaults(aws_config::BehaviorVersion::latest())
             .region("us-east-1")

crates/audit/tests/s3_test.rs

@@ -227,7 +227,7 @@ async fn test_concurrent_writes_for_bundle() -> Result<(), Box<dyn std::error::E
         let key = if i % 4 == 0 {
             "shared-key".to_string()
         } else {
-            format!("unique-key-{}", i)
+            format!("unique-key-{i}")
         };
 
         let event = create_test_event(

crates/datastore/tests/datastore.rs

@@ -80,7 +80,7 @@ async fn insert_and_get() -> eyre::Result<()> {
 
     let insert_result = harness.data_store.insert_bundle(test_bundle.clone()).await;
     if let Err(ref err) = insert_result {
-        eprintln!("Insert failed with error: {:?}", err);
+        eprintln!("Insert failed with error: {err:?}");
     }
     assert!(insert_result.is_ok());
     let bundle_id = insert_result.unwrap();

crates/maintenance/src/main.rs

@@ -143,7 +143,7 @@ async fn process_block(
         .get_block_by_number(block_number.into())
         .full()
         .await?
-        .ok_or_else(|| anyhow::anyhow!("Block {} not found", block_number))?;
+        .ok_or_else(|| anyhow::anyhow!("Block {block_number} not found"))?;
 
     let block_hash = block.header.hash;