Fix lint errors

src/raft/logic.rs

@@ -243,7 +243,7 @@ impl RaftState {
                             leader.clone_from(current_leader);
                         }
                     };
-                    if !old_voted_for.is_some_and(|id| id == from) {
+                    if old_voted_for.is_none_or(|id| id != from) {
                         // If we're newly voting for someone, reset the election timeout
                         self.last_event = timestamp;
                     }
@@ -302,11 +302,10 @@ impl RaftState {
                             );
                             self.set_status(RaftStatus::Leader { abdicating: false });
                             // Immediately send a heartbeat to make leader election stable
-                            return self
-                                .peers
+                            self.peers
                                 .iter()
                                 .map(|peer| (peer.clone(), RaftMessage::Heartbeat { term: *term }))
-                                .collect();
+                                .collect()
                         } else {
                             vec![]
                         }

src/signature_aggregator/price_instrumentation.rs

@@ -41,7 +41,7 @@ impl PriceInstrumentation {
     }
 
     pub fn track_prices(&mut self, round: &str, prices: &[PriceFeed]) {
-        if !self.round.as_ref().is_some_and(|r| r == round) {
+        if self.round.as_ref().is_none_or(|r| r != round) {
             return;
         }
         for (key, value) in prices.iter().flat_map(extract_prices_from_feed) {

src/signature_aggregator/signer.rs

@@ -819,10 +819,10 @@ impl Signer {
             .await
             .context("Could not publish signed result")?;
 
-        if !self
+        if self
             .latest_payload
             .as_ref()
-            .is_some_and(|old| old.timestamp > payload.timestamp)
+            .is_none_or(|old| old.timestamp <= payload.timestamp)
         {
             self.latest_payload = Some(payload);
         }

src/sources/binance.rs

@@ -30,7 +30,7 @@ impl Source for BinanceSource {
         self.streams.values().map(|c| c.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/bybit.rs

@@ -2,7 +2,7 @@ use std::str::FromStr;
 
 use anyhow::{anyhow, Result};
 use dashmap::DashMap;
-use futures::{FutureExt, SinkExt, StreamExt};
+use futures::{future::BoxFuture, FutureExt, SinkExt, StreamExt};
 use rust_decimal::Decimal;
 use serde::{Deserialize, Serialize};
 use tokio::{
@@ -51,10 +51,7 @@ impl Source for ByBitSource {
             .collect()
     }
 
-    fn query<'a>(
-        &'a self,
-        sink: &'a PriceSink,
-    ) -> futures::prelude::future::BoxFuture<anyhow::Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/coinbase.rs

@@ -27,7 +27,7 @@ impl Source for CoinbaseSource {
         self.products.values().map(|p| p.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/fxratesapi.rs

@@ -39,7 +39,7 @@ impl Source for FxRatesApiSource {
     fn tokens(&self) -> Vec<String> {
         self.currencies.clone()
     }
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/maestro.rs

@@ -36,7 +36,7 @@ impl Source for MaestroSource {
         self.tokens.iter().map(|t| t.token.to_string()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/minswap.rs

@@ -30,7 +30,7 @@ impl Source for MinswapSource {
         self.pools.iter().map(|p| p.pool.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/source.rs

@@ -21,5 +21,5 @@ pub trait Source {
         Duration::from_secs(30)
     }
     fn tokens(&self) -> Vec<String>;
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>>;
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>>;
 }

src/sources/spectrum.rs

@@ -30,7 +30,7 @@ impl Source for SpectrumSource {
         self.pools.iter().map(|p| p.pool.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/sundaeswap.rs

@@ -31,7 +31,7 @@ impl Source for SundaeSwapSource {
         self.pools.iter().map(|p| p.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<anyhow::Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }

src/sources/sundaeswap_kupo.rs

@@ -36,7 +36,7 @@ impl Source for SundaeSwapKupoSource {
         self.pools.iter().map(|e| e.pool.token.clone()).collect()
     }
 
-    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<Result<()>> {
+    fn query<'a>(&'a self, sink: &'a PriceSink) -> BoxFuture<'a, Result<()>> {
         self.query_impl(sink).boxed()
     }
 }