diff --git a/protocols/noise/src/io.rs b/protocols/noise/src/io.rs index c1b6616c..780a76c6 100644 --- a/protocols/noise/src/io.rs +++ b/protocols/noise/src/io.rs @@ -62,14 +62,14 @@ pub(crate) enum SnowState { } impl SnowState { - pub fn read_message(&mut self, message: &[u8], payload: &mut [u8]) -> Result { + pub fn read_message(&mut self, message: &[u8], payload: &mut [u8]) -> Result { match self { SnowState::Handshake(session) => session.read_message(message, payload), SnowState::Transport(session) => session.read_message(message, payload), } } - pub fn write_message(&mut self, message: &[u8], payload: &mut [u8]) -> Result { + pub fn write_message(&mut self, message: &[u8], payload: &mut [u8]) -> Result { match self { SnowState::Handshake(session) => session.write_message(message, payload), SnowState::Transport(session) => session.write_message(message, payload), @@ -83,10 +83,10 @@ impl SnowState { } } - pub fn into_transport_mode(self) -> Result { + pub fn into_transport_mode(self) -> Result { match self { SnowState::Handshake(session) => session.into_transport_mode(), - SnowState::Transport(_) => Err(SnowError::State(StateProblem::HandshakeAlreadyFinished)), + SnowState::Transport(_) => Err(snow::Error::State(snow::error::StateProblem::HandshakeAlreadyFinished)), } } } diff --git a/protocols/noise/src/io/handshake.rs b/protocols/noise/src/io/handshake.rs index ff966877..504b0118 100644 --- a/protocols/noise/src/io/handshake.rs +++ b/protocols/noise/src/io/handshake.rs @@ -122,7 +122,7 @@ impl Future for Handshake { /// ``` pub fn rt1_initiator( io: T, - session: Result, + session: Result, identity: KeypairIdentity, identity_x: IdentityExchange ) -> Handshake @@ -156,7 +156,7 @@ where /// ``` pub fn rt1_responder( io: T, - session: Result, + session: Result, identity: KeypairIdentity, identity_x: IdentityExchange, ) -> Handshake @@ -192,7 +192,7 @@ where /// ``` pub fn rt15_initiator( io: T, - session: Result, + session: Result, identity: KeypairIdentity, identity_x: IdentityExchange ) -> Handshake @@ -229,7 +229,7 @@ where /// ``` pub fn rt15_responder( io: T, - session: Result, + session: Result, identity: KeypairIdentity, identity_x: IdentityExchange ) -> Handshake @@ -363,7 +363,7 @@ where let mut payload_buf = vec![0; len]; state.io.read_exact(&mut payload_buf).await?; - let pb: payload::Identity = protobuf::parse_from_bytes(&payload_buf)?; + let pb: payload_proto::Identity = protobuf::parse_from_bytes(&payload_buf)?; if !pb.pubkey.is_empty() { let pk = identity::PublicKey::from_protobuf_encoding(pb.get_pubkey()) @@ -387,7 +387,7 @@ async fn send_identity(state: &mut State) -> Result<(), NoiseError> where T: AsyncWrite + Unpin, { - let mut pb = payload::Identity::new(); + let mut pb = payload_proto::Identity::new(); if state.send_identity { pb.set_pubkey(state.identity.public.clone().into_protobuf_encoding()); }