Add test when message is unparseable

goto · Jun 19, 2024 · c615d69 · c615d69
1 parent a9ee36b
commit c615d69
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/test/java/com/gotocompany/firehose/serializer/TypecastedJsonSerializerTest.java b/src/test/java/com/gotocompany/firehose/serializer/TypecastedJsonSerializerTest.java
@@ -96,6 +96,18 @@ public void serializeShouldReturnMessageAsItIsWhenJsonPathConfigurationDoesNotMa
         Assertions.assertEquals(JsonPath.parse(DEFAULT_JSON_MESSAGE).jsonString(), JsonPath.parse(result).jsonString());
     }
 
+    @Test
+    public void serializeShouldThrowNumberFormatExceptionWhenPayloadTypecastIsUnparseable() {
+        String payload = "{\"key\": \"value\", \"long\":\"1234568129012312\",\"nested\": {\"int\": \"1234\"}, \"double\": \"12.1\"}";
+        String parameters = "[{\"jsonPath\": \"$.key\", \"type\": \"INTEGER\"}]";
+        Map<String, Function<String, Object>> property = serializerConfigConverter.convert(null, parameters);
+        Mockito.when(serializerConfig.getJsonTypecastMapping()).thenReturn(property);
+        Mockito.when(messageSerializer.serialize(Mockito.any())).thenReturn(payload);
+
+        Assertions.assertThrows(NumberFormatException.class,
+                () -> typecastedJsonSerializer.serialize(buildMessage("key", DEFAULT_JSON_MESSAGE)));
+    }
+
 
     private Message buildMessage(String key, String payload) {
         return new Message(