From c3cbd18df9862c87a56deeff865dd493b1f24440 Mon Sep 17 00:00:00 2001 From: Athou Date: Wed, 3 Jul 2024 17:40:23 +0200 Subject: [PATCH] add debug logging --- .../java/com/commafeed/backend/feed/FeedRefreshUpdater.java | 1 + .../main/java/com/commafeed/frontend/ws/WebSocketSessions.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java index 0383c6d3..f47c5455 100644 --- a/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java +++ b/commafeed-server/src/main/java/com/commafeed/backend/feed/FeedRefreshUpdater.java @@ -168,6 +168,7 @@ public class FeedRefreshUpdater { if (subscriptions == null) { feed.setMessage("No new entries found"); } else if (inserted > 0) { + log.debug("inserted {} entries for feed {}", inserted, feed.getId()); List users = subscriptions.stream().map(FeedSubscription::getUser).toList(); cache.invalidateUnreadCount(subscriptions.toArray(new FeedSubscription[0])); cache.invalidateUserRootCategory(users.toArray(new User[0])); diff --git a/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java b/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java index 8e63d8d5..e82563e7 100644 --- a/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java +++ b/commafeed-server/src/main/java/com/commafeed/frontend/ws/WebSocketSessions.java @@ -39,7 +39,7 @@ public class WebSocketSessions { public void sendMessage(User user, String text) { Set userSessions = sessions.get(user.getId()); if (userSessions != null && !userSessions.isEmpty()) { - log.debug("sending '{}' to {} users via websocket", text, userSessions.size()); + log.debug("sending '{}' to user {} via websocket ({} sessions)", text, user.getId(), userSessions.size()); for (Session userSession : userSessions) { if (userSession.isOpen()) { userSession.getAsyncRemote().sendText(text);