Revert "Wrap FieldMask via shared message-to-struct hook on the base converter"

andrewparmet · andrewparmet · commit b9e76392320d · 2026-06-02T19:58:49.000-04:00
This reverts commit 984193b.
diff --git a/common/src/main/java/dev/cel/common/values/BaseProtoCelValueConverter.java b/common/src/main/java/dev/cel/common/values/BaseProtoCelValueConverter.java
@@ -17,6 +17,8 @@
 import static com.google.common.collect.ImmutableList.toImmutableList;
 import static com.google.common.collect.ImmutableMap.toImmutableMap;
 
+import com.google.common.base.CaseFormat;
+import com.google.common.base.Joiner;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
@@ -27,6 +29,7 @@
 import com.google.protobuf.BytesValue;
 import com.google.protobuf.DoubleValue;
 import com.google.protobuf.Duration;
+import com.google.protobuf.FieldMask;
 import com.google.protobuf.FloatValue;
 import com.google.protobuf.Int32Value;
 import com.google.protobuf.Int64Value;
@@ -41,6 +44,8 @@
 import dev.cel.common.annotations.Internal;
 import dev.cel.common.internal.ProtoTimeUtils;
 import dev.cel.common.internal.WellKnownProto;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * {@code BaseProtoCelValueConverter} contains the common logic for converting between native Java
@@ -68,12 +73,6 @@ public Object toRuntimeValue(Object value) {
     return super.toRuntimeValue(value);
   }
 
-  /** Wraps a protobuf message as a navigable struct value. */
-  protected StructValue<String, ?> fromProtoMessageToStructValue(MessageLiteOrBuilder message) {
-    throw new UnsupportedOperationException(
-        "This converter does not support wrapping protobuf messages as struct values.");
-  }
-
   protected Object fromWellKnownProto(MessageLiteOrBuilder message, WellKnownProto wellKnownProto) {
     switch (wellKnownProto) {
       case JSON_VALUE:
@@ -105,7 +104,14 @@ protected Object fromWellKnownProto(MessageLiteOrBuilder message, WellKnownProto
       case UINT64_VALUE:
         return UnsignedLong.fromLongBits(((UInt64Value) message).getValue());
       case FIELD_MASK:
-        return fromProtoMessageToStructValue(message);
+        FieldMask fieldMask = (FieldMask) message;
+        List<String> paths = new ArrayList<>(fieldMask.getPathsCount());
+        for (String path : fieldMask.getPathsList()) {
+          if (!path.isEmpty()) {
+            paths.add(CaseFormat.LOWER_UNDERSCORE.to(CaseFormat.LOWER_CAMEL, path));
+          }
+        }
+        return normalizePrimitive(Joiner.on(",").join(paths));
       case EMPTY:
         return ImmutableMap.of();
       default:
diff --git a/common/src/main/java/dev/cel/common/values/ProtoCelValueConverter.java b/common/src/main/java/dev/cel/common/values/ProtoCelValueConverter.java
@@ -71,17 +71,14 @@ protected Object fromWellKnownProto(MessageLiteOrBuilder msg, WellKnownProto wel
               "Unpacking failed for message: " + message.getDescriptorForType().getFullName(), e);
         }
         return toRuntimeValue(unpackedMessage);
+      case FIELD_MASK:
+        return ProtoMessageValue.create(
+            (Message) message, celDescriptorPool, this, celOptions.enableJsonFieldNames());
       default:
         return super.fromWellKnownProto(message, wellKnownProto);
     }
   }
 
-  @Override
-  protected ProtoMessageValue fromProtoMessageToStructValue(MessageLiteOrBuilder message) {
-    return ProtoMessageValue.create(
-        (Message) message, celDescriptorPool, this, celOptions.enableJsonFieldNames());
-  }
-
   @Override
   public Object toRuntimeValue(Object value) {
     if (value instanceof EnumValueDescriptor) {
@@ -105,7 +102,8 @@ public Object toRuntimeValue(Object value) {
       WellKnownProto wellKnownProto =
           WellKnownProto.getByTypeName(message.getDescriptorForType().getFullName()).orElse(null);
       if (wellKnownProto == null) {
-        return fromProtoMessageToStructValue(message);
+        return ProtoMessageValue.create(
+            message, celDescriptorPool, this, celOptions.enableJsonFieldNames());
       }
 
       return fromWellKnownProto(message, wellKnownProto);
diff --git a/common/src/main/java/dev/cel/common/values/ProtoLiteCelValueConverter.java b/common/src/main/java/dev/cel/common/values/ProtoLiteCelValueConverter.java
@@ -28,7 +28,6 @@
 import com.google.protobuf.CodedInputStream;
 import com.google.protobuf.ExtensionRegistryLite;
 import com.google.protobuf.MessageLite;
-import com.google.protobuf.MessageLiteOrBuilder;
 import com.google.protobuf.WireFormat;
 import dev.cel.common.annotations.Internal;
 import dev.cel.common.internal.CelLiteDescriptorPool;
@@ -185,17 +184,6 @@ public Object toRuntimeValue(Object value) {
     return super.toRuntimeValue(value);
   }
 
-  @Override
-  protected ProtoMessageLiteValue fromProtoMessageToStructValue(MessageLiteOrBuilder message) {
-    MessageLite msg = (MessageLite) message;
-    MessageLiteDescriptor descriptor =
-        descriptorPool
-            .findDescriptor(msg)
-            .orElseThrow(
-                () -> new NoSuchElementException("Could not find a descriptor for: " + msg));
-    return ProtoMessageLiteValue.create(msg, descriptor.getProtoTypeName(), this);
-  }
-
   private Object getDefaultValue(FieldLiteDescriptor fieldDescriptor) {
     EncodingType encodingType = fieldDescriptor.getEncodingType();
     switch (encodingType) {
diff --git a/common/src/test/java/dev/cel/common/values/ProtoLiteCelValueConverterTest.java b/common/src/test/java/dev/cel/common/values/ProtoLiteCelValueConverterTest.java
@@ -27,7 +27,6 @@
 import com.google.protobuf.DoubleValue;
 import com.google.protobuf.Duration;
 import com.google.protobuf.ExtensionRegistryLite;
-import com.google.protobuf.FieldMask;
 import com.google.protobuf.FloatValue;
 import com.google.protobuf.Int32Value;
 import com.google.protobuf.Int64Value;
@@ -105,17 +104,6 @@ public void fromProtoMessageToCelValue_withWellKnownProto_convertsToPrimitivesFr
     assertThat(adaptedValue).isEqualTo(testCase.value);
   }
 
-  @Test
-  public void fromProtoMessageToCelValue_fieldMask_returnsProtoMessageLiteValue() {
-    FieldMask fieldMask = FieldMask.newBuilder().addPaths("foo").addPaths("bar").build();
-
-    Object adaptedValue = PROTO_LITE_CEL_VALUE_CONVERTER.toRuntimeValue(fieldMask);
-
-    assertThat(adaptedValue).isInstanceOf(ProtoMessageLiteValue.class);
-    assertThat(((ProtoMessageLiteValue) adaptedValue).select("paths"))
-        .isEqualTo(ImmutableList.of("foo", "bar"));
-  }
-
   /** Test cases for repeated_int64: 1L,2L,3L */
   @SuppressWarnings("ImmutableEnumChecker") // Test only
   private enum RepeatedFieldBytesTestCase {
