More logging on jackson ser/de (#279)

Author: slinkydeveloper

sdk-api/build.gradle.kts

@@ -10,6 +10,8 @@ dependencies {
 
   api(project(":sdk-common"))
 
+  implementation(coreLibs.log4j.api)
+
   testImplementation(project(":sdk-core"))
   testImplementation(testingLibs.junit.jupiter)
   testImplementation(testingLibs.assertj)

sdk-api/src/main/java/dev/restate/sdk/Component.java

@@ -17,6 +17,8 @@
 import java.util.concurrent.Executors;
 import java.util.function.BiFunction;
 import java.util.stream.Collectors;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 public final class Component implements BindableComponent<Component.Options> {
   private final ComponentDefinition<Component.Options> componentDefinition;
@@ -102,6 +104,8 @@ public static class Handler<REQ, RES> implements InvocationHandler<Component.Opt
     private final HandlerSignature<REQ, RES> handlerSignature;
     private final BiFunction<Context, REQ, RES> runner;
 
+    private static final Logger LOG = LogManager.getLogger(Handler.class);
+
     public Handler(
         HandlerSignature<REQ, RES> handlerSignature,
         BiFunction<? extends Context, REQ, RES> runner) {
@@ -152,6 +156,7 @@ public void handle(
             } catch (Error e) {
               throw e;
             } catch (Throwable e) {
+              LOG.warn("Cannot deserialize input", e);
               callback.onCancel(
                   new TerminalException(
                       TerminalException.BAD_REQUEST_CODE,
@@ -177,6 +182,7 @@ public void handle(
             } catch (Error e) {
               throw e;
             } catch (Throwable e) {
+              LOG.warn("Cannot serialize output", e);
               callback.onCancel(
                   new TerminalException(
                       TerminalException.INTERNAL_SERVER_ERROR_CODE,

sdk-serde-jackson/src/main/java/dev/restate/sdk/serde/jackson/JacksonSerdes.java

@@ -61,7 +61,8 @@ public byte[] serialize(@Nullable T value) {
         try {
           return mapper.writeValueAsBytes(value);
         } catch (JsonProcessingException e) {
-          throw new RuntimeException("Cannot serialize value", e);
+          sneakyThrow(e);
+          return null;
         }
       }
 
@@ -70,7 +71,8 @@ public T deserialize(byte[] value) {
         try {
           return mapper.readValue(value, clazz);
         } catch (IOException e) {
-          throw new RuntimeException("Cannot deserialize value", e);
+          sneakyThrow(e);
+          return null;
         }
       }
 
@@ -94,7 +96,8 @@ public byte[] serialize(@Nullable T value) {
         try {
           return mapper.writeValueAsBytes(value);
         } catch (JsonProcessingException e) {
-          throw new RuntimeException("Cannot serialize value", e);
+          sneakyThrow(e);
+          return null;
         }
       }
 
@@ -103,7 +106,8 @@ public T deserialize(byte[] value) {
         try {
           return mapper.readValue(value, typeReference);
         } catch (IOException e) {
-          throw new RuntimeException("Cannot deserialize value", e);
+          sneakyThrow(e);
+          return null;
         }
       }
 
@@ -113,4 +117,9 @@ public String contentType() {
       }
     };
   }
+
+  @SuppressWarnings("unchecked")
+  private static <E extends Throwable> void sneakyThrow(Object exception) throws E {
+    throw (E) exception;
+  }
 }