Rebase changes

Author: slinkydeveloper

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

@@ -354,8 +354,7 @@ public <T> DurableFuture<T> signal(String name, TypeTag<T> typeTag) throws Termi
     checkNotInsideRun();
     Serde<T> serde = serdeFactory.create(typeTag);
     AsyncResult<Slice> result = Util.awaitCompletableFuture(handlerContext.signal(name));
-    return DurableFuture.fromAsyncResult(result, serviceExecutor)
-        .map(serde::deserialize);
+    return DurableFuture.fromAsyncResult(result, serviceExecutor).map(serde::deserialize);
   }
 
   @Override

sdk-core/src/main/java/dev/restate/sdk/core/EndpointRequestHandler.java

@@ -203,9 +203,9 @@ public RequestProcessor processorForRequest(
         LoggingContextSetter.INVOCATION_TARGET_KEY, fullyQualifiedServiceMethod);
 
     return new RequestProcessorImpl(
+        StateMachine.create(headersAccessor),
         serviceName,
         handlerName,
-            StateMachine.create(headersAccessor),
         svc.getServiceType(),
         handler,
         otelContext,

sdk-core/src/main/java/dev/restate/sdk/core/ExecutorSwitchingHandlerContextImpl.java

@@ -44,9 +44,10 @@ final class ExecutorSwitchingHandlerContextImpl extends HandlerContextImpl {
       HeadersAccessor attemptHeaders,
       StateMachine.Input input,
       Executor coreExecutor) {
-    super(        vm,
-            externalProgressChannel,
-            outputSink,
+    super(
+        vm,
+        externalProgressChannel,
+        outputSink,
         serviceName,
         handlerName,
         serviceType,

sdk-core/src/main/java/dev/restate/sdk/core/HandlerContextImpl.java

@@ -40,15 +40,15 @@ class HandlerContextImpl implements HandlerContextInternal {
   private final Consumer<Slice> outputSink;
 
   private final HandlerRequest handlerRequest;
-    private final HeadersAccessor attemptHeaders;
+  private final HeadersAccessor attemptHeaders;
   private final @Nullable String objectKey;
   private final ServiceType serviceType;
   private final @Nullable HandlerType handlerType;
 
   private final HashMap<Integer, Consumer<RunCompleter>> scheduledRuns;
 
   HandlerContextImpl(
-      StateMachine stateMachine,
+      StateMachine vm,
       ExternalProgressChannel externalProgressChannel,
       Consumer<Slice> outputSink,
       String serviceName,
@@ -58,7 +58,7 @@ class HandlerContextImpl implements HandlerContextInternal {
       Context otelContext,
       HeadersAccessor attemptHeaders,
       StateMachine.Input input) {
-    this.stateMachine = stateMachine;
+    this.stateMachine = vm;
     this.externalProgressChannel = externalProgressChannel;
     this.outputSink = outputSink;
 

sdk-core/src/main/java/dev/restate/sdk/core/RequestProcessorImpl.java

@@ -10,8 +10,8 @@
 
 import dev.restate.common.Slice;
 import dev.restate.sdk.common.TerminalException;
-import dev.restate.sdk.endpoint.HeadersAccessor;
 import dev.restate.sdk.core.sharedcore.StateMachine;
+import dev.restate.sdk.endpoint.HeadersAccessor;
 import dev.restate.sdk.endpoint.definition.HandlerDefinition;
 import dev.restate.sdk.endpoint.definition.ServiceType;
 import io.opentelemetry.context.Context;
@@ -59,9 +59,9 @@ private enum State {
 
   @SuppressWarnings("unchecked")
   RequestProcessorImpl(
+      StateMachine stateMachine,
       String serviceName,
       String handlerName,
-      StateMachine stateMachine,
       ServiceType serviceType,
       HandlerDefinition<?, ?> handlerDefinition,
       Context otelContext,
@@ -260,32 +260,27 @@ private void startHandler() {
     HandlerContextImpl ctx =
         syscallsExecutor != null
             ? new ExecutorSwitchingHandlerContextImpl(
-                serviceName,
-                handlerName,
                 stateMachine,
                 externalProgressChannel,
                 this::onNextOutputSlice,
-                fullyQualifiedHandlerName,
+                serviceName,
+                handlerName,
                 serviceType,
                 handlerDefinition.getHandlerType(),
                 otelContext,
                 attemptHeaders,
-                input,
-                this.syscallsExecutor)
                 stateMachineInput,
-                syscallsExecutor)
+                this.syscallsExecutor)
             : new HandlerContextImpl(
-                serviceName,
-                handlerName,
                 stateMachine,
                 externalProgressChannel,
                 this::onNextOutputSlice,
-                fullyQualifiedHandlerName,
+                serviceName,
+                handlerName,
                 serviceType,
                 handlerDefinition.getHandlerType(),
                 otelContext,
                 attemptHeaders,
-                input);
                 stateMachineInput);
 
     CompletableFuture<Slice> handlerResultFut =

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

@@ -86,7 +86,7 @@ public Slice serialize(T value) {
       public T deserialize(@NonNull Slice value) {
         try {
           return mapper.readValue(
-                  new ByteBufferBackedInputStream(value.asReadOnlyByteBuffer()), constructedType);
+              new ByteBufferBackedInputStream(value.asReadOnlyByteBuffer()), constructedType);
         } catch (IOException e) {
           sneakyThrow(e);
           return null;