wip

russh-keys/src/agent/client.rs

@@ -4,6 +4,7 @@ use byteorder::{BigEndian, ByteOrder};
 use bytes::Bytes;
 use log::debug;
 use russh_cryptovec::CryptoVec;
+use ssh_encoding::{Decode, Encode, Reader};
 use ssh_key::{Algorithm, HashAlg, PrivateKey, PublicKey, Signature};
 use tokio;
 use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
@@ -12,7 +13,6 @@ use super::{msg, Constraint};
 use crate::encoding::Encoding;
 use crate::helpers::EncodedExt;
 use crate::{key, Error};
-use ssh_encoding::{Decode, Encode, Reader};
 
 pub trait AgentStream: AsyncRead + AsyncWrite {}
 

russh/src/auth.rs

@@ -17,10 +17,10 @@ use std::sync::Arc;
 
 use async_trait::async_trait;
 use bitflags::bitflags;
+use russh_keys::helpers::NameList;
 use ssh_key::{Certificate, PrivateKey};
 use thiserror::Error;
 use tokio::io::{AsyncRead, AsyncWrite};
-use russh_keys::helpers::NameList;
 
 use crate::CryptoVec;
 

russh/src/client/mod.rs

@@ -1418,7 +1418,9 @@ async fn reply<H: Handler>(
                 // We've sent ECDH_INIT, waiting for ECDH_REPLY
 
                 #[allow(clippy::indexing_slicing)] // length checked
-                let kex = kexdhdone.server_key_check(false, handler, &mut &buf[1..]).await?;
+                let kex = kexdhdone
+                    .server_key_check(false, handler, &mut &buf[1..])
+                    .await?;
 
                 session.common.strict_kex = session.common.strict_kex || kex.names.strict_kex;
                 session.common.kex = Some(Kex::Keys(kex));

russh/src/server/mod.rs

@@ -122,7 +122,7 @@ impl Default for Config {
 /// A client's response in a challenge-response authentication.
 ///
 /// You should iterate it to get `&[u8]` response slices.
-pub struct Response<'a> (&'a mut (dyn Iterator<Item = Option<Bytes>> + Send));
+pub struct Response<'a>(&'a mut (dyn Iterator<Item = Option<Bytes>> + Send));
 
 impl Iterator for Response<'_> {
     type Item = Bytes;