Run clippy/fmt

relayer/src/bin/feed.rs

@@ -56,10 +56,12 @@ async fn main() {
         }
 
         let start_update_period = if is_on_bootstrap {
-            info!("Verifier is on bootstrap. Will apply updates starting from period {}", verifier_period);
+            info!(
+                "Verifier is on bootstrap. Will apply updates starting from period {}",
+                verifier_period
+            );
             verifier_period
-        }
-        else {
+        } else {
             verifier_period + 1
         };
 
@@ -95,4 +97,4 @@ async fn main() {
         debug!("Sleeping for {}", sleep_duration.as_secs());
         sleep(sleep_duration).await;
     }
-}
+}

relayer/src/consumers/lapin_consumer.rs

@@ -1,13 +1,13 @@
 use super::Amqp;
 use async_trait::async_trait;
 use eyre::{eyre, Result};
-use futures::{StreamExt, TryStreamExt};
+use futures::StreamExt;
 use lapin::{
     options::{BasicAckOptions, BasicConsumeOptions, BasicNackOptions},
     types::FieldTable,
     Channel, Connection, ConnectionProperties, Consumer,
 };
-use log::{debug, error, info};
+use log::{debug, info};
 use mockall::automock;
 
 pub struct LapinConsumer {

relayer/src/relayer.rs

@@ -12,7 +12,7 @@ use eth::{consensus::EthBeaconAPI, execution::EthExecutionAPI, utils::get_full_b
 use eyre::{eyre, Result};
 use log::{debug, error, info, warn};
 use prover::prover::{errors::StateProverError, types::EnrichedContent, ProverAPI};
-use reqwest::Client;
+
 use std::{collections::HashMap, sync::Arc, time::Duration};
 use tokio::time::sleep;
 
@@ -293,7 +293,7 @@ impl<C: Amqp, P: ProverAPI, CR: EthBeaconAPI, ER: EthExecutionAPI, V: VerifierAP
                         "Got finality update with slot {}",
                         update.finalized_header.beacon.slot
                     );
-                    return Ok(UpdateVariant::Finality(update));
+                    Ok(UpdateVariant::Finality(update))
                 }
                 Err(e) => Err(eyre!("Error fetching finality update {}", e)),
             },
@@ -303,7 +303,7 @@ impl<C: Amqp, P: ProverAPI, CR: EthBeaconAPI, ER: EthExecutionAPI, V: VerifierAP
                         "Got optimistic update with slot {}",
                         update.attested_header.beacon.slot
                     );
-                    return Ok(UpdateVariant::Optimistic(update));
+                    Ok(UpdateVariant::Optimistic(update))
                 }
                 Err(e) => Err(eyre!("Error fetching finality update {}", e)),
             },
@@ -335,7 +335,7 @@ impl<C: Amqp, P: ProverAPI, CR: EthBeaconAPI, ER: EthExecutionAPI, V: VerifierAP
         }
 
         println!("STATE WOULD PASS");
-        return Ok(true);
+        Ok(true)
     }
 }
 

relayer/src/types.rs

@@ -7,7 +7,7 @@ use consensus_types::{
 use eth::types::EthConfig;
 use ethers::{
     contract::EthEvent,
-    types::{Address, Bytes, Log, H256, U256},
+    types::{Address, Bytes, Log, H256},
 };
 use prover::prover::types::ProverConfig;
 use serde::{Deserialize, Serialize};