Revert "Add custom enum deserializer to improve error messaging, impr…

…ove byte count error mesages (opensearch-project#5076)"

This reverts commit e9bffee.

data-prepper-api/src/main/java/org/opensearch/dataprepper/model/types/ByteCount.java

@@ -79,13 +79,11 @@ public static ByteCount parse(final String string) {
         final String unitString = matcher.group("unit");
 
         if(unitString == null) {
-            throw new ByteCountInvalidInputException("Byte counts must have a unit. Valid byte units include: " +
-                    Arrays.stream(Unit.values()).map(unitValue -> unitValue.unitString).collect(Collectors.toList()));
+            throw new ByteCountInvalidInputException("Byte counts must have a unit.");
         }
 
         final Unit unit = Unit.fromString(unitString)
-                .orElseThrow(() -> new ByteCountInvalidInputException("Invalid byte unit: '" + unitString + "'. Valid byte units include: "
-                        + Arrays.stream(Unit.values()).map(unitValue -> unitValue.unitString).collect(Collectors.toList())));
+                .orElseThrow(() -> new ByteCountInvalidInputException("Invalid byte unit: '" + unitString + "'"));
 
         final BigDecimal valueBigDecimal = new BigDecimal(valueString);
 

data-prepper-pipeline-parser/src/main/java/org/opensearch/dataprepper/pipeline/parser/ByteCountDeserializer.java

@@ -34,7 +34,7 @@ public ByteCount deserialize(final JsonParser parser, final DeserializationConte
         try {
             return ByteCount.parse(byteString);
         } catch (final Exception ex) {
-            throw new IllegalArgumentException(ex.getMessage());
+            throw new IllegalArgumentException(ex);
         }
     }
 }

data-prepper-pipeline-parser/src/test/java/org/opensearch/dataprepper/pipeline/parser/ByteCountDeserializerTest.java

@@ -13,7 +13,6 @@
 import org.junit.jupiter.params.provider.ValueSource;
 import org.opensearch.dataprepper.model.types.ByteCount;
 
-import static org.hamcrest.CoreMatchers.containsString;
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.hamcrest.CoreMatchers.notNullValue;
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -32,28 +31,9 @@ void setUp() {
     }
 
     @ParameterizedTest
-    @ValueSource(strings = {"1", "10"})
-    void convert_with_no_byte_unit_throws_expected_exception(final String invalidByteString) {
-        final IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> objectMapper.convertValue(invalidByteString, ByteCount.class));
-        assertThat(exception.getMessage(), containsString("Byte counts must have a unit. Valid byte units include: [b, kb, mb, gb]"));
-    }
-
-    @ParameterizedTest
-    @ValueSource(strings = {"10 2b", "bad"})
-    void convert_with_non_parseable_values_throws(final String invalidByteString) {
-        final IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> objectMapper.convertValue(invalidByteString, ByteCount.class));
-        assertThat(exception.getMessage(), containsString("Unable to parse bytes"));
-    }
-
-    @ParameterizedTest
-    @CsvSource({
-            "10f, f",
-            "1vb, vb",
-            "3g, g"
-    })
-    void convert_with_invalid_byte_units_throws(final String invalidByteString, final String invalidUnit) {
-        final IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> objectMapper.convertValue(invalidByteString, ByteCount.class));
-        assertThat(exception.getMessage(), containsString("Invalid byte unit: '" + invalidUnit + "'. Valid byte units include: [b, kb, mb, gb]"));
+    @ValueSource(strings = {"1", "1b 2b", "1vb", "bad"})
+    void convert_with_invalid_values_throws(final String invalidByteString) {
+        assertThrows(IllegalArgumentException.class, () -> objectMapper.convertValue(invalidByteString, ByteCount.class));
     }
 
     @ParameterizedTest

data-prepper-plugin-framework/src/main/java/org/opensearch/dataprepper/plugin/ObjectMapperConfiguration.java

@@ -13,7 +13,6 @@
 import org.opensearch.dataprepper.model.types.ByteCount;
 import org.opensearch.dataprepper.pipeline.parser.ByteCountDeserializer;
 import org.opensearch.dataprepper.pipeline.parser.DataPrepperDurationDeserializer;
-import org.opensearch.dataprepper.pipeline.parser.EnumDeserializer;
 import org.opensearch.dataprepper.pipeline.parser.EventKeyDeserializer;
 import org.springframework.context.annotation.Bean;
 
@@ -34,7 +33,6 @@ public class ObjectMapperConfiguration {
     ObjectMapper extensionPluginConfigObjectMapper() {
         final SimpleModule simpleModule = new SimpleModule();
         simpleModule.addDeserializer(Duration.class, new DataPrepperDurationDeserializer());
-        simpleModule.addDeserializer(Enum.class, new EnumDeserializer());
         simpleModule.addDeserializer(ByteCount.class, new ByteCountDeserializer());
 
         return new ObjectMapper()
@@ -49,7 +47,6 @@ ObjectMapper pluginConfigObjectMapper(
         final SimpleModule simpleModule = new SimpleModule();
         simpleModule.addDeserializer(Duration.class, new DataPrepperDurationDeserializer());
         simpleModule.addDeserializer(ByteCount.class, new ByteCountDeserializer());
-        simpleModule.addDeserializer(Enum.class, new EnumDeserializer());
         simpleModule.addDeserializer(EventKey.class, new EventKeyDeserializer(eventKeyFactory));
         TRANSLATE_VALUE_SUPPORTED_JAVA_TYPES.stream().forEach(clazz -> simpleModule.addDeserializer(
                 clazz, new DataPrepperScalarTypeDeserializer<>(variableExpander, clazz)));