Fix the RAW content type

Author: slinkydeveloper

common/src/main/java/dev/restate/serde/Serde.java

@@ -153,6 +153,11 @@ public Slice serialize(byte[] value) {
         public byte[] deserialize(@NonNull Slice value) {
           return value.toByteArray();
         }
+
+        @Override
+        public String contentType() {
+          return "application/octet-stream";
+        }
       };
 
   /** Passthrough serializer/deserializer */

sdk-core/src/test/kotlin/dev/restate/sdk/core/kotlinapi/reflections/ReflectionDiscoveryTest.kt

@@ -53,21 +53,21 @@ class ReflectionDiscoveryTest {
   @Test
   fun checkRawInputContentType() {
     assertThatDiscovery(RawInputOutput())
-      .extractingService("RawInputOutput")
-      .extractingHandler("rawInput")
-      .extracting({ it.input }, type(Input::class.java))
-      .extracting { it.contentType }
-      .isEqualTo(Serde.RAW.contentType())
+        .extractingService("RawInputOutput")
+        .extractingHandler("rawInput")
+        .extracting({ it.input }, type(Input::class.java))
+        .extracting { it.contentType }
+        .isEqualTo(Serde.RAW.contentType())
   }
 
   @Test
   fun checkRawOutputContentType() {
     assertThatDiscovery(RawInputOutput())
-      .extractingService("RawInputOutput")
-      .extractingHandler("rawOutput")
-      .extracting({ it.output }, type(Output::class.java))
-      .extracting { it.contentType }
-      .isEqualTo(Serde.RAW.contentType())
+        .extractingService("RawInputOutput")
+        .extractingHandler("rawOutput")
+        .extracting({ it.output }, type(Output::class.java))
+        .extracting { it.contentType }
+        .isEqualTo(Serde.RAW.contentType())
   }
 
   @Test

test-services/src/main/kotlin/dev/restate/sdk/testservices/interpreter.kt

@@ -173,8 +173,7 @@ class ObjectInterpreterImpl(private val layer: Int) : ObjectInterpreter {
           }
         }
         is RecoverTerminalCallMaybeUnAwaited -> {
-          val awaitable =
-              toService<ServiceInterpreterHelper>().request { terminalFailure() }.call()
+          val awaitable = toService<ServiceInterpreterHelper>().request { terminalFailure() }.call()
           promises[i] = { checkAwaitableFails(awaitable, i, cmd) }
         }
         is RejectAwakeable -> {