refactor(noise): modify message framing

Resolves #4488.

Pull-Request: #4548.

Author: 0xcrust

Cargo.lock

@@ -9,6 +9,7 @@ license = "MIT"
 repository = "https://github.com/libp2p/rust-libp2p"
 
 [dependencies]
+asynchronous-codec = "0.7"
 bytes = "1"
 curve25519-dalek = "4.1.1"
 futures = "0.3.28"

transports/noise/Cargo.toml

@@ -22,8 +22,9 @@
 
 mod framed;
 pub(crate) mod handshake;
+use asynchronous_codec::Framed;
 use bytes::Bytes;
-use framed::{NoiseFramed, MAX_FRAME_LEN};
+use framed::{Codec, MAX_FRAME_LEN};
 use futures::prelude::*;
 use futures::ready;
 use log::trace;
@@ -38,7 +39,7 @@ use std::{
 ///
 /// `T` is the type of the underlying I/O resource.
 pub struct Output<T> {
-    io: NoiseFramed<T, snow::TransportState>,
+    io: Framed<T, Codec<snow::TransportState>>,
     recv_buffer: Bytes,
     recv_offset: usize,
     send_buffer: Vec<u8>,
@@ -47,12 +48,12 @@ pub struct Output<T> {
 
 impl<T> fmt::Debug for Output<T> {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-        f.debug_struct("NoiseOutput").field("io", &self.io).finish()
+        f.debug_struct("NoiseOutput").finish()
     }
 }
 
 impl<T> Output<T> {
-    fn new(io: NoiseFramed<T, snow::TransportState>) -> Self {
+    fn new(io: Framed<T, Codec<snow::TransportState>>) -> Self {
         Output {
             io,
             recv_buffer: Bytes::new(),