Merge pull request from GHSA-rfhg-rjfp-9q8q

* fix(s2n-quic-transport): close connection when no available connection ids

* allow all connection migrations when testing

* add generator to stateless reset token

* fix partial eq impl for connection IDs

* add new connection ID to fuzz test

* implement hash and fix merge issues

* Impl PartialOrd and Ord

* PR feedback

* clippy

quic/s2n-quic-core/src/connection/id.rs

@@ -35,7 +35,7 @@ pub const MAX_LIFETIME: Duration = Duration::from_secs(24 * 60 * 60); // one day
 macro_rules! id {
     ($type:ident, $min_len:expr) => {
         /// Uniquely identifies a QUIC connection between 2 peers
-        #[derive(Copy, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
+        #[derive(Copy, Clone, Eq)]
         #[cfg_attr(any(feature = "generator", test), derive(TypeGenerator))]
         pub struct $type {
             bytes: [u8; MAX_LEN],
@@ -49,6 +49,30 @@ macro_rules! id {
             }
         }
 
+        impl PartialEq for $type {
+            fn eq(&self, other: &Self) -> bool {
+                self.as_bytes() == other.as_bytes()
+            }
+        }
+
+        impl core::hash::Hash for $type {
+            fn hash<H: core::hash::Hasher>(&self, state: &mut H) {
+                self.as_bytes().hash(state);
+            }
+        }
+
+        impl PartialOrd for $type {
+            fn partial_cmp(&self, other: &Self) -> Option<core::cmp::Ordering> {
+                Some(self.cmp(other))
+            }
+        }
+
+        impl Ord for $type {
+            fn cmp(&self, other: &Self) -> core::cmp::Ordering {
+                self.as_bytes().cmp(&other.as_bytes())
+            }
+        }
+
         impl $type {
             /// The minimum length for this connection ID type
             pub const MIN_LEN: usize = $min_len;

quic/s2n-quic-core/src/path/migration.rs

@@ -219,3 +219,18 @@ pub mod disabled {
         }
     }
 }
+
+#[cfg(any(test, feature = "testing"))]
+pub mod allow_all {
+    use super::*;
+
+    #[derive(Debug, Default)]
+    pub struct Validator;
+
+    impl super::Validator for Validator {
+        fn on_migration_attempt(&mut self, _attempt: &Attempt) -> Outcome {
+            // allow all migration attempts
+            Outcome::Allow
+        }
+    }
+}

quic/s2n-quic-core/src/stateless_reset/token.rs

@@ -20,6 +20,10 @@ pub const LEN: usize = 128 / 8;
 // Hash can still be derived.
 #[allow(clippy::derived_hash_with_manual_eq)]
 #[derive(Copy, Clone, Debug, Eq, Hash)]
+#[cfg_attr(
+    any(test, feature = "generator"),
+    derive(bolero_generator::TypeGenerator)
+)]
 pub struct Token([u8; LEN]);
 
 impl Token {

quic/s2n-quic-transport/src/endpoint/mod.rs

@@ -1172,7 +1172,7 @@ pub mod testing {
         type StreamManager = crate::stream::DefaultStreamManager;
         type ConnectionCloseFormatter = s2n_quic_core::connection::close::Development;
         type EventSubscriber = Subscriber;
-        type PathMigrationValidator = path::migration::default::Validator;
+        type PathMigrationValidator = path::migration::allow_all::Validator;
         type PacketInterceptor = s2n_quic_core::packet::interceptor::Disabled;
         type DatagramEndpoint = s2n_quic_core::datagram::Disabled;
 
@@ -1202,7 +1202,7 @@ pub mod testing {
         type StreamManager = crate::stream::DefaultStreamManager;
         type ConnectionCloseFormatter = s2n_quic_core::connection::close::Development;
         type EventSubscriber = Subscriber;
-        type PathMigrationValidator = path::migration::default::Validator;
+        type PathMigrationValidator = path::migration::allow_all::Validator;
         type PacketInterceptor = s2n_quic_core::packet::interceptor::Disabled;
         type DatagramEndpoint = s2n_quic_core::datagram::Disabled;
 

quic/s2n-quic-transport/src/path/manager.rs

@@ -705,11 +705,10 @@ impl<Config: endpoint::Config> Manager<Config> {
                     active_path_connection_id,
                     publisher,
                 )
-                .expect(
-                    "since we are only checking the active path and new id was delivered \
-                    via the new_connection_id frames, there will always be a new id available \
-                    to consume if necessary",
-                );
+                .ok_or(transport::Error::PROTOCOL_VIOLATION.with_reason(
+                    "A NEW_CONNECTION_ID frame was received that retired the active path's \
+                    connection ID and no unused connection IDs remain to replace it",
+                ))?
         }
 
         Ok(())