Added unit tests to check async batch request feature flag

Author: RSam25

conf/default-config.json

@@ -41,5 +41,5 @@
   "operator_type": "public",
   "enable_remote_config": true,
   "uid_instance_id_prefix": "local-operator",
-  "enable_async_batch_request": true
+  "enable_async_batch_request": false
 }

src/main/java/com/uid2/operator/Const.java

@@ -42,6 +42,6 @@ public class Config extends com.uid2.shared.Const.Config {
 
         public static final String EnableAsyncBatchRequestProp = "enable_async_batch_request";
 
-        public static final String DefaultWorkerPoolThreadCount = "default_worker_pool_thread_count";
+        public static final String DefaultWorkerPoolThreadCountProp = "default_worker_pool_thread_count";
     }
 }

src/main/java/com/uid2/operator/Main.java

@@ -61,7 +61,6 @@
 import java.time.Duration;
 import java.time.Instant;
 import java.util.*;
-import java.util.function.Consumer;
 import java.util.function.Supplier;
 
 import static com.uid2.operator.Const.Config.EnableRemoteConfigProp;
@@ -498,7 +497,7 @@ private static Vertx createVertx() {
             : 3600 * 1000;
 
         final int defaultWorkerPoolSize = Math.max(2, (Runtime.getRuntime().availableProcessors() - 2) / 2 + 1);
-        final int workerPoolSize = getEnvInt(Const.Config.DefaultWorkerPoolThreadCount, defaultWorkerPoolSize);
+        final int workerPoolSize = getEnvInt(Const.Config.DefaultWorkerPoolThreadCountProp, defaultWorkerPoolSize);
         LOGGER.info("Creating Vertx with default worker pool size: {}", workerPoolSize);
 
         VertxOptions vertxOptions = new VertxOptions()

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

@@ -142,6 +142,7 @@ public class UIDOperatorVerticleTest {
     private ExtendedUIDOperatorVerticle uidOperatorVerticle;
     private RuntimeConfig runtimeConfig;
     private EncryptedTokenEncoder encoder;
+    private ListAppender<ILoggingEvent> asyncBatchRequestLogWatcher;
 
     @BeforeEach
     void deployVerticle(Vertx vertx, VertxTestContext testContext, TestInfo testInfo) {
@@ -161,6 +162,20 @@ void deployVerticle(Vertx vertx, VertxTestContext testContext, TestInfo testInfo
         if (testInfo.getDisplayName().equals("cstgNoPhoneSupport(Vertx, VertxTestContext)")) {
             config.put("enable_phone_support", false);
         }
+        if (testInfo.getTestMethod().isPresent() &&
+                testInfo.getTestMethod().get().getName().equals("asyncBatchRequestEnabledLogsCorrectMessage")) {
+            config.put(Const.Config.EnableAsyncBatchRequestProp, true);
+            asyncBatchRequestLogWatcher = new ListAppender<>();
+            asyncBatchRequestLogWatcher.start();
+            ((Logger) LoggerFactory.getLogger(UIDOperatorVerticle.class)).addAppender(asyncBatchRequestLogWatcher);
+        }
+        if (testInfo.getTestMethod().isPresent() &&
+                testInfo.getTestMethod().get().getName().equals("asyncBatchRequestDisabledLogsCorrectMessage")) {
+            config.put(Const.Config.EnableAsyncBatchRequestProp, false);
+            asyncBatchRequestLogWatcher = new ListAppender<>();
+            asyncBatchRequestLogWatcher.start();
+            ((Logger) LoggerFactory.getLogger(UIDOperatorVerticle.class)).addAppender(asyncBatchRequestLogWatcher);
+        }
         when(configStore.getConfig()).thenAnswer(x -> runtimeConfig);
 
         this.uidInstanceIdProvider = new UidInstanceIdProvider("test-instance", "id");
@@ -5602,4 +5617,24 @@ void identityBucketsAlwaysReturnMilliseconds(Vertx vertx, VertxTestContext testC
             testContext.completeNow();
         });
     }
+
+    @Test
+    void asyncBatchRequestEnabledLogsCorrectMessage(Vertx vertx, VertxTestContext testContext) {
+        // Verify that when enable_async_batch_request is true, the correct log message is emitted
+        assertThat(asyncBatchRequestLogWatcher.list.stream()
+                .map(ILoggingEvent::getFormattedMessage)
+                .collect(Collectors.toList()))
+                .contains("Async batch requests enabled");
+        testContext.completeNow();
+    }
+
+    @Test
+    void asyncBatchRequestDisabledLogsCorrectMessage(Vertx vertx, VertxTestContext testContext) {
+        // Verify that when enable_async_batch_request is false, the correct log message is emitted
+        assertThat(asyncBatchRequestLogWatcher.list.stream()
+                .map(ILoggingEvent::getFormattedMessage)
+                .collect(Collectors.toList()))
+                .contains("Async batch requests disabled");
+        testContext.completeNow();
+    }
 }