From fa9a707c87654330dfb5788a6029b8199c6cdf17 Mon Sep 17 00:00:00 2001 From: "Boslet, Cory" Date: Thu, 16 Apr 2020 10:43:38 -0400 Subject: move network adapter to an external client task Began impelenting new network external task. Made the vnfAdapterTask subflow an openstack subflow, refactored infra flows and BB to call it for network functions. Fixed bugs discovered through a robot dry run, added unit test, added support for rollback network request Updated junit test files for comparison due to not polling for response Removed the no longer used network adapter rest task from bpmn tasks Removed the unused network adapter async and its beans Removed network async client package from open pojo scan Issue-ID: SO-2813 Signed-off-by: Benjamin, Max (mb388a) Change-Id: I4c25892012cc86659ab122448ed1aca5cab91671 --- .../resources/subprocess/DoCreateVfModule.bpmn | 890 ++++++++++----------- 1 file changed, 445 insertions(+), 445 deletions(-) (limited to 'bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateVfModule.bpmn') diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateVfModule.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateVfModule.bpmn index 0d1b970c62..74e0600f4f 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateVfModule.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoCreateVfModule.bpmn @@ -1,5 +1,5 @@ - + SequenceFlow_1 @@ -37,7 +37,7 @@ SequenceFlow_21 - + #{execution.getVariable("DCVFM_volumeGroupName") != null && execution.getVariable("DCVFM_volumeGroupName") != "" } @@ -76,19 +76,19 @@ SequenceFlow_20 SequenceFlow_1nh92s8 - import org.onap.so.bpmn.infrastructure.scripts.* String response = execution.getVariable("DCVFM_assignSDNCAdapterResponse") def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.validateSDNCResponse(execution, response, "assign")]]> +doCreateVfModule.validateSDNCResponse(execution, response, "assign") SequenceFlow_8 SequenceFlow_18 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessSDNCAssignRequest(execution)]]> +doCreateVfModule.preProcessSDNCAssignRequest(execution) @@ -96,9 +96,9 @@ doCreateVfModule.preProcessSDNCAssignRequest(execution)]]> SequenceFlow_0p61zug SequenceFlow_0aegg0r SequenceFlow_23 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessSDNCGetRequest(execution, "vfmodule")]]> +doCreateVfModule.preProcessSDNCGetRequest(execution, "vfmodule") @@ -118,12 +118,12 @@ doCreateVfModule.preProcessSDNCGetRequest(execution, "vfmodule")]]> SequenceFlow_24 SequenceFlow_31 - import org.onap.so.bpmn.infrastructure.scripts.* String response = execution.getVariable("DCVFM_getSDNCAdapterResponse") def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.validateSDNCResponse(execution, response, "get")]]> +doCreateVfModule.validateSDNCResponse(execution, response, "get") @@ -138,16 +138,16 @@ doCreateVfModule.validateSDNCResponse(execution, response, "get")]]> SequenceFlow_1avfxsz SequenceFlow_5 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessUpdateAAIVfModuleRequestOrch(execution)]]> +doCreateVfModule.preProcessUpdateAAIVfModuleRequestOrch(execution) SequenceFlow_10 SequenceFlow_12 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessSDNCActivateRequest(execution)]]> +doCreateVfModule.preProcessSDNCActivateRequest(execution) @@ -165,12 +165,12 @@ doCreateVfModule.preProcessSDNCActivateRequest(execution)]]> SequenceFlow_13 SequenceFlow_14 - import org.onap.so.bpmn.infrastructure.scripts.* String response = execution.getVariable("DCVFM_activateSDNCAdapterResponse") def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.validateSDNCResponse(execution, response, "activate")]]> +doCreateVfModule.validateSDNCResponse(execution, response, "activate") SequenceFlow_14 @@ -195,9 +195,9 @@ doCreateVfModule.validateSDNCResponse(execution, response, "activate")]]> SequenceFlow_28 SequenceFlow_3 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.prepareCreateAAIVfModuleVolumeGroupRequest(execution)]]> +doCreateVfModule.prepareCreateAAIVfModuleVolumeGroupRequest(execution) @@ -220,13 +220,13 @@ doCreateVfModule.prepareCreateAAIVfModuleVolumeGroupRequest(execution)]]> SequenceFlow_31 SequenceFlow_32 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessVNFAdapterRequest(execution)]]> +doCreateVfModule.preProcessVNFAdapterRequest(execution) - + - + @@ -239,9 +239,9 @@ doCreateVfModule.preProcessVNFAdapterRequest(execution)]]> SequenceFlow_33 SequenceFlow_1ushk1d - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.postProcessVNFAdapterRequest(execution)]]> +doCreateVfModule.postProcessVNFAdapterRequest(execution) SequenceFlow_0xfanpi @@ -265,9 +265,9 @@ doCreateVfModule.postProcessVNFAdapterRequest(execution)]]> SequenceFlow_25 SequenceFlow_27 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.postProcessCreateAAIVfModule(execution)]]> +doCreateVfModule.postProcessCreateAAIVfModule(execution) @@ -277,22 +277,22 @@ doCreateVfModule.postProcessCreateAAIVfModule(execution)]]> - + execution.getVariable("DCVFM_isBaseVfModule") == "true" SequenceFlow_36 SequenceFlow_37 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.queryAAIVfModule(execution)]]> +doCreateVfModule.queryAAIVfModule(execution) SequenceFlow_16 SequenceFlow_7 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.setSuccessIndicator(execution, true)]]> +doCreateVfModule.setSuccessIndicator(execution, true) @@ -302,20 +302,20 @@ doCreateVfModule.setSuccessIndicator(execution, true)]]> SequenceFlow_40 SequenceFlow_43 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -return doCreateVfModule.queryCloudRegion(execution)]]> +return doCreateVfModule.queryCloudRegion(execution) - + #{execution.getVariable("DCVFM_volumeGroupId") != null && execution.getVariable("DCVFM_volumeGroupId") != "" } SequenceFlow_1 SequenceFlow_4 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessRequest(execution)]]> +doCreateVfModule.preProcessRequest(execution) @@ -352,16 +352,16 @@ doCreateVfModule.preProcessRequest(execution)]]> - + execution.getVariable("DCVFM_contrailNetworkPolicyFqdnList") != null && !execution.getVariable("DCVFM_contrailNetworkPolicyFqdnList").isEmpty() SequenceFlow_0ery1pk SequenceFlow_0abffyj - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.createNetworkPoliciesInAAI(execution)]]> +doCreateVfModule.createNetworkPoliciesInAAI(execution) SequenceFlow_0363dz7 @@ -374,7 +374,7 @@ doCreateVfModule.createNetworkPoliciesInAAI(execution)]]> SequenceFlow_1avfxsz - + !execution.getVariable("DCVFM_oamManagementV4Address").isEmpty() || !execution.getVariable("DCVFM_oamManagementV6Address").isEmpty() @@ -384,9 +384,9 @@ doCreateVfModule.createNetworkPoliciesInAAI(execution)]]> SequenceFlow_0bi38s7 SequenceFlow_1qm81ym - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.prepUpdateAAIGenericVnf(execution)]]> +doCreateVfModule.prepUpdateAAIGenericVnf(execution) @@ -401,16 +401,16 @@ doCreateVfModule.prepUpdateAAIGenericVnf(execution)]]> - + #{execution.getVariable("DCVFM_sdncVersion" ) == '1707'} SequenceFlow_0m382su SequenceFlow_0g270u0 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessSDNCGetRequest(execution, 'vnf')]]> +doCreateVfModule.preProcessSDNCGetRequest(execution, 'vnf') @@ -428,12 +428,12 @@ doCreateVfModule.preProcessSDNCGetRequest(execution, 'vnf')]]> SequenceFlow_1yrlvgb SequenceFlow_170kw7h - import org.onap.so.bpmn.infrastructure.scripts.* String response = execution.getVariable("DCVFM_getVnfSDNCAdapterResponse") def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.validateSDNCResponse(execution, response, "get")]]> +doCreateVfModule.validateSDNCResponse(execution, response, "get") @@ -445,7 +445,7 @@ doCreateVfModule.validateSDNCResponse(execution, response, "get")]]> - + #{execution.getVariable("DCVFM_vfModuleName") == null} @@ -486,16 +486,16 @@ doCreateVfModule.validateSDNCResponse(execution, response, "get")]]> SequenceFlow_04bd5in SequenceFlow_1i1q78e - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessRollback(execution)]]> +doCreateVfModule.preProcessRollback(execution) SequenceFlow_0112l2c SequenceFlow_0z2rczk - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.postProcessRollback(execution)]]> +doCreateVfModule.postProcessRollback(execution) @@ -508,14 +508,14 @@ doCreateVfModule.postProcessRollback(execution)]]> - + #{execution.getVariable("disableRollback" ) == true} SequenceFlow_1nh7m8d SequenceFlow_1pgo10r - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.processBPMNException(execution)]]> +doCreateVfModule.processBPMNException(execution) @@ -525,7 +525,7 @@ doCreateVfModule.processBPMNException(execution)]]> SequenceFlow_006rnym - + #{execution.getVariable("DCVFM_volumeGroupId") != null && execution.getVariable("DCVFM_volumeGroupId") != "" } SequenceFlow_4 @@ -540,18 +540,18 @@ doCreateVfModule.processBPMNException(execution)]]> - + execution.getVariable("DCVFM_aLaCarte") == true - + execution.getVariable("DCVFM_twoPhaseDesign") == true SequenceFlow_00bh7m7 - + execution.getVariable("DCVFM_orchestrationStatus") == "PendingActivation" || execution.getVariable("DCVFM_orchestrationStatus") == "Assigned" SequenceFlow_1nh92s8 @@ -559,7 +559,7 @@ doCreateVfModule.processBPMNException(execution)]]> SequenceFlow_1iyt5i4 - + execution.getVariable("DCVFM_aLaCarte") == true @@ -581,30 +581,30 @@ doCreateVfModule.processBPMNException(execution)]]> SequenceFlow_17cp3tn SequenceFlow_0ynd0iy - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessUpdateAAIVfModuleRequestStatus(execution, 'PendingActivation')]]> +doCreateVfModule.preProcessUpdateAAIVfModuleRequestStatus(execution, 'PendingActivation') SequenceFlow_16mgvsd SequenceFlow_0cc17yk - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.queryCatalogDB(execution)]]> +doCreateVfModule.queryCatalogDB(execution) SequenceFlow_1y8q87e SequenceFlow_1sf1091 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.queryAAIVfModuleForStatus(execution)]]> +doCreateVfModule.queryAAIVfModuleForStatus(execution) SequenceFlow_1mnipp8 SequenceFlow_00bh7m7 - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.setSuccessIndicator(execution, true)]]> +doCreateVfModule.setSuccessIndicator(execution, true) SequenceFlow_15i583d @@ -613,7 +613,7 @@ doCreateVfModule.setSuccessIndicator(execution, true)]]> - + #{execution.getVariable("DCVFM_volumeGroupId") != null && execution.getVariable("DCVFM_volumeGroupId") != "" } SequenceFlow_0tfrcnc @@ -629,7 +629,7 @@ doCreateVfModule.setSuccessIndicator(execution, true)]]> SequenceFlow_0p3cspl - + execution.getVariable("DCVFM_isBaseVfModule") == "true" @@ -642,9 +642,9 @@ doCreateVfModule.setSuccessIndicator(execution, true)]]> SequenceFlow_0oadvvx SequenceFlow_03batve - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -return doCreateVfModule.queryCloudRegion(execution)]]> +return doCreateVfModule.queryCloudRegion(execution) @@ -663,17 +663,17 @@ return doCreateVfModule.queryCloudRegion(execution)]]> SequenceFlow_0p3cspl SequenceFlow_1k7xbcu - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.queryAAIVfModule(execution)]]> +doCreateVfModule.queryAAIVfModule(execution) SequenceFlow_006rnym SequenceFlow_1iyt5i4 SequenceFlow_0thm33s - import org.onap.so.bpmn.infrastructure.scripts.* def doCreateVfModule = new DoCreateVfModule() -doCreateVfModule.preProcessUpdateAAIVfModuleRequestStatus(execution, 'Assigned')]]> +doCreateVfModule.preProcessUpdateAAIVfModuleRequestStatus(execution, 'Assigned') @@ -693,983 +693,983 @@ doCreateVfModule.preProcessUpdateAAIVfModuleRequestStatus(execution, 'Assigned') - + - + - - + + - + - + - + - + - + - + - + - + - + - + - + - - + + - + - + - + - + - + - + - + - + - - - - + + + + - - - + + + - + - - - - + + + + - + - + - - + + - + - - + + - + - - - + + + - + - - - + + + - - - + + + - - - - + + + + - + - + - + - + - + - + - - - - + + + + - - - - + + + + - - - - + + + + - + - + - - - - + + + + - - - - + + + + - + - + - + - - + + - - + + - - - - + + + + - - + + - - - - + + + + - + - - + + - + - + - + - + - + - - + + - + - + - - - - + + + + - - + + - - + + - + - + - + - + - + - - - + + + - + - - + + - + - + - - - - + + + + - - - - + + + + - + - - + + - + - - - - + + + + - + - - - - - + + + + + - + - - + + - + - + - - + + - - - + + + - + - - + + - + - - - + + + - + - + - + - + - - - + + + - + - - - - + + + + - - - + + + - - + + - + - - - - + + + + - - + + - + - + - - + + - + - - - + + + - + - - + + - - + + - + - + - + - - - - + + + + - - - + + + - + - + - - + + - + - - - + + + - + - + - + - + - + - + - + - + - - + + - - - - + + + + - - + + - - + + - + - + - - + + - + - - - + + + - + - + - - - + + + - + - + - - + + - + - + - + - - + + - + - + - + - - - + + + - + - - + + - + - - + + - - + + - + - + - - + + - + - + - + - - + + - + - - + + - - + + - - - - - + + + + + - + - - - - + + + + - + - - + + - - + + - - + + - + - + - + - + - + - + - + - - + + - + - - - + + + - + - + - - + + - - + + - - - + + + - + - + - - + + - + - - - + + + - + - + - - - - - - + + + + + + - - - + + + - + - + - + - + - + - - + + - - - - - + + + + + -- cgit 1.2.3-korg