fmt

roles/jd-client/src/lib/mod.rs

@@ -6,8 +6,7 @@ pub mod status;
 pub mod template_receiver;
 pub mod upstream_sv2;
 
-use std::sync::atomic::AtomicBool;
-use std::time::Duration;
+use std::{sync::atomic::AtomicBool, time::Duration};
 
 /// Is used by the template receiver and the downstream. When a NewTemplate is received the context
 /// that is running the template receiver set this value to false and then the message is sent to

roles/jd-client/src/lib/template_receiver/mod.rs

@@ -1,18 +1,16 @@
 use super::{job_declarator::JobDeclarator, status, PoolChangerTrigger};
 use async_channel::{Receiver, Sender};
-use codec_sv2::Frame;
-use codec_sv2::{HandshakeRole, Initiator, StandardEitherFrame, StandardSv2Frame};
+use codec_sv2::{Frame, HandshakeRole, Initiator, StandardEitherFrame, StandardSv2Frame};
 use error_handling::handle_result;
 use key_utils::Secp256k1PublicKey;
 use network_helpers::noise_connection_tokio::Connection;
 use roles_logic_sv2::{
     handlers::{template_distribution::ParseServerTemplateDistributionMessages, SendTo_},
-    parsers::{PoolMessages, TemplateDistribution},
-    template_distribution_sv2::{CoinbaseOutputDataSize, SubmitSolution},
-};
-use roles_logic_sv2::{
     job_declaration_sv2::AllocateMiningJobTokenSuccess,
-    template_distribution_sv2::{NewTemplate, RequestTransactionData},
+    parsers::{PoolMessages, TemplateDistribution},
+    template_distribution_sv2::{
+        CoinbaseOutputDataSize, NewTemplate, RequestTransactionData, SubmitSolution,
+    },
     utils::Mutex,
 };
 use setup_connection::SetupConnectionHandler;

roles/pool/src/lib/mining_pool/mod.rs

@@ -22,8 +22,12 @@ use roles_logic_sv2::{
     utils::{CoinbaseOutput as CoinbaseOutput_, Mutex},
 };
 use serde::Deserialize;
-use std::convert::{TryFrom, TryInto};
-use std::{collections::HashMap, net::SocketAddr, sync::Arc};
+use std::{
+    collections::HashMap,
+    convert::{TryFrom, TryInto},
+    net::SocketAddr,
+    sync::Arc,
+};
 use stratum_common::bitcoin::{Script, TxOut};
 use tokio::{net::TcpListener, task};
 use tracing::{debug, error, info, warn};

roles/translator/src/lib/upstream_sv2/upstream_connection.rs

@@ -1,5 +1,4 @@
-use super::super::error::ProxyResult;
-use super::{EitherFrame, StdFrame};
+use super::{super::error::ProxyResult, EitherFrame, StdFrame};
 use async_channel::{Receiver, Sender};
 
 /// Handles the sending and receiving of messages to and from an SV2 Upstream role (most typically