(streampipes) branch dev updated: fix(#4246): Accept full and shorthand propertyScope values in compactadapters (#4249)

[zehnder]

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 444028b0a9 fix(#4246): Accept full and shorthand propertyScope values 
in compactadapters (#4249)
444028b0a9 is described below

commit 444028b0a9571f7624d2f8746c849cd3bfb660fa
Author: Philipp Zehnder <ten...@users.noreply.github.com>
AuthorDate: Thu Mar 12 22:37:40 2026 +0100

    fix(#4246): Accept full and shorthand propertyScope values in 
compactadapters (#4249)
---
 .../management/compact/SchemaMetadataEnricher.java | 24 ++++++++--------------
 1 file changed, 8 insertions(+), 16 deletions(-)

diff --git 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
index 41c202651e..f3bb1c412c 100644
--- 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
+++ 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
@@ -22,7 +22,6 @@ import 
org.apache.streampipes.model.connect.adapter.compact.CompactEventProperty
 import org.apache.streampipes.model.schema.EventProperty;
 import org.apache.streampipes.model.schema.EventPropertyPrimitive;
 import org.apache.streampipes.model.schema.PropertyScope;
-import org.apache.streampipes.vocabulary.XSD;
 
 import java.net.URI;
 import java.util.Map;
@@ -68,24 +67,17 @@ public class SchemaMetadataEnricher {
   }
 
   private PropertyScope convertScope(String scope) {
-    if (scope.equalsIgnoreCase("header")) {
-      return PropertyScope.HEADER_PROPERTY;
-    } else if (scope.equalsIgnoreCase("dimension")) {
-      return PropertyScope.DIMENSION_PROPERTY;
-    } else if (scope.equalsIgnoreCase("measurement")) {
+    if (scope == null || scope.isBlank()) {
       return PropertyScope.MEASUREMENT_PROPERTY;
-    } else {
-      return PropertyScope.NONE;
     }
-  }
 
-  private String convertType(String shortRuntimeType) {
-    return switch (shortRuntimeType) {
-      case "integer" -> XSD.INTEGER.toString();
-      case "boolean" -> XSD.BOOLEAN.toString();
-      case "float" -> XSD.FLOAT.toString();
-      case "double" -> XSD.DOUBLE.toString();
-      default -> XSD.STRING.toString();
+    return switch (scope.trim().toUpperCase()) {
+      case "HEADER", "HEADER_PROPERTY" -> PropertyScope.HEADER_PROPERTY;
+      case "DIMENSION", "DIMENSION_PROPERTY" -> 
PropertyScope.DIMENSION_PROPERTY;
+      case "MEASUREMENT", "MEASUREMENT_PROPERTY" -> 
PropertyScope.MEASUREMENT_PROPERTY;
+      case "NONE" -> PropertyScope.NONE;
+      default -> PropertyScope.MEASUREMENT_PROPERTY;
     };
   }
+
 }