replace LengthDelimitedCodec with custom MessageFrameCodec

Author: aschran

crates/anemo/src/config.rs

@@ -63,13 +63,13 @@ pub struct Config {
     ///
     /// This limit is applied in the following ways:
     ///  - Inbound connections from [`KnownPeers`] with [`PeerAffinity::High`] or
-    ///     [`PeerAffinity::Allowed`] bypass this limit. All other inbound
-    ///     connections are only accepted if the total number of inbound and outbound
-    ///     connections, irrespective of affinity, is less than this limit.
+    ///    [`PeerAffinity::Allowed`] bypass this limit. All other inbound
+    ///    connections are only accepted if the total number of inbound and outbound
+    ///    connections, irrespective of affinity, is less than this limit.
     ///  - Outbound connections explicitly made by the application via [`Network::connect`] or
-    ///     [`Network::connect_with_peer_id`] bypass this limit.
+    ///    [`Network::connect_with_peer_id`] bypass this limit.
     ///  - Outbound connections made in the background, due to configured [`KnownPeers`], to peers with
-    ///     [`PeerAffinity::High`] bypass this limit and are always attempted.
+    ///    [`PeerAffinity::High`] bypass this limit and are always attempted.
     ///
     /// If unspecified, there will be no limit on the number of concurrent connections.
     ///

crates/anemo/src/crypto.rs

@@ -326,9 +326,12 @@ fn pki_error(error: webpki::Error) -> rustls::Error {
         BadDer | BadDerTime => {
             rustls::Error::InvalidCertificate(rustls::CertificateError::BadEncoding)
         }
+        #[allow(deprecated)]
         InvalidSignatureForPublicKey
         | UnsupportedSignatureAlgorithm
-        | UnsupportedSignatureAlgorithmForPublicKey => {
+        | UnsupportedSignatureAlgorithmForPublicKey
+        | UnsupportedSignatureAlgorithmContext(..)
+        | UnsupportedSignatureAlgorithmForPublicKeyContext(..) => {
             rustls::Error::InvalidCertificate(rustls::CertificateError::BadSignature)
         }
         e => {

crates/anemo/src/network/request_handler.rs

@@ -1,3 +1,4 @@
+use super::wire::MessageFrameCodec;
 use super::{
     wire::{network_message_frame_codec, read_request, write_response},
     ActivePeers,
@@ -10,7 +11,7 @@ use bytes::Bytes;
 use quinn::RecvStream;
 use std::convert::Infallible;
 use std::sync::Arc;
-use tokio_util::codec::{FramedRead, FramedWrite, LengthDelimitedCodec};
+use tokio_util::codec::{FramedRead, FramedWrite};
 use tower::{util::BoxCloneService, ServiceExt};
 use tracing::{debug, trace};
 
@@ -121,8 +122,8 @@ impl InboundRequestHandler {
 struct BiStreamRequestHandler {
     connection: Connection,
     service: BoxCloneService<Request<Bytes>, Response<Bytes>, Infallible>,
-    send_stream: FramedWrite<SendStream, LengthDelimitedCodec>,
-    recv_stream: FramedRead<RecvStream, LengthDelimitedCodec>,
+    send_stream: FramedWrite<SendStream, MessageFrameCodec>,
+    recv_stream: FramedRead<RecvStream, MessageFrameCodec>,
 }
 
 impl BiStreamRequestHandler {