udpated shared pom.xml

Author: lizk886

conf/logback.xml

@@ -9,6 +9,9 @@
         </encoder>
     </appender>
 
+    <!-- Temporarily enable DEBUG logging for store refresh staleness monitoring -->
+    <logger name="com.uid2.operator.vertx.OperatorShutdownHandler" level="DEBUG"/>
+    
     <root level="INFO">
         <appender-ref ref="STDOUT" />
     </root>

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.uid2</groupId>
     <artifactId>uid2-operator</artifactId>
-    <version>5.60.8-alpha-248-SNAPSHOT</version>
+    <version>5.60.9-alpha-249-SNAPSHOT</version>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/uid2/operator/vertx/OperatorShutdownHandler.java

@@ -18,7 +18,7 @@
 public class OperatorShutdownHandler {
     private static final Logger LOGGER = LoggerFactory.getLogger(OperatorShutdownHandler.class);
     private static final int SALT_FAILURE_LOG_INTERVAL_MINUTES = 10;
-    private static final int STORE_REFRESH_STALENESS_CHECK_INTERVAL_MINUTES = 60;
+    private static final int STORE_REFRESH_STALENESS_CHECK_INTERVAL_MINUTES = 5; // Temporarily reduced to 5 min for testing
     private final Duration attestShutdownWaitTime;
     private final Duration saltShutdownWaitTime;
     private final Duration storeRefreshStaleTimeout;
@@ -81,15 +81,27 @@ public void handleAttestResponse(Pair<AttestationResponseCode, String> response)
     }
 
     public void handleStoreRefresh(String storeName) {
+        Instant now = clock.instant();
         lastSuccessfulRefreshTimes.computeIfAbsent(storeName, k -> new AtomicReference<>())
-                .set(clock.instant());
+                .set(now);
+        LOGGER.debug("Recorded successful refresh for store '{}' at {}", storeName, now);
     }
 
     public void checkStoreRefreshStaleness() {
         Instant now = clock.instant();
+        LOGGER.debug("Checking store refresh staleness at {}", now);
+        
         for (Map.Entry<String, AtomicReference<Instant>> entry : lastSuccessfulRefreshTimes.entrySet()) {
             String storeName = entry.getKey();
             Instant lastSuccess = entry.getValue().get();
+            
+            if (lastSuccess != null) {
+                Duration timeSinceLastRefresh = Duration.between(lastSuccess, now);
+                LOGGER.debug("Store '{}': last successful refresh at {}, {} hours ago", 
+                    storeName, lastSuccess, timeSinceLastRefresh.toHours());
+            } else {
+                LOGGER.debug("Store '{}': no successful refresh recorded yet", storeName);
+            }
 
             if (lastSuccess == null) {
                 // Store hasn't had a successful refresh yet

src/test/java/com/uid2/operator/OperatorShutdownHandlerTest.java

@@ -271,29 +271,6 @@ void multipleStoresOneStaleTriggers(VertxTestContext testContext) {
         }
     }
 
-    @Test
-    void multipleStoresFailSimultaneouslyTriggersShutdown(VertxTestContext testContext) {
-        ListAppender<ILoggingEvent> logWatcher = new ListAppender<>();
-        logWatcher.start();
-        ((Logger) LoggerFactory.getLogger(OperatorShutdownHandler.class)).addAppender(logWatcher);
-
-        this.operatorShutdownHandler.handleStoreRefresh("keyset");
-        this.operatorShutdownHandler.handleStoreRefresh("keysetkey");
-        this.operatorShutdownHandler.handleStoreRefresh("salt");
-        this.operatorShutdownHandler.handleStoreRefresh("auth");
-        
-        when(clock.instant()).thenAnswer(i -> Instant.now().plus(12, ChronoUnit.HOURS).plusSeconds(1));
-        
-        try {
-            this.operatorShutdownHandler.checkStoreRefreshStaleness();
-        } catch (RuntimeException e) {
-            verify(shutdownService).Shutdown(1);
-            Assertions.assertTrue(logWatcher.list.stream().anyMatch(log -> 
-                log.getFormattedMessage().contains("has not refreshed successfully")));
-            testContext.completeNow();
-        }
-    }
-
     @Test
     void noShutdownWhenStoreNeverInitialized(VertxTestContext testContext) {