satisfy the clippy

Author: rkuhn

crates/amaru-consensus/src/chain_forward.rs

@@ -69,7 +69,9 @@ impl ForwardStage {
         network_magic: u64,
         listen_address: &str,
     ) -> Self {
-        let runtime = AcTokio::new("consensus.forward", 1).unwrap();
+        #[allow(clippy::expect_used)]
+        let runtime =
+            AcTokio::new("consensus.forward", 1).expect("failed to create AcTokio runtime");
         Self {
             store,
             upstream: Default::default(),
@@ -105,7 +107,9 @@ impl gasket::framework::Worker<ForwardStage> for Worker {
         let server = TcpListener::bind(&stage.listen_address).await.or_panic()?;
         if let Some(downstream) = &stage.downstream {
             tracing::debug!("sending listening event");
-            downstream.send(ForwardEvent::Listening(server.local_addr().unwrap().port()));
+            downstream.send(ForwardEvent::Listening(
+                server.local_addr().or_panic()?.port(),
+            ));
         }
 
         let (tx, incoming_peers) = mpsc::channel(10);
@@ -247,6 +251,7 @@ impl gasket::framework::Worker<ForwardStage> for Worker {
     }
 }
 
+#[allow(clippy::large_enum_variant)]
 enum ClientMsg {
     Peer(PeerServer, Tip),
     Op(ClientOp),

crates/amaru-consensus/src/chain_forward/client_protocol.rs

@@ -68,6 +68,7 @@ pub async fn client_protocols(
     Ok(())
 }
 
+#[allow(clippy::large_enum_variant)]
 pub enum ChainSyncMsg {
     /// An operation coming in from the ledger
     Op(ClientOp),

crates/amaru-consensus/src/chain_forward/client_state.rs

@@ -5,6 +5,7 @@ use pallas_network::miniprotocols::{chainsync::Tip, Point};
 use std::{collections::VecDeque, sync::Arc};
 use tokio::sync::Mutex;
 
+#[allow(clippy::large_enum_variant)]
 #[derive(Debug, Clone, PartialEq, Eq)]
 pub(super) enum ClientOp {
     Backward(Point),
@@ -47,7 +48,10 @@ impl ClientState {
             match op {
                 ClientOp::Backward(point) => {
                     let store = self.store.lock().await;
-                    let header = store.load_header(&hash_point(point)).unwrap();
+                    #[allow(clippy::expect_used)]
+                    let header = store
+                        .load_header(&hash_point(point))
+                        .expect("rollback point was not in store");
                     Tip(point.clone(), header.block_height())
                 }
                 ClientOp::Forward(header) => {