add apis to stages

bpm-crafters · Oct 16, 2024 · a4aa9d1 · a4aa9d1
1 parent 7047411
commit a4aa9d1
Show file tree

Hide file tree

Showing 4 changed files with 47 additions and 1 deletion.
diff --git a/...n/dev/bpmcrafters/processengineapi/adapter/c7/embedded/testing/AbstractC7EmbeddedStage.kt b/...n/dev/bpmcrafters/processengineapi/adapter/c7/embedded/testing/AbstractC7EmbeddedStage.kt
@@ -6,6 +6,8 @@ import com.tngtech.jgiven.annotation.ProvidedScenarioState
 import com.tngtech.jgiven.annotation.Quoted
 import com.tngtech.jgiven.annotation.ScenarioState
 import dev.bpmcrafters.processengineapi.CommonRestrictions
+import dev.bpmcrafters.processengineapi.adapter.c7.embedded.correlation.CorrelationApiImpl
+import dev.bpmcrafters.processengineapi.adapter.c7.embedded.correlation.SignalApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c7.embedded.deploy.DeploymentApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c7.embedded.process.StartProcessApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c7.embedded.task.completion.C7ServiceTaskCompletionApiImpl
@@ -16,6 +18,8 @@ import dev.bpmcrafters.processengineapi.adapter.c7.embedded.task.delivery.pull.E
 import dev.bpmcrafters.processengineapi.adapter.c7.embedded.task.subscription.C7TaskSubscriptionApiImpl
 import dev.bpmcrafters.processengineapi.adapter.commons.task.InMemSubscriptionRepository
 import dev.bpmcrafters.processengineapi.adapter.commons.task.UserTaskSupport
+import dev.bpmcrafters.processengineapi.correlation.CorrelationApi
+import dev.bpmcrafters.processengineapi.correlation.SignalApi
 import dev.bpmcrafters.processengineapi.deploy.DeployBundleCommand
 import dev.bpmcrafters.processengineapi.deploy.DeploymentApi
 import dev.bpmcrafters.processengineapi.deploy.NamedResource.Companion.fromClasspath
@@ -62,6 +66,12 @@ abstract class AbstractC7EmbeddedStage<SUBTYPE : AbstractC7EmbeddedStage<SUBTYPE
   @ProvidedScenarioState
   protected lateinit var deploymentApi: DeploymentApi
 
+  @ProvidedScenarioState
+  protected lateinit var signalApi: SignalApi
+
+  @ProvidedScenarioState
+  protected lateinit var correlationApi: CorrelationApi
+
   @ProvidedScenarioState
   protected lateinit var processEngineServices: ProcessEngineServices
 
@@ -126,6 +136,9 @@ abstract class AbstractC7EmbeddedStage<SUBTYPE : AbstractC7EmbeddedStage<SUBTYPE
       taskSubscriptionApi, restrictions, null, null
     )
 
+    signalApi = SignalApiImpl(processEngineServices.runtimeService)
+    correlationApi = CorrelationApiImpl(processEngineServices.runtimeService)
+
     initialize()
 
     // activate delivery

diff --git a/...main/kotlin/dev/bpmcrafters/processengineapi/adapter/c8/testing/AbstractC8ProcessStage.kt b/...main/kotlin/dev/bpmcrafters/processengineapi/adapter/c8/testing/AbstractC8ProcessStage.kt
@@ -6,6 +6,8 @@ import com.tngtech.jgiven.annotation.ProvidedScenarioState
 import com.tngtech.jgiven.annotation.Quoted
 import com.tngtech.jgiven.annotation.ScenarioState
 import dev.bpmcrafters.processengineapi.CommonRestrictions
+import dev.bpmcrafters.processengineapi.adapter.c8.correlation.CorrelationApiImpl
+import dev.bpmcrafters.processengineapi.adapter.c8.correlation.SignalApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c8.deploy.DeploymentApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c8.process.StartProcessApiImpl
 import dev.bpmcrafters.processengineapi.adapter.c8.task.completion.C8ZeebeExternalServiceTaskCompletionApiImpl
@@ -15,6 +17,8 @@ import dev.bpmcrafters.processengineapi.adapter.c8.task.delivery.SubscribingRefr
 import dev.bpmcrafters.processengineapi.adapter.c8.task.subscription.C8TaskSubscriptionApiImpl
 import dev.bpmcrafters.processengineapi.adapter.commons.task.InMemSubscriptionRepository
 import dev.bpmcrafters.processengineapi.adapter.commons.task.UserTaskSupport
+import dev.bpmcrafters.processengineapi.correlation.CorrelationApi
+import dev.bpmcrafters.processengineapi.correlation.SignalApi
 import dev.bpmcrafters.processengineapi.deploy.DeployBundleCommand
 import dev.bpmcrafters.processengineapi.deploy.DeploymentApi
 import dev.bpmcrafters.processengineapi.deploy.NamedResource.Companion.fromClasspath
@@ -69,6 +73,12 @@ abstract class AbstractC8ProcessStage<SUBTYPE : AbstractC8ProcessStage<SUBTYPE>>
   @ProvidedScenarioState
   protected lateinit var deploymentApi: DeploymentApi
 
+  @ProvidedScenarioState
+  protected lateinit var signalApi: SignalApi
+
+  @ProvidedScenarioState
+  protected lateinit var correlationApi: CorrelationApi
+
   @ProvidedScenarioState
   protected lateinit var taskInformation: TaskInformation
 
@@ -125,6 +135,9 @@ abstract class AbstractC8ProcessStage<SUBTYPE : AbstractC8ProcessStage<SUBTYPE>>
       null
     )
 
+    signalApi = SignalApiImpl(client)
+    correlationApi = CorrelationApiImpl(client)
+
     initialize()
 
     // activate delivery

diff --git a/...src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessStages.java b/...src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessStages.java
@@ -1,10 +1,29 @@
 package dev.bpmcrafters.example.common.adapter.out.process;
 
+import com.tngtech.jgiven.annotation.ProvidedScenarioState;
+import dev.bpmcrafters.example.common.application.port.out.WorkflowOutPort;
 import dev.bpmcrafters.processengineapi.adapter.c7.embedded.testing.AbstractC7EmbeddedStage;
 
 public class SimpleProcessStages {
   static class ActionStage extends AbstractC7EmbeddedStage<ActionStage> {
 
+    @ProvidedScenarioState
+    private WorkflowOutPort workflowOutPort;
+
+    @Override
+    public void initialize() {
+      workflowOutPort = new WorkflowAdapter(
+        startProcessApi,
+        signalApi,
+        correlationApi,
+        deploymentApi
+      );
+    }
+
+    public ActionStage process_is_started(String value, Integer intValue) {
+      workflowOutPort.startSimpleProcess(value, intValue);
+      return self();
+    }
   }
 
   static class AssertStage extends AbstractC7EmbeddedStage<AssertStage> {

diff --git a/...7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessTest.java b/...7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessTest.java
@@ -20,7 +20,8 @@ public void setup() {
 
   // @Test
   public void should_start_process_and_run_happy_path() {
-
+    given()
+      .process_is_started("test", 42);
   }
 
 }