* validation: @pattern supports @pattern(ignoreCase = true)

Signed-off-by: neo <[email protected]>

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ### 9.1.3 (9/26/2024 - )
 
+* validation: @Pattern supports @Pattern(ignoreCase = true)
+
 ### 9.1.2 (8/9/2024 - 9/26/2024)
 
 * search: loading from json into search request

core-ng-api/src/main/java/core/framework/api/validate/Pattern.java

@@ -14,5 +14,7 @@
 public @interface Pattern {
     String value();
 
+    boolean ignoreCase() default false;
+
     String message() default "field must match /{pattern}/, value={value}";
 }

core-ng/src/main/java/core/framework/internal/kafka/KafkaMessages.java

@@ -8,6 +8,7 @@
 import java.util.Map;
 
 class KafkaMessages {
+    // key -> message, messages with same key will be processed in same thread
     final Map<String, KafkaMessage> ordered = new HashMap<>();
     final List<KafkaMessage> unordered = new ArrayList<>();
     final String topic;
@@ -23,6 +24,7 @@ class KafkaMessages {
     void addOrdered(ConsumerRecord<String, byte[]> record) {
         var message = new KafkaMessage(record);
         if (message.key != null) {
+            // only ensure message processing order by key, be aware of kafka ensures by partition, in practice, we only need key level ordering
             KafkaMessage root = ordered.get(message.key);
             if (root != null) root.addSubsequent(message);
             else ordered.put(message.key, message);

core-ng/src/main/java/core/framework/internal/kafka/MessageListenerThread.java

@@ -109,6 +109,7 @@ Collection<KafkaMessages> poll() {
         ConsumerRecords<String, byte[]> records = consumer.poll(Duration.ofSeconds(30));
         if (records.isEmpty()) return null;
 
+        // topic -> messages, use linked hash map to keep message in same order as polled from kafka
         Map<String, KafkaMessages> messageMappings = new LinkedHashMap<>();
         for (ConsumerRecord<String, byte[]> record : records) {
             String topic = record.topic();

core-ng/src/main/java/core/framework/internal/validate/BeanValidatorBuilder.java

@@ -144,7 +144,8 @@ private void buildStringValidation(CodeBuilder builder, Field field, String path
         if (pattern != null) {
             String patternFieldName = field.getName() + "Pattern" + (index++);
             String patternVariable = variable(pattern.value());
-            this.builder.addField("private final java.util.regex.Pattern {} = java.util.regex.Pattern.compile({});", patternFieldName, patternVariable);
+            int flags = pattern.ignoreCase() ? java.util.regex.Pattern.CASE_INSENSITIVE : 0;
+            this.builder.addField("private final java.util.regex.Pattern {} = java.util.regex.Pattern.compile({}, {});", patternFieldName, patternVariable, flags);
             builder.indent(2).append("if (!this.{}.matcher(bean.{}).matches()) errors.add({}, {}, java.util.Map.of(\"value\", bean.{}, \"pattern\", {}));\n",
                 patternFieldName, field.getName(), pathLiteral, variable(pattern.message()),
                 field.getName(), patternVariable);

core-ng/src/test/java/core/framework/internal/validate/BeanValidatorPatternTest.java

@@ -22,6 +22,7 @@ void createBeanValidator() {
     void valid() {
         var bean = new Bean();
         bean.field1 = "abc-def";
+        bean.field4 = "Abc-Def";
 
         var errors = new ValidationErrors();
         validator.validate(bean, errors, false);
@@ -54,5 +55,8 @@ static class Bean {
 
         @Pattern(value = "[a-z0-9]+", message = "field3 must be [a-z0-9]+")
         public String field3;
+
+        @Pattern(value = "[a-z-]+", ignoreCase = true)
+        public String field4;
     }
 }