From 2870569c55749c74f5507b08816d38ac54371183 Mon Sep 17 00:00:00 2001
From: ospab <ospab@ospab.host>
Date: Fri, 29 May 2026 00:37:08 +0300
Subject: [PATCH] chore: reduce client and server logging verbosity for
 outbound datagrams and relays

---
 ostp-client/src/bridge.rs | 34 +++++++++++++---------------------
 ostp-server/src/lib.rs    |  4 +---
 2 files changed, 14 insertions(+), 24 deletions(-)

diff --git a/ostp-client/src/bridge.rs b/ostp-client/src/bridge.rs
index 5c25fd7..e93f845 100644
--- a/ostp-client/src/bridge.rs
+++ b/ostp-client/src/bridge.rs
@@ -614,12 +614,10 @@ impl Bridge {
                                 Ok(ProtocolAction::SendDatagram(frame)) => {
                                     if send_datagram(&session.socket, &frame, self.transport_mode == "udp" ).await.is_ok() {
                                         self.metrics.bytes_sent.fetch_add(frame.len() as u64, Ordering::Relaxed);
-                                        if self.debug {
-                                            let _ = tx.send(UiEvent::Log(format!(
-                                                "Outbound datagram sent stream_id={stream_id} bytes={}",
-                                                frame.len()
-                                            ))).await;
-                                        }
+                                        tracing::trace!(
+                                            "Outbound datagram sent stream_id={stream_id} bytes={}",
+                                            frame.len()
+                                        );
                                     }
                                 }
                                 Ok(ProtocolAction::Multiple(list)) => {
@@ -632,25 +630,19 @@ impl Bridge {
                                             }
                                         }
                                     }
-                                    if self.debug {
-                                        let _ = tx.send(UiEvent::Log(format!(
-                                            "Outbound datagram batch stream_id={stream_id} sent={sent}"
-                                        ))).await;
-                                    }
+                                    tracing::trace!(
+                                        "Outbound datagram batch stream_id={stream_id} sent={sent}"
+                                    );
                                 }
                                 Ok(ProtocolAction::Noop) => {
-                                    if self.debug {
-                                        let _ = tx.send(UiEvent::Log(format!(
-                                            "Outbound datagram noop stream_id={stream_id}"
-                                        ))).await;
-                                    }
+                                    tracing::trace!(
+                                        "Outbound datagram noop stream_id={stream_id}"
+                                    );
                                 }
                                 Ok(_) => {
-                                    if self.debug {
-                                        let _ = tx.send(UiEvent::Log(format!(
-                                            "Outbound datagram unexpected action stream_id={stream_id}"
-                                        ))).await;
-                                    }
+                                    tracing::trace!(
+                                        "Outbound datagram unexpected action stream_id={stream_id}"
+                                    );
                                 }
                                 Err(e) => {
                                     tracing::warn!("Protocol error packing outbound stream_id={}: {}", stream_id, e);
diff --git a/ostp-server/src/lib.rs b/ostp-server/src/lib.rs
index 5f9d36a..92683d7 100644
--- a/ostp-server/src/lib.rs
+++ b/ostp-server/src/lib.rs
@@ -289,8 +289,6 @@ pub async fn run_server(
                         || msg.starts_with("Listening")
                         || msg.starts_with("Shutdown")
                         || msg.starts_with("Session ")
-                        || msg.starts_with("Relay CONNECT")
-                        || msg.starts_with("Relay CLOSE")
                         || msg.starts_with("Relay error");
                     if debug || is_essential {
                         tracing::info!("{msg}");
@@ -592,7 +590,7 @@ async fn run_server_loop(
                         let _ = ui_event_tx.send(UiEvent::Log(format!("Relay CONNECT ok for [{session_id}:{stream_id}] -> {target}")));
                     }
                     Err(err) => {
-                        let _ = ui_event_tx.send(UiEvent::Log(format!("Relay CONNECT failed for [{session_id}:{stream_id}] -> {target}: {err}")));
+                        let _ = ui_event_tx.send(UiEvent::Log(format!("Relay error: CONNECT failed for [{session_id}:{stream_id}] -> {target}: {err}")));
                         let _ = relay::send_relay_to_stream(session_id, stream_id, RelayMessage::Error(format!("connect failed: {err}")), &mut dispatcher, &socket, &ui_event_tx, &tcp_map).await;
                     }
                 }