Put logs in UserEventDispatcher.

xwiki · Feb 16, 2024 · 8898d14 · 8898d14
1 parent 0a345f7
commit 8898d14
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...default/src/main/java/org/xwiki/notifications/notifiers/internal/UserEventDispatcher.java b/...default/src/main/java/org/xwiki/notifications/notifiers/internal/UserEventDispatcher.java
@@ -273,6 +273,7 @@ private CompletableFuture<?> dispatch(Event event, DocumentReference user, boole
         // Get the entity id
         String entityId = this.entityReferenceSerializer.serialize(user);
         CompletableFuture<?> result = new CompletableFuture<>();
+        this.logger.debug("Dispatching event [{}] to user [{}]", event, user);
 
         // Make sure the event is not already pre filtered
         // Make sure the user asked to be alerted about this event
@@ -322,10 +323,10 @@ private boolean isPrefiltered(Event event, String entityId, boolean mail)
         }
 
         try (EventSearchResult result = this.events.search(eventQuery)) {
+            this.logger.debug("[{}] is prefiltered? [{}]", event, result.getTotalHits() > 0);
             return result.getTotalHits() > 0;
         } catch (Exception e) {
             this.logger.error("Failed to check status for event [{}] and entity [{}]", event.getId(), entityId, e);
-
             return false;
         }
     }

diff --git a/...rs-default/src/main/java/org/xwiki/notifications/notifiers/internal/UserEventManager.java b/...rs-default/src/main/java/org/xwiki/notifications/notifiers/internal/UserEventManager.java
@@ -111,6 +111,7 @@ public void initialize() throws InitializationException
      */
     public boolean isListening(Event event, DocumentReference user, NotificationFormat format)
     {
+        boolean result = false;
         try {
             if (hasAccess(user, event) && isEventAfterUserCreationDate(event, user)
                 && (hasCorrespondingNotificationPreference(user, event, format)
@@ -121,13 +122,14 @@ public boolean isListening(Event event, DocumentReference user, NotificationForm
                     true, NotificationFilter.FilteringPhase.PRE_FILTERING));
                 filters.sort(null);
 
-                return !isEventFiltered(filters, event, user, format);
+                result = !isEventFiltered(filters, event, user, format);
             }
         } catch (NotificationException e) {
             this.logger.error("Failed to get event filters for user [{}]", user, e);
         }
 
-        return false;
+        this.logger.debug("event [{}] is listened by [{}] with format [{}]: [{}]", event, user, format, result);
+        return result;
     }
 
     private boolean hasAccess(DocumentReference user, Event event)