crates: formatting with new 2024 edition rules

`cargo fmt --all`

Changelog-None

Author: daywalker90

cln-rpc/examples/getinfo.rs

@@ -1,5 +1,5 @@
-use anyhow::{anyhow, Context};
-use cln_rpc::{model::requests::GetinfoRequest, ClnRpc, Request};
+use anyhow::{Context, anyhow};
+use cln_rpc::{ClnRpc, Request, model::requests::GetinfoRequest};
 use std::env::args;
 use std::path::Path;
 use tokio;

cln-rpc/src/jsonrpc.rs

@@ -1,8 +1,8 @@
 //! Common structs to handle JSON-RPC decoding and encoding. They are
 //! generic over the Notification and Request types.
 
-use serde::ser::{SerializeStruct, Serializer};
 use serde::de::{self, Deserializer};
+use serde::ser::{SerializeStruct, Serializer};
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
 use std::fmt::Debug;

cln-rpc/src/lib.rs

@@ -79,15 +79,15 @@ use crate::codec::JsonCodec;
 pub use anyhow::Error;
 use anyhow::Result;
 use core::fmt::Debug;
-use futures_util::sink::SinkExt;
 use futures_util::StreamExt;
+use futures_util::sink::SinkExt;
 use log::{debug, trace};
-use serde::{de::DeserializeOwned, Serialize};
+use serde::{Serialize, de::DeserializeOwned};
 use std::path::Path;
 use std::sync::atomic::AtomicUsize;
 use std::sync::atomic::Ordering;
-use tokio::net::unix::{OwnedReadHalf, OwnedWriteHalf};
 use tokio::net::UnixStream;
+use tokio::net::unix::{OwnedReadHalf, OwnedWriteHalf};
 use tokio_util::codec::{FramedRead, FramedWrite};
 
 pub mod codec;
@@ -559,8 +559,11 @@ mod test {
     #[test]
     fn serialize_custom_msg_notification() {
         let msg = CustomMsgNotification {
-            peer_id : PublicKey::from_str("0364aeb75519be29d1af7b8cc6232dbda9fdabb79b66e4e1f6a223750954db210b").unwrap(),
-            payload : String::from("941746573749")
+            peer_id: PublicKey::from_str(
+                "0364aeb75519be29d1af7b8cc6232dbda9fdabb79b66e4e1f6a223750954db210b",
+            )
+            .unwrap(),
+            payload: String::from("941746573749"),
         };
 
         let notification = Notification::CustomMsg(msg);
@@ -576,14 +579,16 @@ mod test {
                 }
             )
         );
-
     }
 
     #[test]
     fn serialize_block_added_notification() {
         let block_added = BlockAddedNotification {
-            hash : crate::primitives::Sha256::from_str("000000000000000000000acab8abe0c67a52ed7e5a90a19c64930ff11fa84eca").unwrap(),
-            height : 830702
+            hash: crate::primitives::Sha256::from_str(
+                "000000000000000000000acab8abe0c67a52ed7e5a90a19c64930ff11fa84eca",
+            )
+            .unwrap(),
+            height: 830702,
         };
 
         let notification = Notification::BlockAdded(block_added);
@@ -613,6 +618,6 @@ mod test {
             }
         });
 
-        let _ : Notification = serde_json::from_value(connect_json).unwrap();
+        let _: Notification = serde_json::from_value(connect_json).unwrap();
     }
 }

cln-rpc/src/primitives.rs

@@ -1,6 +1,6 @@
 //! Primitive types representing [`Amount`]s, [`PublicKey`]s, ...
 use anyhow::Context;
-use anyhow::{anyhow, Error, Result};
+use anyhow::{Error, Result, anyhow};
 use bitcoin::hashes::Hash as BitcoinHash;
 use serde::{Deserialize, Serialize};
 use serde::{Deserializer, Serializer};

plugins/bip353-plugin/src/config.rs

