From 5767acd347b9f56e7e31bbe11e2d0c7ba84cac44 Mon Sep 17 00:00:00 2001
From: Mike Dilger <mike@mikedilger.com>
Date: Wed, 21 Feb 2024 09:54:43 +1300
Subject: [PATCH] better logging

---
 src/main.rs  | 4 ++--
 src/nostr.rs | 5 +++++
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index b0709a4..16607ed 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -464,9 +464,9 @@ impl WebSocketService {
                     self.errcount += 1;
                     log::error!("{}: {e}", self.peer);
                     if msg.len() < 2048 {
-                        log::error!("{}: msg was {}", self.peer, msg);
+                        log::error!("{}:   msg was {}", self.peer, msg);
                     } else {
-                        log::error!("{}: msg was {} ...", self.peer, &msg[..2048]);
+                        log::error!("{}:   truncated msg was {} ...", self.peer, &msg[..2048]);
                     }
                     let reply = NostrReply::Notice(format!("error: {}", e));
                     self.websocket.send(Message::text(reply.as_json())).await?;
diff --git a/src/nostr.rs b/src/nostr.rs
index cdc2118..e656ae1 100644
--- a/src/nostr.rs
+++ b/src/nostr.rs
@@ -80,6 +80,11 @@ impl WebSocketService {
 
         if let Err(e) = self.req_inner(&subid, filters).await {
             log::error!("{}: {e}", self.peer);
+            if msg.len() < 2048 {
+                log::error!("{}:   msg was {}", self.peer, msg);
+            } else {
+                log::error!("{}:   truncated msg was {} ...", self.peer, &msg[..2048]);
+            }
             let reply = match e.inner {
                 ChorusError::TooManySubscriptions => {
                     let max_subscriptions = GLOBALS.config.get().unwrap().max_subscriptions;