more stuff

quic/src/connections/codes.rs

@@ -0,0 +1,38 @@
+use std::fmt::Display;
+
+#[derive(Debug)]
+pub(super) enum ResetCode {
+    Unspecified,
+}
+
+impl From<u32> for ResetCode {
+    fn from(value: u32) -> Self {
+        match value {
+            0 => Self::Unspecified,
+
+            _ => Self::Unspecified,
+        }
+    }
+}
+
+impl From<ResetCode> for u32 {
+    fn from(value: ResetCode) -> Self {
+        match value {
+            ResetCode::Unspecified => 0,
+        }
+    }
+}
+
+impl From<ResetCode> for quinn_proto::VarInt {
+    fn from(value: ResetCode) -> Self {
+        quinn_proto::VarInt::from_u32(value.into())
+    }
+}
+
+impl Display for ResetCode {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        f.write_str(match self {
+            ResetCode::Unspecified => "unspecified or unknown",
+        })
+    }
+}

quic/src/connections/mod.rs

@@ -1,3 +1,4 @@
+mod codes;
 mod systems;
 
 pub(crate) use systems::*;

quic/src/connections/systems.rs

@@ -2,6 +2,7 @@ use std::{sync::Mutex, time::Instant};
 use bevy::{prelude::*, utils::HashMap};
 use bevy_stardust::{connections::{PeerAddress, PeerRtt}, prelude::*};
 use bytes::BytesMut;
+use connections::codes::ResetCode;
 use datagrams::{Datagram, DatagramDesequencer, DatagramHeader, DatagramPurpose, DatagramSequencer};
 use endpoints::perform_transmit;
 use quinn_proto::{Connection, Dir, Event as AppEvent, SendDatagramError, StreamEvent, StreamId, VarInt};
@@ -164,7 +165,12 @@ pub(crate) fn connection_event_handler_system(
                             senders.remove(&id);
                         },
 
-                        (streams::StreamWriteOutcome::Error(_), _) => todo!(),
+                        (streams::StreamWriteOutcome::Error(_), _) => {
+                            trace!("Stream reset due to error: ");
+                            let _ = stream.reset(ResetCode::Unspecified.into());
+                            senders.remove(&id);
+                        },
+
                         _ => {},
                     }
                 },
@@ -173,7 +179,12 @@ pub(crate) fn connection_event_handler_system(
                     readers.remove(&id);
                 },
 
-                StreamEvent::Stopped { id, error_code: _ } => todo!(),
+                StreamEvent::Stopped { id, error_code } => {
+                    let code: ResetCode = (error_code.into_inner() as u32).into();
+                    trace!("Remote peer stopped stream: {code}");
+
+                    todo!()
+                },
 
                 // We don't care about this
                 StreamEvent::Available { dir: _ } => {},