@@ -1,4 +1,4 @@
-use cln_plugin::{messages::ProxyInfo, Plugin};
+use cln_plugin::{Plugin, messages::ProxyInfo};
 
 pub fn get_proxy(plugin: Plugin<()>) -> Option<ProxyInfo> {
     match plugin.configuration().always_use_proxy {

plugins/bip353-plugin/src/main.rs

@@ -3,8 +3,8 @@ use std::time::Duration;
 use anyhow::anyhow;
 use bitcoin::hex::DisplayHex;
 use bitcoin_payment_instructions::{
-    hrn_resolution::HumanReadableName, http_resolver::HTTPHrnResolver, PaymentInstructions,
-    PaymentMethod, PossiblyResolvedPaymentMethod,
+    PaymentInstructions, PaymentMethod, PossiblyResolvedPaymentMethod,
+    hrn_resolution::HumanReadableName, http_resolver::HTTPHrnResolver,
 };
 use cln_plugin::{Builder, Plugin, RpcMethodBuilder};
 use serde::Serialize;

plugins/currencyrate-plugin/src/main.rs

@@ -2,7 +2,7 @@ use anyhow::anyhow;
 use cln_plugin::options::StringArrayConfigOption;
 use cln_plugin::{Builder, ConfiguredPlugin, Plugin, RpcMethodBuilder};
 use cln_rpc::ClnRpc;
-use serde_json::{json, Value};
+use serde_json::{Value, json};
 use std::net::{IpAddr, SocketAddr};
 use std::path::Path;
 use std::str::FromStr;
@@ -190,7 +190,10 @@ async fn currencyrate(plugin: Plugin<PluginState>, args: Value) -> Result<Value,
     }
 }
 
-async fn listcurrencyrates(plugin: Plugin<PluginState>, args: Value) -> Result<Value, anyhow::Error> {
+async fn listcurrencyrates(
+    plugin: Plugin<PluginState>,
+    args: Value,
+) -> Result<Value, anyhow::Error> {
     let currency = match args {
         Value::Array(values) => {
             let currency = values

plugins/examples/cln-plugin-startup.rs

@@ -7,7 +7,7 @@ use cln_plugin::options::{
     DefaultStringArrayConfigOption, IntegerArrayConfigOption, IntegerConfigOption,
     StringArrayConfigOption,
 };
-use cln_plugin::{messages, Builder, Error, HookBuilder, Plugin};
+use cln_plugin::{Builder, Error, HookBuilder, Plugin, messages};
 
 const TEST_NOTIF_TAG: &str = "test_custom_notification";
 

plugins/examples/cln-subscribe-wildcard.rs

@@ -1,6 +1,5 @@
 /// This plug-in subscribes to the wildcard-notifications
 /// and creates a corresponding log-entry
-
 use anyhow::Result;
 use cln_plugin::{Builder, Plugin};
 
@@ -14,21 +13,15 @@ async fn main() -> Result<()> {
         .await?;
 
     match configured {
-	Some(p) => p.join().await?,
-	None => return Ok(()) // cln was started with --help
+        Some(p) => p.join().await?,
+        None => return Ok(()), // cln was started with --help
     };
 
     Ok(())
 }
 
-async fn handle_wildcard_notification(_plugin: Plugin<()>, value : serde_json::Value) -> Result<()> {
-    let notification_type : String = value
-	.as_object()
-	.unwrap()
-	.keys()
-	.next()
-	.unwrap()
-	.into();
+async fn handle_wildcard_notification(_plugin: Plugin<()>, value: serde_json::Value) -> Result<()> {
+    let notification_type: String = value.as_object().unwrap().keys().next().unwrap().into();
 
     log::info!("Received notification {}", notification_type);
     Ok(())

plugins/grpc-plugin/src/main.rs

@@ -1,6 +1,6 @@
 use anyhow::{Context, Result};
 use cln_grpc::pb::node_server::NodeServer;
-use cln_plugin::{options, Builder, Plugin};
+use cln_plugin::{Builder, Plugin, options};
 use cln_rpc::notifications::Notification;
 use std::net::SocketAddr;
 use std::path::PathBuf;
@@ -30,10 +30,12 @@ const OPTION_GRPC_HOST: options::DefaultStringConfigOption =
         "Which host should the grpc listen for incomming connections?",
     );
 
-const OPTION_GRPC_MSG_BUFFER_SIZE : options::DefaultIntegerConfigOption = options::ConfigOption::new_i64_with_default(
-    "grpc-msg-buffer-size",
-    1024,
-    "Number of notifications which can be stored in the grpc message buffer. Notifications can be skipped if this buffer is full");
+const OPTION_GRPC_MSG_BUFFER_SIZE: options::DefaultIntegerConfigOption =
+    options::ConfigOption::new_i64_with_default(
+        "grpc-msg-buffer-size",
+        1024,
+        "Number of notifications which can be stored in the grpc message buffer. Notifications can be skipped if this buffer is full",
+    );
 
 #[tokio::main(flavor = "current_thread")]
 async fn main() -> Result<()> {