Emit qlog PacketReceived events

Author: Ralith

quinn-proto/src/connection/mod.rs

@@ -1934,6 +1934,14 @@ impl Connection {
             // Update outgoing spin bit, inverting iff we're the client
             self.spin = self.side.is_client() ^ spin;
         }
+
+        self.config.qlog_sink.emit_packet_received(
+            packet,
+            space_id,
+            !is_1rtt,
+            now,
+            self.orig_rem_cid,
+        );
     }
 
     fn reset_idle_timeout(&mut self, now: Instant, space: SpaceId) {

quinn-proto/src/connection/qlog.rs

@@ -8,7 +8,9 @@ use std::sync::{Arc, Mutex};
 use qlog::{
     events::{
         Event, EventData,
-        quic::{PacketHeader, PacketLost, PacketLostTrigger, PacketSent, PacketType},
+        quic::{
+            PacketHeader, PacketLost, PacketLostTrigger, PacketReceived, PacketSent, PacketType,
+        },
     },
     streamer::QlogStreamer,
 };
@@ -141,6 +143,33 @@ impl QlogSink {
             stream.emit_event(orig_rem_cid, EventData::PacketSent(event), now);
         }
     }
+
+    pub(super) fn emit_packet_received(
+        &self,
+        pn: u64,
+        space: SpaceId,
+        is_0rtt: bool,
+        now: Instant,
+        orig_rem_cid: ConnectionId,
+    ) {
+        #[cfg(feature = "qlog")]
+        {
+            let Some(stream) = self.stream.as_ref() else {
+                return;
+            };
+
+            let event = PacketReceived {
+                header: PacketHeader {
+                    packet_number: Some(pn),
+                    packet_type: packet_type(space, is_0rtt),
+                    ..Default::default()
+                },
+                ..Default::default()
+            };
+
+            stream.emit_event(orig_rem_cid, EventData::PacketReceived(event), now);
+        }
+    }
 }
 
 #[cfg(feature = "qlog")]