feat(core): pause/resume protocol with ExecutionPhase lifecycle

Clean up code

Resolve: #71
Signed-off-by: Aleksandr Suvorov <asuvorov@hensu.io>

Author: alxsuv

hensu-server/src/main/java/io/hensu/server/workflow/WorkflowService.java

@@ -1,5 +1,6 @@
 package io.hensu.server.workflow;
 
+import io.hensu.core.resume.ResumeInput;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import java.util.List;
@@ -44,8 +45,7 @@ public ExecutionStartResult startExecution(
         return executionService.startExecution(tenantId, workflowId, context);
     }
 
-    public void resumeExecution(
-            String tenantId, String executionId, io.hensu.core.resume.ResumeInput resumeInput) {
+    public void resumeExecution(String tenantId, String executionId, ResumeInput resumeInput) {
         stateService.resumeExecution(tenantId, executionId, resumeInput);
     }
 

hensu-server/src/test/java/io/hensu/server/api/ExecutionResourceTest.java

@@ -9,6 +9,7 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
+import io.hensu.core.resume.ResumeInput;
 import io.hensu.server.security.RequestTenantResolver;
 import io.hensu.server.workflow.ExecutionNotFoundException;
 import io.hensu.server.workflow.ExecutionOutput;
@@ -88,11 +89,9 @@ void shouldResumeWithApproveDecision() {
                 assertThat(response.getStatus()).isEqualTo(200);
             }
 
-            ArgumentCaptor<io.hensu.core.resume.ResumeInput> captor =
-                    ArgumentCaptor.forClass(io.hensu.core.resume.ResumeInput.class);
+            ArgumentCaptor<ResumeInput> captor = ArgumentCaptor.forClass(ResumeInput.class);
             verify(workflowService).resumeExecution(eq("tenant-1"), eq("exec-1"), captor.capture());
-            assertThat(captor.getValue())
-                    .isInstanceOf(io.hensu.core.resume.ResumeInput.ApplyReview.class);
+            assertThat(captor.getValue()).isInstanceOf(ResumeInput.ApplyReview.class);
         }
 
         @Test
@@ -105,11 +104,9 @@ void shouldResumeWithContextEdits() {
                 assertThat(response.getStatus()).isEqualTo(200);
             }
 
-            ArgumentCaptor<io.hensu.core.resume.ResumeInput> captor =
-                    ArgumentCaptor.forClass(io.hensu.core.resume.ResumeInput.class);
+            ArgumentCaptor<ResumeInput> captor = ArgumentCaptor.forClass(ResumeInput.class);
             verify(workflowService).resumeExecution(eq("tenant-1"), eq("exec-1"), captor.capture());
-            assertThat(captor.getValue())
-                    .isInstanceOf(io.hensu.core.resume.ResumeInput.ApplyContextEdits.class);
+            assertThat(captor.getValue()).isInstanceOf(ResumeInput.ApplyContextEdits.class);
         }
 
         @Test
@@ -118,10 +115,9 @@ void shouldResumeWithNullRequestAsNone() {
                 assertThat(response.getStatus()).isEqualTo(200);
             }
 
-            ArgumentCaptor<io.hensu.core.resume.ResumeInput> captor =
-                    ArgumentCaptor.forClass(io.hensu.core.resume.ResumeInput.class);
+            ArgumentCaptor<ResumeInput> captor = ArgumentCaptor.forClass(ResumeInput.class);
             verify(workflowService).resumeExecution(eq("tenant-1"), eq("exec-1"), captor.capture());
-            assertThat(captor.getValue()).isInstanceOf(io.hensu.core.resume.ResumeInput.None.class);
+            assertThat(captor.getValue()).isInstanceOf(ResumeInput.None.class);
         }
 
         @Test

hensu-server/src/test/java/io/hensu/server/integration/StatePersistenceIntegrationTest.java

@@ -2,6 +2,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+import io.hensu.core.resume.ResumeInput;
 import io.hensu.core.state.HensuSnapshot;
 import io.hensu.core.workflow.Workflow;
 import io.hensu.server.workflow.ExecutionStartResult;
@@ -55,7 +56,7 @@ void shouldPauseAndResumeOnDifferentInstance() {
         // Phase 2: Resume — simulates a different server instance by using the
         // persisted snapshot. The TestPauseHandler returns SUCCESS on second call.
         workflowService.resumeExecution(
-                TEST_TENANT, pausedSnapshot.executionId(), io.hensu.core.resume.ResumeInput.NONE);
+                TEST_TENANT, pausedSnapshot.executionId(), ResumeInput.NONE);
 
         // Verify final snapshot shows completion with both step outputs.
         // The repository stores one snapshot per execution ID — the completed
@@ -83,8 +84,7 @@ void shouldPreserveExecutionIdAcrossResume() {
         assertThat(paused.get().checkpointReason()).isEqualTo("paused");
 
         // Resume
-        workflowService.resumeExecution(
-                TEST_TENANT, result.executionId(), io.hensu.core.resume.ResumeInput.NONE);
+        workflowService.resumeExecution(TEST_TENANT, result.executionId(), ResumeInput.NONE);
 
         // The completed snapshot should preserve the same workflow ID
         List<HensuSnapshot> snapshots =
@@ -106,8 +106,7 @@ void shouldApplyResumeModifications() {
         workflowService.resumeExecution(
                 TEST_TENANT,
                 result.executionId(),
-                new io.hensu.core.resume.ResumeInput.ApplyContextEdits(
-                        Map.of("extra", "injected-value")));
+                new ResumeInput.ApplyContextEdits(Map.of("extra", "injected-value")));
 
         // Verify the injected key is present in the final state
         List<HensuSnapshot> snapshots =