Merge pull request quarkusio#36366 from michalvavrik/feature/ref-oidc-db-token-state-manager

OIDC Db Token State Manager - disable MSSQL test due to limited Github CI resources and cancel timer on shutdown

Author: sberyozkin

extensions/oidc-db-token-state-manager/deployment/src/test/java/io/quarkus/oidc/db/token/state/manager/MsSqlDbTokenStateManagerTest.java

@@ -1,10 +1,13 @@
 package io.quarkus.oidc.db.token.state.manager;
 
 import org.jboss.shrinkwrap.api.asset.StringAsset;
+import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 import io.quarkus.test.QuarkusUnitTest;
 
+// Becomes flaky in Github CI due to limited resources
+@EnabledIfSystemProperty(named = "run-mssql-db-token-state-manager-test", disabledReason = "Insufficient GH CI resources", matches = "true")
 public class MsSqlDbTokenStateManagerTest extends AbstractDbTokenStateManagerTest {
 
     @RegisterExtension

extensions/oidc-db-token-state-manager/runtime/src/main/java/io/quarkus/oidc/db/token/state/manager/runtime/OidcDbTokenStateManagerInitializer.java

@@ -11,6 +11,7 @@
 
 import org.jboss.logging.Logger;
 
+import io.quarkus.runtime.ShutdownEvent;
 import io.quarkus.runtime.StartupEvent;
 import io.smallrye.mutiny.Uni;
 import io.vertx.core.Handler;
@@ -27,6 +28,7 @@ public class OidcDbTokenStateManagerInitializer {
      * Extra 30 seconds before we delete expired tokens.
      */
     private static final long EXPIRED_EXTRA_GRACE = 30;
+    private static volatile Long timerId = null;
 
     void initialize(@Observes StartupEvent event, OidcDbTokenStateManagerRunTimeConfig config, Vertx vertx, Pool pool,
             OidcDbTokenStateManagerInitializerProperties initializerProps) {
@@ -36,8 +38,14 @@ void initialize(@Observes StartupEvent event, OidcDbTokenStateManagerRunTimeConf
         periodicallyDeleteExpiredTokens(vertx, pool, config.deleteExpiredDelay().toMillis());
     }
 
+    void shutdown(@Observes ShutdownEvent event, Vertx vertx) {
+        if (timerId != null) {
+            vertx.cancelTimer(timerId);
+        }
+    }
+
     private static void periodicallyDeleteExpiredTokens(Vertx vertx, Pool pool, long delayBetweenChecks) {
-        vertx
+        timerId = vertx
                 .setPeriodic(5000, delayBetweenChecks, new Handler<Long>() {
 
                     private final AtomicBoolean deleteInProgress = new AtomicBoolean(false);