provide reason for json processing exception

Signed-off-by: Pawel Leszczynski <leszczynski.pawel@gmail.com>

Author: pawel-big-lebowski

CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## [Unreleased](https://github.com/MarquezProject/marquez/compare/0.28.0...HEAD)
 
+* Include error message for JSON processing exception [`#2271`](https://github.com/MarquezProject/marquez/pull/2271) [@pawel-big-lebowski](https://github.com/pawel-big-lebowski)  
+    *In case of JSON processing exceptions Marquez API should return exception message to a client.*
+
 ## [0.28.0](https://github.com/MarquezProject/marquez/compare/0.27.0...0.28.0) - 2022-11-21
 
 ### Added

api/src/main/java/marquez/MarquezContext.java

@@ -22,6 +22,7 @@
 import marquez.api.SourceResource;
 import marquez.api.TagResource;
 import marquez.api.exceptions.JdbiExceptionExceptionMapper;
+import marquez.api.exceptions.JsonProcessingExceptionMapper;
 import marquez.db.BaseDao;
 import marquez.db.ColumnLineageDao;
 import marquez.db.DatasetDao;
@@ -96,6 +97,7 @@ public final class MarquezContext {
   @Getter private final SearchResource searchResource;
   @Getter private final ImmutableList<Object> resources;
   @Getter private final JdbiExceptionExceptionMapper jdbiException;
+  @Getter private final JsonProcessingExceptionMapper jsonException;
   @Getter private final GraphQLHttpServlet graphqlServlet;
 
   private MarquezContext(
@@ -137,6 +139,7 @@ private MarquezContext(
     this.lineageService = new LineageService(lineageDao, jobDao);
     this.columnLineageService = new ColumnLineageService(columnLineageDao, datasetFieldDao);
     this.jdbiException = new JdbiExceptionExceptionMapper();
+    this.jsonException = new JsonProcessingExceptionMapper();
     final ServiceFactory serviceFactory =
         ServiceFactory.builder()
             .datasetService(datasetService)
@@ -169,6 +172,7 @@ private MarquezContext(
             jobResource,
             tagResource,
             jdbiException,
+            jsonException,
             openLineageResource,
             searchResource);
 

api/src/main/java/marquez/api/exceptions/JsonProcessingExceptionMapper.java

@@ -0,0 +1,28 @@
+/*
+ * Copyright 2018-2022 contributors to the Marquez project
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package marquez.api.exceptions;
+
+import static javax.ws.rs.core.MediaType.APPLICATION_JSON_TYPE;
+import static javax.ws.rs.core.Response.Status.BAD_REQUEST;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import io.dropwizard.jersey.errors.ErrorMessage;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.ext.ExceptionMapper;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class JsonProcessingExceptionMapper implements ExceptionMapper<JsonProcessingException> {
+
+  @Override
+  public Response toResponse(JsonProcessingException e) {
+    log.error("Failed to process JSON", e);
+    return Response.serverError()
+        .type(APPLICATION_JSON_TYPE)
+        .entity(new ErrorMessage(BAD_REQUEST.getStatusCode(), e.getMessage()))
+        .build();
+  }
+}

api/src/test/java/marquez/OpenLineageIntegrationTest.java

@@ -150,6 +150,25 @@ public void testSendOpenLineageEventFailsValidation(String eventBody) throws IOE
     assertThat(resp.join()).isEqualTo(422);
   }
 
+  @Test
+  public void testSendOpenLineageEventFailsJsonProcessing() throws IOException {
+    String eventWithIncorrectEventTimeFormat =
+        "{\"eventTime\": \"2021-11-03\", \"eventType\": \"START\", \"inputs\": [], \"job\": {\"facets\": {}, \"name\": \"job\", \"namespace\": \"openlineage\"}, \"outputs\": [], \"run\": {\"facets\": {}, \"runId\": \"123e4567-e89b-12d3-a456-426614174000\"}}";
+
+    final CompletableFuture<String> resp =
+        this.sendLineage(eventWithIncorrectEventTimeFormat)
+            .thenApply(HttpResponse::body)
+            .whenComplete(
+                (val, err) -> {
+                  if (err != null) {
+                    Assertions.fail("Could not complete request");
+                  }
+                });
+    assertThat(resp.join())
+        .contains(
+            "Cannot deserialize value of type `java.time.ZonedDateTime` from String \\\"2021-11-03\\\"");
+  }
+
   @Test
   public void testGetLineageForNonExistantDataset() {
     CompletableFuture<Integer> response =