Feature/#95 decision service

docs/introduction/features.md

@@ -69,3 +69,8 @@ but still provide an alternative implementation for some methods.
 ## HistoryService
 
 * Historic process instance query: `#createHistoricProcessInstanceQuery()`
+
+## DecisionService
+
+* Evaluate decision: `#evaluateDecisionById()`,`#evaluateDecisionByKey()`
+* Evaluate decision table: `#evaluateDecisionTableById()`,`#evaluateDecisionTableByKey()`.`#evaluateDecisionTableByKeyAndVersion()`

docs/user-guide/examples.md

@@ -69,6 +69,8 @@ feign:
         url: "http://localhost:8083/engine-rest/"
       variableInstance:
         url: "http://localhost:8083/engine-rest/"
+      decisionDefinition:
+        url: "http://localhost:8083/engine-rest/"
 ```
 
 To run this example, you will need the server part from the next example. To activate the server part only, please
@@ -154,5 +156,7 @@ feign:
         url: "http://localhost:8083/engine-rest/"
       variableInstance:
         url: "http://localhost:8083/engine-rest/"
+      decisionDefinition:
+        url: "http://localhost:8083/engine-rest/"
 ```
 

docs/user-guide/support-matrix.md

@@ -109,3 +109,11 @@ Here are currently implemented methods. The version behind the service name deno
 ## HistoryService @ 0.0.7
 
 * `# createHistoricProcessInstanceQuery`
+
+## DecisionService @ 7.17.3
+
+* `# evaluateDecisionById`
+* `# evaluateDecisionByKey`
+* `# evaluateDecisionTableById`
+* `# evaluateDecisionTableByKey`
+* `# evaluateDecisionTableByKeyAndVersion`

examples/example-provided/src/main/resources/application.yml

@@ -49,6 +49,8 @@ feign:
         url: "http://localhost:${server.port}/engine-rest/"
       variableInstance:
         url: "http://localhost:${server.port}/engine-rest/"
+      decisionDefinition:
+        url: "http://localhost:${server.port}/engine-rest/"
 
 logging:
   level:

examples/example/src/main/resources/application.yml

@@ -32,7 +32,8 @@ feign:
         url: "http://localhost:8083/engine-rest/"
       variableInstance:
         url: "http://localhost:8083/engine-rest/"
-
+      decisionDefinition:
+        url: "http://localhost:8083/engine-rest/"
 
 logging:
   level:

examples/itest/pom.xml

@@ -81,6 +81,12 @@
 
     <!-- Testing -->
     <!-- add junit 4 to enable its usage until Camunda switched to JUnit 5 -->
+    <dependency>
+      <groupId>io.holunda.decision</groupId>
+      <artifactId>camunda-decision-model</artifactId>
+      <version>0.0.1</version>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>

examples/itest/src/test/kotlin/org/camunda/community/rest/itest/DecisionServiceITest.kt

@@ -0,0 +1,128 @@
+/*-
+ * #%L
+ * camunda-platform-7-rest-client-spring-boot-itest
+ * %%
+ * Copyright (C) 2019 Camunda Services GmbH
+ * %%
+ * Copyright Camunda Services GmbH and/or licensed to Camunda Services GmbH
+ *  under one or more contributor license agreements. See the NOTICE file
+ *  distributed with this work for additional information regarding copyright
+ *  ownership. Camunda licenses this file to you under the Apache License,
+ *  Version 2.0; you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ * #L%
+ */
+package org.camunda.community.rest.itest
+
+import com.tngtech.jgiven.annotation.As
+import io.toolisticon.testing.jgiven.GIVEN
+import io.toolisticon.testing.jgiven.THEN
+import io.toolisticon.testing.jgiven.WHEN
+import org.camunda.bpm.engine.DecisionService
+import org.camunda.community.rest.itest.stages.CamundaRestClientITestBase
+import org.camunda.community.rest.itest.stages.DecisionServiceActionStage
+import org.camunda.community.rest.itest.stages.DecisionServiceAssertStage
+import org.junit.Test
+
+@As("Incident")
+class DecisionServiceITest : CamundaRestClientITestBase<DecisionService, DecisionServiceActionStage, DecisionServiceAssertStage>() {
+
+  @Test
+  fun `should evaluate decision by id`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed()
+    WHEN
+      .decision_is_evaluated_by_id(mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+  }
+
+  @Test
+  fun `should evaluate decision by key`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed()
+    WHEN
+      .decision_is_evaluated_by_key(variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+  }
+
+  @Test
+  fun `should evaluate decision table by id`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed()
+    WHEN
+      .decision_table_is_evaluated_by_id(mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+  }
+
+  @Test
+  fun `should evaluate decision table by key`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed()
+    WHEN
+      .decision_table_is_evaluated_by_key(variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+  }
+
+  @Test
+  fun `should evaluate decision table by key and version`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed()
+      .and()
+      .decision_table_is_deployed(version = "2")
+    WHEN
+      .decision_table_is_evaluated_by_key_and_version(version = 1, variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+    WHEN
+      .decision_table_is_evaluated_by_key_and_version(version = 2, variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output1", "Rule1OutputV2")))
+  }
+
+  @Test
+  fun `should evaluate decision table by key with tenant`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .decision_table_is_deployed(tenantId = "tenantId")
+    WHEN
+      .decision_table_is_evaluated_by_key_and_tenant(tenantId = "tenantId", variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output1", "Rule1Output")))
+  }
+
+  @Test
+  fun `should evaluate decision table by key in drd`() {
+    GIVEN
+      .no_deployment_exists()
+      .and()
+      .drd_is_deployed()
+    WHEN
+      .decision_table_is_evaluated_by_key(decisionDefinitionKey = "table2", variables = mutableMapOf(Pair("input1", "Rule1")))
+    THEN
+      .decision_table_result_is_correct(mutableMapOf(Pair("output2", "Rule1Output2")))
+  }
+
+}