ci: enforce strict formatting and clippy compliance 🏮

Author: intelliDean

bin/flashstat-server/src/main.rs

@@ -5,7 +5,7 @@ use flashstat_common::{
     Config, FlashBlock, ReorgEvent, ReorgSeverity, SequencerStats, SystemHealth,
 };
 use flashstat_db::FlashStorage;
-use jsonrpsee::core::{RpcResult, async_trait};
+use jsonrpsee::core::{async_trait, RpcResult};
 use jsonrpsee::server::ServerBuilder;
 use jsonrpsee::types::error::ErrorObjectOwned;
 use std::sync::Arc;
@@ -97,10 +97,7 @@ impl FlashApiServer for FlashServer {
         Ok(stats)
     }
 
-    async fn ingest_block(
-        &self,
-        block: ethers::types::Block<ethers::types::H256>,
-    ) -> RpcResult<()> {
+    async fn ingest_block(&self, block: ethers::types::Block<ethers::types::H256>) -> RpcResult<()> {
         self.monitor
             .handle_new_block(block)
             .await

bin/flashstat-tui/src/main.rs

@@ -1,19 +1,19 @@
 use crossterm::{
     event::{self, DisableMouseCapture, EnableMouseCapture, Event, KeyCode},
     execute,
-    terminal::{EnterAlternateScreen, LeaveAlternateScreen, disable_raw_mode, enable_raw_mode},
+    terminal::{disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen},
 };
 use eyre::Result;
 use flashstat_api::FlashApiClient;
 use flashstat_common::{FlashBlock, ReorgEvent, SequencerStats, SystemHealth};
 use jsonrpsee::http_client::HttpClientBuilder;
 use ratatui::{
-    Frame, Terminal,
     backend::CrosstermBackend,
     layout::{Constraint, Direction, Layout},
     style::{Color, Modifier, Style},
     text::{Line, Span},
     widgets::{Block, Borders, List, ListItem, Paragraph},
+    Frame, Terminal,
 };
 use std::{
     io,
@@ -202,18 +202,27 @@ fn ui(f: &mut Frame, app: &App) {
         .iter()
         .map(|b| {
             let content = vec![Line::from(vec![
-                Span::styled(format!("#{:<10}", b.number), Style::default().fg(Color::Cyan)),
+                Span::styled(
+                    format!("#{:<10}", b.number),
+                    Style::default().fg(Color::Cyan),
+                ),
                 Span::raw(" | "),
-                Span::styled(format!("{:.2}%", b.confidence), Style::default().fg(Color::Yellow)),
+                Span::styled(
+                    format!("{:.2}%", b.confidence),
+                    Style::default().fg(Color::Yellow),
+                ),
                 Span::raw(" | "),
                 Span::raw(format!("{}", b.hash)),
             ])];
             ListItem::new(content)
         })
         .collect();
 
-    let block_list =
-        List::new(blocks).block(Block::default().borders(Borders::ALL).title("Live Block Feed"));
+    let block_list = List::new(blocks).block(
+        Block::default()
+            .borders(Borders::ALL)
+            .title("Live Block Feed"),
+    );
     f.render_widget(block_list, main_chunks[0]);
 
     // Sequencer Reputation
@@ -227,7 +236,10 @@ fn ui(f: &mut Frame, app: &App) {
                 Color::Red
             };
             let content = vec![Line::from(vec![
-                Span::styled(format!("{:.4}… ", s.address), Style::default().fg(Color::Gray)),
+                Span::styled(
+                    format!("{:.4}… ", s.address),
+                    Style::default().fg(Color::Gray),
+                ),
                 Span::styled(
                     format!("Score: {:<5}", s.reputation_score),
                     Style::default().fg(score_color),
@@ -254,9 +266,9 @@ fn ui(f: &mut Frame, app: &App) {
                 flashstat_common::ReorgSeverity::Deep => {
                     Style::default().fg(Color::Red).add_modifier(Modifier::BOLD)
                 }
-                flashstat_common::ReorgSeverity::Equivocation => {
-                    Style::default().fg(Color::Magenta).add_modifier(Modifier::BOLD)
-                }
+                flashstat_common::ReorgSeverity::Equivocation => Style::default()
+                    .fg(Color::Magenta)
+                    .add_modifier(Modifier::BOLD),
             };
 
             let content = vec![Line::from(vec![
@@ -268,7 +280,11 @@ fn ui(f: &mut Frame, app: &App) {
         .collect();
 
     let reorg_list = List::new(reorgs)
-        .block(Block::default().borders(Borders::ALL).title("Security Alerts"))
+        .block(
+            Block::default()
+                .borders(Borders::ALL)
+                .title("Security Alerts"),
+        )
         .highlight_style(
             Style::default()
                 .add_modifier(Modifier::BOLD)

bin/flashstat/src/main.rs

@@ -32,7 +32,7 @@ async fn main() -> Result<()> {
     let storage = std::sync::Arc::new(flashstat_db::RedbStorage::new(&config.storage.db_path)?);
 
     // 6. Run Monitor
-    let mut monitor = FlashMonitor::new(config, storage, shutdown_tx.subscribe()).await?;
+    let monitor = FlashMonitor::new(config, storage, shutdown_tx.subscribe()).await?;
 
     if let Err(e) = monitor.run().await {
         error!("Fatal monitor error: {:?}", e);

crates/flashstat-api/src/lib.rs

@@ -1,9 +1,9 @@
 use ethers::types::H256;
-use flashstat_api::FlashApiServer;
-use flashstat_common::FlashBlock;
-use jsonrpsee::core::RpcResult;
+use flashstat_common::{FlashBlock, ReorgEvent};
 use jsonrpsee::proc_macros::rpc;
 
+use jsonrpsee::core::RpcResult;
+
 #[rpc(server, client, namespace = "flash")]
 pub trait FlashApi {
     #[method(name = "getConfidence")]
@@ -16,10 +16,10 @@ pub trait FlashApi {
     async fn get_recent_blocks(&self, limit: usize) -> RpcResult<Vec<FlashBlock>>;
 
     #[method(name = "getRecentReorgs")]
-    async fn get_recent_reorgs(&self, limit: usize) -> RpcResult<Vec<flashstat_common::ReorgEvent>>;
+    async fn get_recent_reorgs(&self, limit: usize) -> RpcResult<Vec<ReorgEvent>>;
 
     #[method(name = "getEquivocations")]
-    async fn get_equivocations(&self, limit: usize) -> RpcResult<Vec<flashstat_common::ReorgEvent>>;
+    async fn get_equivocations(&self, limit: usize) -> RpcResult<Vec<ReorgEvent>>;
 
     #[method(name = "getHealth")]
     async fn get_health(&self) -> RpcResult<flashstat_common::SystemHealth>;
@@ -33,6 +33,6 @@ pub trait FlashApi {
     #[subscription(name = "subscribeBlocks", item = FlashBlock)]
     async fn subscribe_blocks(&self) -> jsonrpsee::core::SubscriptionResult;
 
-    #[subscription(name = "subscribeEvents", item = flashstat_common::ReorgEvent)]
+    #[subscription(name = "subscribeEvents", item = ReorgEvent)]
     async fn subscribe_events(&self) -> jsonrpsee::core::SubscriptionResult;
 }