From a4aa9d1d7c94a3e464e80436368acf9d35c9ce75 Mon Sep 17 00:00:00 2001 From: Simon Zambrovski Date: Wed, 16 Oct 2024 12:45:36 +0200 Subject: [PATCH] add apis to stages --- .../testing/AbstractC7EmbeddedStage.kt | 13 +++++++++++++ .../c8/testing/AbstractC8ProcessStage.kt | 13 +++++++++++++ .../out/process/SimpleProcessStages.java | 19 +++++++++++++++++++ .../out/process/SimpleProcessTest.java | 3 ++- 4 files changed, 47 insertions(+), 1 deletion(-) diff --git a/engine-adapter/camunda-platform-7-embedded-core/src/main/kotlin/dev/bpmcrafters/processengineapi/adapter/c7/embedded/testing/AbstractC7EmbeddedStage.kt b/engine-adapter/camunda-platform-7-embedded-core/src/main/kotlin/dev/bpmcrafters/processengineapi/adapter/c7/embedded/testing/AbstractC7EmbeddedStage.kt index 15741a1..054e29a 100644 --- a/engine-adapter/camunda-platform-7-embedded-core/src/main/kotlin/dev/bpmcrafters/processengineapi/adapter/c7/embedded/testing/AbstractC7EmbeddedStage.kt +++ b/engine-adapter/camunda-platform-7-embedded-core/src/main/kotlin/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> @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> null ) + signalApi = SignalApiImpl(client) + correlationApi = CorrelationApiImpl(client) + initialize() // activate delivery diff --git a/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessStages.java b/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessStages.java index 5b0f0da..c558e26 100644 --- a/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessStages.java +++ b/examples/java-c7/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 { + @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 { diff --git a/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessTest.java b/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessTest.java index 0c0c278..e99ddc4 100644 --- a/examples/java-c7/src/test/java/dev/bpmcrafters/example/common/adapter/out/process/SimpleProcessTest.java +++ b/examples/java-c7/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); } }