SK-2274 warning log when user provide limits

Author: skyflow-bharti

common/pom.xml

@@ -11,7 +11,7 @@
     </parent>
 
     <artifactId>common</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.1</version>
     <name>${project.groupId}:${project.artifactId}</name>
 
 

common/src/main/java/com/skyflow/logs/InfoLogs.java

@@ -92,7 +92,9 @@ public enum InfoLogs {
     VALIDATE_GET_DETECT_RUN_REQUEST("Validating get detect run request."),
     REIDENTIFY_TEXT_SUCCESS("Text data re-identified."),
 
-    PROCESSING_BATCHES("Processing batch")
+    PROCESSING_BATCHES("Processing batch"),
+    SET_CONCURRENCY_LIMIT("Setting concurrency limit to %s1"),
+    SET_BATCH_SIZE("Setting batch size to %s1"),
     ;
 
 

common/src/main/java/com/skyflow/logs/WarningLogs.java

@@ -3,6 +3,8 @@
 public enum WarningLogs {
     INVALID_BATCH_SIZE_PROVIDED("Invalid value for batch size provided, switching to default value."),
     INVALID_CONCURRENCY_LIMIT_PROVIDED("Invalid value for concurrency limit provided, switching to default value."),
+    BATCH_SIZE_EXCEEDS_MAX_LIMIT("Provided batch size exceeds the maximum limit, switching to max limit."),
+    CONCURRENCY_EXCEEDS_MAX_LIMIT("Provided concurrency limit exceeds the maximum limit, switching to max limit.")
     ;
 
     private final String log;

v2/pom.xml

@@ -24,7 +24,7 @@
         <dependency>
             <groupId>com.skyflow</groupId>
             <artifactId>common</artifactId>
-            <version>1.0.0</version>
+            <version>1.0.1</version>
         </dependency>
 
     </dependencies>

v3/pom.xml

@@ -43,7 +43,7 @@
         <dependency>
             <groupId>com.skyflow</groupId>
             <artifactId>common</artifactId>
-            <version>1.0.0</version>
+            <version>1.0.1</version>
         </dependency>
     </dependencies>
 

v3/src/main/java/com/skyflow/vault/controller/VaultController.java

@@ -306,8 +306,12 @@ private void configureInsertConcurrencyAndBatchSize(int totalRequests) {
             if (userProvidedBatchSize != null) {
                 try {
                     int batchSize = Integer.parseInt(userProvidedBatchSize);
+                    if (batchSize > Constants.MAX_DETOKENIZE_BATCH_SIZE) {
+                        LogUtil.printWarningLog(WarningLogs.BATCH_SIZE_EXCEEDS_MAX_LIMIT.getLog());
+                    }
                     int maxBatchSize = Math.min(batchSize, Constants.MAX_INSERT_BATCH_SIZE);
                     if (maxBatchSize > 0) {
+//                        LogUtil.printInfoLog(InfoLogs.SET_BATCH_SIZE.getLog() + maxBatchSize);
                         this.insertBatchSize = maxBatchSize;
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_BATCH_SIZE_PROVIDED.getLog());
@@ -326,8 +330,11 @@ private void configureInsertConcurrencyAndBatchSize(int totalRequests) {
                 try {
                     int concurrencyLimit = Integer.parseInt(userProvidedConcurrencyLimit);
                     int maxConcurrencyLimit = Math.min(concurrencyLimit, Constants.MAX_INSERT_CONCURRENCY_LIMIT);
-
+                    if (concurrencyLimit > Constants.MAX_DETOKENIZE_CONCURRENCY_LIMIT) {
+                        LogUtil.printWarningLog(WarningLogs.CONCURRENCY_EXCEEDS_MAX_LIMIT.getLog());
+                    }
                     if (maxConcurrencyLimit > 0) {
+//                        LogUtil.printInfoLog(InfoLogs.SET_CONCURRENCY_LIMIT.getLog() + maxConcurrencyLimit);
                         this.insertConcurrencyLimit = Math.min(maxConcurrencyLimit, maxConcurrencyNeeded);
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_CONCURRENCY_LIMIT_PROVIDED.getLog());
@@ -357,8 +364,12 @@ private void configureDetokenizeConcurrencyAndBatchSize(int totalRequests) {
             if (userProvidedBatchSize != null) {
                 try {
                     int batchSize = Integer.parseInt(userProvidedBatchSize);
+                    if (batchSize > Constants.MAX_DETOKENIZE_BATCH_SIZE) {
+                        LogUtil.printWarningLog(WarningLogs.BATCH_SIZE_EXCEEDS_MAX_LIMIT.getLog());
+                    }
                     int maxBatchSize = Math.min(batchSize, Constants.MAX_DETOKENIZE_BATCH_SIZE);
                     if (maxBatchSize > 0) {
+//                        LogUtil.printInfoLog(InfoLogs.SET_BATCH_SIZE.getLog() + maxBatchSize);
                         this.detokenizeBatchSize = maxBatchSize;
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_BATCH_SIZE_PROVIDED.getLog());
@@ -376,9 +387,13 @@ private void configureDetokenizeConcurrencyAndBatchSize(int totalRequests) {
             if (userProvidedConcurrencyLimit != null) {
                 try {
                     int concurrencyLimit = Integer.parseInt(userProvidedConcurrencyLimit);
+                    if (concurrencyLimit > Constants.MAX_DETOKENIZE_CONCURRENCY_LIMIT) {
+                        LogUtil.printWarningLog(WarningLogs.CONCURRENCY_EXCEEDS_MAX_LIMIT.getLog());
+                    }
                     int maxConcurrencyLimit = Math.min(concurrencyLimit, Constants.MAX_DETOKENIZE_CONCURRENCY_LIMIT);
 
                     if (maxConcurrencyLimit > 0) {
+//                        LogUtil.printInfoLog(InfoLogs.SET_CONCURRENCY_LIMIT.getLog() + maxConcurrencyLimit);
                         this.detokenizeConcurrencyLimit = Math.min(maxConcurrencyLimit, maxConcurrencyNeeded);
                     } else {
                         LogUtil.printWarningLog(WarningLogs.INVALID_CONCURRENCY_LIMIT_PROVIDED.getLog());