nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-05-03 06:51:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

client trace messages

Browse Source
This commit is contained in:
Mike Dilger 2025-01-21 10:14:20 +13:00
parent e42a18efce
commit f6dbf63e64
No known key found for this signature in database
GPG Key ID: 47581A78D4329BA4
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/lib.rs
View File

@ -368,6 +368,8 @@ struct WebSocketService {
impl WebSocketService { impl WebSocketService {
async fn send(&mut self, m: Message) -> Result<(), Error> { 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 // Throttling: we consume burst tokens, but we do not throttle on output
if m.len() > self.burst_tokens { if m.len() > self.burst_tokens {
log::info!(target: "Client", "{}: Rate limited exceeded", self.peer); log::info!(target: "Client", "{}: Rate limited exceeded", self.peer);

2
src/nostr.rs
View File

@ -18,6 +18,8 @@ impl WebSocketService {
self.buffer.resize(newlen, 0); self.buffer.resize(newlen, 0);
} }
log::trace!(target: "Client", "{}: {}", self.peer, msg);
let input = msg.as_bytes(); let input = msg.as_bytes();
let mut inpos = 0; let mut inpos = 0;
eat_whitespace(input, &mut inpos); eat_whitespace(input, &mut inpos);