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);