checkpoint

crates/tx5/Cargo.toml

@@ -22,11 +22,14 @@ backend-webrtc-rs = [ "tx5-connection/backend-webrtc-rs" ]
 [dependencies]
 base64 = { workspace = true }
 tokio = { workspace = true, features = [ "full" ] }
+tracing = { workspace = true }
 tx5-connection = { workspace = true, default-features = false }
 tx5-core = { workspace = true }
 url = { workspace = true }
 
 [dev-dependencies]
+sbd-server = { workspace = true }
+tracing-subscriber = { workspace = true }
 
 [[bench]]
 name = "throughput"

crates/tx5/src/ep.rs

@@ -36,6 +36,32 @@ pub enum EndpointEvent {
     },
 }
 
+impl std::fmt::Debug for EndpointEvent {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            Self::ListeningAddressOpen { local_url } => {
+                f.debug_struct("ListeningAddressOpen").field("peer_url", local_url).finish()
+            }
+            Self::ListeningAddressClosed { local_url } => {
+                f.debug_struct("ListeningAddressClosed")
+                    .field("peer_url", local_url)
+                    .finish()
+            }
+            Self::Connected { peer_url } => {
+                f.debug_struct("Connected").field("peer_url", peer_url).finish()
+            }
+            Self::Disconnected { peer_url } => {
+                f.debug_struct("Disconnected")
+                    .field("peer_url", peer_url)
+                    .finish()
+            }
+            Self::Message { peer_url, .. } => {
+                f.debug_struct("Message").field("peer_url", peer_url).finish()
+            }
+        }
+    }
+}
+
 pub(crate) struct EpInner {
     this: Weak<Mutex<EpInner>>,
     config: Arc<Config>,

crates/tx5/src/lib.rs

@@ -63,6 +63,9 @@ pub(crate) use peer::*;
 mod ep;
 pub use ep::*;
 
+#[cfg(test)]
+mod test;
+
 //pub use tx5_core::Tx5InitConfig;
 
 // #[cfg(test)]