Progress

Author: slinkydeveloper

sdk-core/src/main/java/dev/restate/sdk/core/sharedcore/SharedCoreInstance.java

@@ -15,6 +15,7 @@
 import com.dylibso.chicory.runtime.Instance;
 import com.dylibso.chicory.runtime.Memory;
 import com.dylibso.chicory.wasm.WasmModule;
+import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.dataformat.cbor.databind.CBORMapper;
 import dev.restate.sdk.core.ProtocolException;
@@ -28,7 +29,14 @@
 class SharedCoreInstance {
 
   private static final Logger LOG = LogManager.getLogger(SharedCoreInstance.class);
-  private static final CBORMapper CBOR = CBORMapper.builder().build();
+  private static final CBORMapper CBOR = CBORMapper.builder()
+          .defaultPropertyInclusion(
+                  JsonInclude.Value.construct(
+                          JsonInclude.Include.NON_NULL,
+                          JsonInclude.Include.NON_NULL
+                  )
+          )
+          .build();
   private static final WasmModule WASM_MODULE =
       dev.restate.sdk.core.sharedcore.generated.SharedCoreWasm.load();
   private static final ThreadLocal<SharedCoreInstance> THREAD_LOCAL =

sdk-core/src/main/rust/src/lib.rs

@@ -1082,8 +1082,11 @@ impl From<NonEmptyValueParam> for NonEmptyValue {
 struct VmSysCallParameters {
     service: String,
     handler: String,
+    #[serde(default)]
     key: Option<String>,
+    #[serde(default)]
     idempotency_key: Option<String>,
+    #[serde(default)]
     headers: Vec<(String, String)>,
     #[serde(with = "serde_bytes")]
     input: Vec<u8>,
@@ -1094,11 +1097,15 @@ struct VmSysCallParameters {
 struct VmSysSendParameters {
     service: String,
     handler: String,
+    #[serde(default)]
     key: Option<String>,
+    #[serde(default)]
     idempotency_key: Option<String>,
+    #[serde(default)]
     headers: Vec<(String, String)>,
     #[serde(with = "serde_bytes")]
     input: Vec<u8>,
+    #[serde(default)]
     execution_time_since_unix_epoch_millis: Option<u64>,
 }
 
@@ -1148,6 +1155,7 @@ struct VmProposeRunCompletionParameters {
     handle: u32,
     result: RunResult,
     attempt_duration_millis: u64,
+    #[serde(default)]
     retry_policy: Option<WasmRetryPolicy>,
 }
 
@@ -1181,8 +1189,11 @@ enum RunResult {
 struct WasmRetryPolicy {
     initial_interval_millis: u64,
     factor: f32,
+    #[serde(default)]
     max_interval_millis: Option<u64>,
+    #[serde(default)]
     max_attempts: Option<u32>,
+    #[serde(default)]
     max_duration_millis: Option<u64>,
 }