UNOMI-810 : add logs regarding scopes

apache · Dec 8, 2023 · 91957c6 · 91957c6
1 parent 7c2c4b2
commit 91957c6
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/itests/src/test/java/org/apache/unomi/itests/migration/Migrate16xTo220IT.java b/itests/src/test/java/org/apache/unomi/itests/migration/Migrate16xTo220IT.java
@@ -27,6 +27,8 @@
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -36,6 +38,8 @@
 
 public class Migrate16xTo220IT extends BaseIT {
 
+    private Logger logger = LoggerFactory.getLogger(Migrate16xTo220IT.class);
+
     private int eventCount = 0;
     private int sessionCount = 0;
 
@@ -260,9 +264,15 @@ private void checkEventTypesNotPersistedAnymore() {
     private void checkScopeHaveBeenCreated() {
         // check that the scope mySite have been created based on the previous existings events
         Map<String, Long> existingScopesFromEvents = persistenceService.aggregateWithOptimizedQuery(null, new TermsAggregate("scope"), Event.ITEM_TYPE);
+        // Log stored scopes
+        persistenceService.getAllItems(Scope.class).forEach(scope -> logger.info("Persisted scope : {} (itemId {})", scope.getScope(), scope.getItemId()));
+        // Log registered scopes
+        scopeService.getScopes().forEach(scope -> logger.info("Loaded scope : {} (itemId {})", scope.getScope(), scope.getItemId()));
+
         for (String scopeFromEvents : existingScopesFromEvents.keySet()) {
             if (!Objects.equals(scopeFromEvents, "_filtered")) {
                 Scope scope = scopeService.getScope(scopeFromEvents);
+                // Display all scopes
                 Assert.assertNotNull(String.format("Unable to find registered scope %s", scopeFromEvents), scope);
             }
         }

diff --git a/services/src/main/java/org/apache/unomi/services/impl/scope/ScopeServiceImpl.java b/services/src/main/java/org/apache/unomi/services/impl/scope/ScopeServiceImpl.java
@@ -21,6 +21,8 @@
 import org.apache.unomi.api.services.SchedulerService;
 import org.apache.unomi.api.services.ScopeService;
 import org.apache.unomi.persistence.spi.PersistenceService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -32,6 +34,7 @@
 import java.util.stream.Collectors;
 
 public class ScopeServiceImpl implements ScopeService {
+    private Logger logger = LoggerFactory.getLogger(ScopeServiceImpl.class);
 
     private PersistenceService persistenceService;
 
@@ -57,6 +60,7 @@ public void setScopesRefreshInterval(Integer scopesRefreshInterval) {
 
     public void postConstruct() {
         initializeTimers();
+        logger.info("Scope service initialized");
     }
 
     public void preDestroy() {
@@ -84,6 +88,7 @@ public Scope getScope(String id) {
     }
 
     private void initializeTimers() {
+        logger.info("Init scope refresh {}ms", scopesRefreshInterval);
         TimerTask task = new TimerTask() {
             @Override
             public void run() {