From f6dbf63e64790e9020e3ab37992df50ccef03d9a Mon Sep 17 00:00:00 2001 From: Mike Dilger Date: Tue, 21 Jan 2025 10:14:20 +1300 Subject: [PATCH] client trace messages --- src/lib.rs | 2 ++ src/nostr.rs | 2 ++ 2 files changed, 4 insertions(+) diff --git a/src/lib.rs b/src/lib.rs index 81fc8aa..c90416d 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -368,6 +368,8 @@ struct WebSocketService { impl WebSocketService { async fn send(&mut self, m: Message) -> Result<(), Error> { + log::trace!(target: "Client", "{}: {}", self.peer, m); + // Throttling: we consume burst tokens, but we do not throttle on output if m.len() > self.burst_tokens { log::info!(target: "Client", "{}: Rate limited exceeded", self.peer); diff --git a/src/nostr.rs b/src/nostr.rs index b420660..fc3f36d 100644 --- a/src/nostr.rs +++ b/src/nostr.rs @@ -18,6 +18,8 @@ impl WebSocketService { self.buffer.resize(newlen, 0); } + log::trace!(target: "Client", "{}: {}", self.peer, msg); + let input = msg.as_bytes(); let mut inpos = 0; eat_whitespace(input, &mut inpos);