From 06fb1d8bc8727d476c0998ff19f90a07f14edade Mon Sep 17 00:00:00 2001 From: hyu2010 Date: Tue, 20 Jul 2021 15:34:03 -0400 Subject: SO changes for Service Intent This update contains the SO changes for the CCVPN extension to support Intent Based Networking (REQ-719). The SO is responsible for providing the Service Intent orchestration, as well as providing the Service Intent APIs which are consumed by the IBN use-case. The changes on the SO are technology-agnostic and are relatively simple. i.e., Technology specific network configurations are carried out by the SDNC. Issue-ID: SO-3714 Signed-off-by: hyu2010 Change-Id: Iec9d2fc80adc79faaeeaf811bd0d02c9d7611d61 Signed-off-by: hyu2010 --- .../process/CreateServiceIntentInstance.bpmn | 175 +++++++++++ .../process/DeleteServiceIntentInstance.bpmn | 161 +++++++++++ .../process/ModifyServiceIntentInstance.bpmn | 173 +++++++++++ .../subprocess/DoCloudLeasedLineCreate.bpmn | 321 +++++++++++++++++++++ .../subprocess/DoCloudLeasedLineDelete.bpmn | 235 +++++++++++++++ .../subprocess/DoCloudLeasedLineModify.bpmn | 252 ++++++++++++++++ 6 files changed, 1317 insertions(+) create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateServiceIntentInstance.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/DeleteServiceIntentInstance.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ModifyServiceIntentInstance.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineCreate.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineDelete.bpmn create mode 100644 bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineModify.bpmn (limited to 'bpmn/so-bpmn-infrastructure-flows') diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateServiceIntentInstance.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateServiceIntentInstance.bpmn new file mode 100644 index 0000000000..7e8290d728 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/CreateServiceIntentInstance.bpmn @@ -0,0 +1,175 @@ + + + + + Flow_0cmaj9d + + + Flow_0cmaj9d + Flow_0ou7wr9 + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new CreateServiceIntentInstance() +nss.preProcessRequest(execution) + + + Flow_0ayd6dj + Flow_0m5n6md + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new CreateServiceIntentInstance() +nss.sendSyncResponse(execution) + + + Flow_0m5n6md + Flow_1fij4ds + Flow_0g7721r + Flow_1kk0exp + + + Flow_189zwjw + Flow_1fij4ds + Flow_1kk0exp + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${initResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_18cgkru + Flow_0ayd6dj + + + + + + #{execution.getVariable("serviceType") != "CLL"} + + + #{execution.getVariable("serviceType") == "CLL"} + + + #{execution.getVariable("networkType") == "AN"} + + + Flow_0ou7wr9 + Flow_18cgkru + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new CreateServiceIntentInstance() +nss.prepareInitOperationStatus(execution) + + + + + + + + + + + + + + + + + + + Flow_0g7721r + Flow_189zwjw + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/DeleteServiceIntentInstance.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/DeleteServiceIntentInstance.bpmn new file mode 100644 index 0000000000..384f9657d3 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/DeleteServiceIntentInstance.bpmn @@ -0,0 +1,161 @@ + + + + + Flow_143ck2k + + + + Flow_143ck2k + Flow_0pttfuf + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new DeleteServiceIntentInstance() +nss.preProcessRequest(execution) + + + Flow_1c1j5i1 + Flow_1kljyhj + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new DeleteServiceIntentInstance() +nss.sendSyncResponse(execution) + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${initResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_04jsg9s + Flow_1c1j5i1 + + + + + Flow_0pttfuf + Flow_04jsg9s + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new DeleteServiceIntentInstance() +nss.prepareInitOperationStatus(execution) + + + + Flow_1kljyhj + Flow_0zwyxxc + Flow_0roz1jy + + + + + + + + + + + + + + Flow_0zwyxxc + Flow_1l74oic + + + Flow_1l74oic + Flow_0roz1jy + + + #{execution.getVariable("serviceType") == "CLL"} + + + #{execution.getVariable("serviceType") != "CLL"} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ModifyServiceIntentInstance.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ModifyServiceIntentInstance.bpmn new file mode 100644 index 0000000000..e042c1a552 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/process/ModifyServiceIntentInstance.bpmn @@ -0,0 +1,173 @@ + + + + + Flow_1t0w8dn + + + Flow_1t0w8dn + Flow_0fzchbl + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new ModifyServiceIntentInstance() +nss.preProcessRequest(execution) + + + Flow_1q030ul + Flow_0ps6iyc + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new ModifyServiceIntentInstance() +nss.sendSyncResponse(execution) + + + Flow_0ps6iyc + Flow_15luvlg + Flow_0usuozn + Flow_1dfyoe6 + + + Flow_1b2k523 + Flow_1dfyoe6 + Flow_15luvlg + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${initResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + Flow_1grhlet + Flow_1q030ul + + + + + + + #{execution.getVariable("networkType") == "TN"} + + + #{execution.getVariable("serviceType") == "CLL"} + + + Flow_0fzchbl + Flow_1grhlet + import org.onap.so.bpmn.infrastructure.scripts.* +def nss = new ModifyServiceIntentInstance() +nss.prepareInitOperationStatus(execution) + + + + + + + + + + + + + + + Flow_0usuozn + Flow_1b2k523 + + + + #{execution.getVariable("serviceType") != "CLL"} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineCreate.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineCreate.bpmn new file mode 100644 index 0000000000..96ebce2297 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineCreate.bpmn @@ -0,0 +1,321 @@ + + + + + SequenceFlow_03s744c + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def css= new DoCloudLeasedLineCreate() +css.preProcessRequest(execution) + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_06rrcwf + + + SequenceFlow_07e12rt + SequenceFlow_0t094g7 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineCreate() +runScript.prepareUpdateJobStatus(execution,"INPROGRESS","10","Create Cloud Leased Line started") + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineCreate() +runScript.prepareUpdateJobStatus(execution,"FINISHED","100","Created CLL successfully") + + + + + + + + Flow_1865m9a + Flow_15mdc4q + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +execution.setVariable("orchestrationStatus", "created") +def runScript = new DoCloudLeasedLineCreate() +runScript.updateAAIOrchStatus(execution) + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_0t094g7 + Flow_1k88aak + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_06rrcwf + + + + Flow_1k88aak + Flow_0xqfi6l + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCloudLeasedLineCreate() +dcsi.createServiceInstance(execution) + + + Flow_0xqfi6l + Flow_1wzmy62 + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCloudLeasedLineCreate() +dcsi.createAllottedResource(execution) + + + Flow_1wzmy62 + Flow_08u0q5g + Flow_15mdc4q + + + Flow_08u0q5g + Flow_1xqkjy9 + import org.onap.so.bpmn.infrastructure.scripts.* +def dcsi = new DoCloudLeasedLineCreate() +dcsi.preprocessSdncCreateCllRequest(execution) + + + + + + + + + + + + Flow_1xqkjy9 + Flow_0vvbiux + + + Flow_0vvbiux + Flow_1865m9a + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("CLL_SDNCAdapterResponse") + +def dcsi = new DoCloudLeasedLineCreate() +dcsi.validateSDNCResponse(execution, response, "allocate") + + + + + + + #{(execution.getVariable("enableSdnc" ) == true)} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineDelete.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineDelete.bpmn new file mode 100644 index 0000000000..4f84317945 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineDelete.bpmn @@ -0,0 +1,235 @@ + + + + + SequenceFlow_03s744c + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_0ca4l8d + + + SequenceFlow_1jygjln + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineDelete() +runScript.prepareUpdateJobStatus(execution,"FINISHED","100","Deleted CLL successfully") + + + + + Flow_0sj0mtu + Flow_0cpctye + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineDelete() +runScript.preprocessSdncDeleteCllRequest(execution) + + + + + + + + + + + + + Flow_0cpctye + Flow_0fuabjs + + + + Flow_0fuabjs + SequenceFlow_1jdb2oq + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("CLL_SDNCAdapterResponse") + +def runScript = new DoCloudLeasedLineDelete() +runScript.validateSDNCResponse(execution, response, "deallocate") + + + SequenceFlow_1jdb2oq + Flow_0dirb5b + SequenceFlow_1jygjln + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineDelete() +runScript.deleteServiceInstance(execution) + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineDelete() +runScript.preProcessRequest(execution) + + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_0ca4l8d + + + + SequenceFlow_07e12rt + Flow_0sj0mtu + Flow_0dirb5b + + + #{(execution.getVariable("enableSdnc" ) == true)} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineModify.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineModify.bpmn new file mode 100644 index 0000000000..1c2ce98f09 --- /dev/null +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCloudLeasedLineModify.bpmn @@ -0,0 +1,252 @@ + + + + + SequenceFlow_03s744c + + + + SequenceFlow_1w67v6s + + + + SequenceFlow_08mlzwz + + + SequenceFlow_1w67v6s + SequenceFlow_08mlzwz + import org.onap.so.bpmn.common.scripts.* +ExceptionUtil ex = new ExceptionUtil() +ex.processJavaException(execution) + + + + + + Flow_1akxvak + + + SequenceFlow_0kixzdj + SequenceFlow_1qv8qw1 + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineModify() +runScript.prepareUpdateJobStatus(execution,"FINISHED","100","Modified CLL successfully") + + + + + Flow_0h5rwlh + Flow_0b3rxne + SequenceFlow_0kixzdj + import org.onap.so.bpmn.infrastructure.scripts.* +execution.setVariable("orchestrationStatus", "modified") +def runScript = new DoCloudLeasedLineModify() +runScript.updateAAIOrchStatus(execution) + + + + SequenceFlow_07e12rt + SequenceFlow_1jdb2oq + import org.onap.so.bpmn.infrastructure.scripts.* + +def runScript = new DoCloudLeasedLineModify() +runScript.updateServiceInstanceInAAI(execution) + + + + SequenceFlow_03s744c + SequenceFlow_07e12rt + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineModify() +runScript.preProcessRequest(execution) + + + + Flow_0cm9i4m + Flow_1dvo5ih + import org.onap.so.bpmn.infrastructure.scripts.* +def runScript = new DoCloudLeasedLineModify() +runScript.preprocessSdncModifyCllRequest(execution) + + + + + + + + + + + + + Flow_1dvo5ih + Flow_139j3yd + + + + Flow_139j3yd + Flow_0h5rwlh + import org.onap.so.bpmn.infrastructure.scripts.* + +String response = execution.getVariable("CLL_SDNCAdapterResponse") + +def runScript = new DoCloudLeasedLineModify() +runScript.validateSDNCResponse(execution, response, "modify") + + + + + + + ${dbAdapterEndpoint} + + + application/soap+xml + Basic YnBlbDpwYXNzd29yZDEk + + + ${updateResourceOperationStatus} + POST + ${statusCode} + ${response} + + http-connector + + + SequenceFlow_1qv8qw1 + Flow_1akxvak + + + + SequenceFlow_1jdb2oq + Flow_0cm9i4m + Flow_0b3rxne + + + #{(execution.getVariable("enableSdnc" ) == true)} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + -- cgit 1.2.3-korg