From 2016015c8fed2a65da329c7cd84ee69f6bc18849 Mon Sep 17 00:00:00 2001
From: Dimitris Lamprinos <pkakelas@gmail.com>
Date: Thu, 18 Jan 2024 19:38:07 +0200
Subject: [PATCH] Run clippy/fmt

---
 relayer/src/bin/feed.rs                 | 10 ++++++----
 relayer/src/consumers/lapin_consumer.rs |  4 ++--
 relayer/src/relayer.rs                  |  8 ++++----
 relayer/src/types.rs                    |  2 +-
 4 files changed, 13 insertions(+), 11 deletions(-)

diff --git a/relayer/src/bin/feed.rs b/relayer/src/bin/feed.rs
index 0427b83..9d7f332 100644
--- a/relayer/src/bin/feed.rs
+++ b/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;
     }
-}
\ No newline at end of file
+}
diff --git a/relayer/src/consumers/lapin_consumer.rs b/relayer/src/consumers/lapin_consumer.rs
index 5b58809..82342c0 100644
--- a/relayer/src/consumers/lapin_consumer.rs
+++ b/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 {
diff --git a/relayer/src/relayer.rs b/relayer/src/relayer.rs
index 834f038..432e7d1 100644
--- a/relayer/src/relayer.rs
+++ b/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)
     }
 }
 
diff --git a/relayer/src/types.rs b/relayer/src/types.rs
index a41675d..03831d9 100644
--- a/relayer/src/types.rs
+++ b/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};