From 9f2a2bc0638714ca453ba8d73db7d66306760d22 Mon Sep 17 00:00:00 2001 From: Srinivasan Ramanathan Date: Wed, 9 Sep 2020 12:05:14 +0000 Subject: Changes for MDONS usecase SO-2950 Changes for MDONS usecase Async flow Change-Id: I2385610a43b993f66a482cd321f8c7fd2db3535f Issue-ID: SO-2950 Signed-off-by: Srinivasan Ramanathan --- .../scripts/CreateSDNCNetworkResource.groovy | 1 + .../process/CreateSDNCNetworkResource.bpmn | 169 ++++++++++++++------- 2 files changed, 112 insertions(+), 58 deletions(-) (limited to 'bpmn') diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSDNCNetworkResource.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSDNCNetworkResource.groovy index 2b9e43109c..56a97bc271 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSDNCNetworkResource.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/CreateSDNCNetworkResource.groovy @@ -265,6 +265,7 @@ public class CreateSDNCNetworkResource extends AbstractServiceTaskProcessor { String uResourceInput = jsonUtil.addJsonValue(resourceInput, "requestInputs.service-name", inputParameters.get("name")) resourceInputObj.setResourceParameters(uResourceInput) execution.setVariable(Prefix + "resourceInput", resourceInputObj.toString()) + execution.setVariable("isAsyncRequired", "Yes") break case ~/[\w\s\W]*sdwanvpnattachment[\w\s\W]*/ : diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateSDNCNetworkResource.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateSDNCNetworkResource.bpmn index 5a4b3ac348..a1f70333e3 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateSDNCNetworkResource.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateSDNCNetworkResource.bpmn @@ -1,5 +1,5 @@ - + SequenceFlow_1qo2pln @@ -26,7 +26,7 @@ dcsi.prepareSDNCRequest(execution) - SequenceFlow_15mvedq + SequenceFlow_11i5vrt SequenceFlow_0u8d8j5 @@ -46,7 +46,7 @@ def dcsi = new CreateSDNCNetworkResource() dcsi.preProcessRequest(execution) - + SequenceFlow_0khtova SequenceFlow_1mz0vdx @@ -155,157 +155,210 @@ dcsi.updateResourceInput(execution) SequenceFlow_0u8d8j5 + SequenceFlow_06wc3j9 SequenceFlow_0oqe2oa import org.onap.so.bpmn.infrastructure.scripts.* def dcsi = new CreateSDNCNetworkResource() dcsi.afterCreateSDNCCall(execution) + + SequenceFlow_15mvedq + SequenceFlow_11i5vrt + SequenceFlow_1r9zpux + + + + + + + + + + + + + SequenceFlow_1r9zpux + SequenceFlow_06wc3j9 + + + #{(execution.getVariable("isAsyncRequired") == "Yes")} + + - + - + - - + + - - + + - + - + - + - + - - + + - - + + - + - + - - + + - - - - - + + + + + - + - + - + - + - + - + - - - + + + - + - + - - + + - + - - - + + + - - + + - - + + - + - - + + - + - - + + - - + + - - + + - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg