Add generic workflow for delete NS

[so.git] / bpmn / MSOInfrastructureBPMN / src / main / groovy / org / openecomp / mso / bpmn / infrastructure / scripts / DeleteVfModuleVolumeInfraV1.groovy

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteVfModuleVolumeInfraV1.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteVfModuleVolumeInfraV1.groovy
index 7bda7b4..5a38d9f 100644 (file)
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteVfModuleVolumeInfraV1.groovy
+++ b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DeleteVfModuleVolumeInfraV1.groovy
@@ -1,6 +1,6 @@
 /*-\r
  * ============LICENSE_START=======================================================\r
- * OPENECOMP - MSO\r
+ * ONAP - SO\r
  * ================================================================================\r
  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
  * ================================================================================\r
@@ -26,7 +26,7 @@ import java.util.concurrent.ExecutionException;
 \r
 import org.springframework.web.util.UriUtils\r
 import org.camunda.bpm.engine.delegate.BpmnError\r
-import org.camunda.bpm.engine.runtime.Execution\r
+import org.camunda.bpm.engine.delegate.DelegateExecution\r
 import org.apache.commons.lang3.*\r
 import org.openecomp.mso.bpmn.common.scripts.AaiUtil;\r
 import org.openecomp.mso.bpmn.common.scripts.AbstractServiceTaskProcessor;\r
@@ -45,7 +45,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
         * This method is executed during the preProcessRequest task of the <class>DeleteVfModuleVolume.bpmn</class> process.\r
         * @param execution\r
         */\r
-       public InitializeProcessVariables(Execution execution){\r
+       public InitializeProcessVariables(DelegateExecution execution){\r
                execution.setVariable('prefix', 'DELVfModVol_')\r
                execution.setVariable("DELVfModVol_volumeRequest", null)\r
                execution.setVariable('DELVfModVol_requestInfo', null)\r
@@ -76,7 +76,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
         * Perform initial processing, such as request validation, initialization of variables, etc.\r
         * * @param execution\r
         */\r
-       public void preProcessRequest (Execution execution) {\r
+       public void preProcessRequest (DelegateExecution execution) {\r
                def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
                preProcessRequest(execution, isDebugEnabled)\r
        }\r
@@ -85,7 +85,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
         * This method is executed during the preProcessRequest task of the <class>DeleteVfModuleVolume.bpmn</class> process.\r
         * @param execution\r
         */\r
-       public void preProcessRequest (Execution execution, isDebugLogEnabled) {\r
+       public void preProcessRequest (DelegateExecution execution, isDebugLogEnabled) {\r
 \r
                InitializeProcessVariables(execution)\r
 \r
@@ -132,23 +132,12 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
                execution.setVariable('DELVfModVol_volumeParams', utils.getNodeXml(request, 'volume-params'))\r
                execution.setVariable('DELVfModVol_cloudRegion', utils.getNodeText1(request, 'aic-cloud-region'))\r
 \r
-               try {\r
-                       // Catalog DB headers Authorization\r
-                       String basicAuthValueDB = execution.getVariable("URN_mso_adapters_db_auth")\r
-                       utils.log("DEBUG", " Obtained BasicAuth userid password for Catalog DB adapter: " + basicAuthValueDB, isDebugLogEnabled)\r
-                       \r
-                       def encodedString = utils.getBasicAuth(basicAuthValueDB, execution.getVariable("URN_mso_msoKey"))\r
-                       execution.setVariable("BasicAuthHeaderValueDB",encodedString)\r
-               } catch (IOException ex) {\r
-                       String dataErrorMessage = " Unable to encode Catalog DB user/password string - " + ex.getMessage()\r
-                       utils.log("DEBUG", dataErrorMessage, isDebugLogEnabled)\r
-                       exceptionUtil.buildAndThrowWorkflowException(execution, 2500, dataErrorMessage)\r
-               }\r
+               setBasicDBAuthHeader(execution, isDebugLogEnabled)\r
                \r
                logDebug('Request: ' + createVolumeIncoming, isDebugLogEnabled)\r
        }\r
 \r
-       public void sendSyncResponse (Execution execution, isDebugEnabled) {\r
+       public void sendSyncResponse (DelegateExecution execution, isDebugEnabled) {\r
 \r
                String volumeRequest = execution.getVariable("DELVfModVol_volumeRequest")\r
                utils.log("DEBUG", " DELVfModVol_volumeRequest - " + "\n" + volumeRequest, isDebugEnabled)\r
@@ -180,7 +169,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void sendSyncError (Execution execution, isDebugEnabled) {\r
+       public void sendSyncError (DelegateExecution execution, isDebugEnabled) {\r
                WorkflowException we = execution.getVariable('WorkflowException')\r
                def errorCode = we?.getErrorCode()\r
                def errorMessage = we?.getErrorMessage()\r
@@ -189,7 +178,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void callRESTQueryAAICloudRegion (Execution execution, isDebugEnabled) {\r
+       public void callRESTQueryAAICloudRegion (DelegateExecution execution, isDebugEnabled) {\r
 \r
                String cloudRegion = execution.getVariable('DELVfModVol_cloudRegion')\r
 \r
@@ -227,7 +216,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
         * Query volume group by id\r
         * @param execution\r
         */\r
-       public void queryAAIForVolumeGroup(Execution execution, isDebugLogEnabled) {\r
+       public void queryAAIForVolumeGroup(DelegateExecution execution, isDebugLogEnabled) {\r
 \r
                ExceptionUtil exceptionUtil = new ExceptionUtil()\r
 \r
@@ -354,7 +343,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
                return false\r
        }\r
 \r
-       public void prepareVnfAdapterDeleteRequest(Execution execution, isDebugLogEnabled) {\r
+       public void prepareVnfAdapterDeleteRequest(DelegateExecution execution, isDebugLogEnabled) {\r
                def cloudRegion = execution.getVariable('DELVfModVol_cloudRegion')\r
                def tenantId = execution.getVariable('DELVfModVol_tenantId')\r
                def volumeGroupId = execution.getVariable('DELVfModVol_volumeGroupId')\r
@@ -390,7 +379,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void deleteVolGrpId(Execution execution, isDebugEnabled) {\r
+       public void deleteVolGrpId(DelegateExecution execution, isDebugEnabled) {\r
 \r
                // get variables\r
                String queryAAIVolGrpIdResponse = execution.getVariable("DELVfModVol_queryAAIVolGrpResponse")\r
@@ -433,10 +422,10 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void prepareDBRequest (Execution execution, isDebugLogEnabled) {\r
+       public void prepareDBRequest (DelegateExecution execution, isDebugLogEnabled) {\r
 \r
                WorkflowException workflowExceptionObj = execution.getVariable("WorkflowException")\r
-\r
+               ExceptionUtil exceptionUtil = new ExceptionUtil();\r
                def requestId = execution.getVariable('DELVfModVol_requestId')\r
                def volOutputs = execution.getVariable('DELVfModVol_volumeOutputs')\r
                def statusMessage = "VolumeGroup successfully deleted"\r
@@ -450,7 +439,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
                        requestStatus = "FAILURE"\r
                        progress = ""\r
                }\r
-\r
+               \r
                String updateInfraRequest = """\r
                        <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"\r
                                        xmlns:req="http://org.openecomp.mso/requestsdb">\r
@@ -475,7 +464,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
        }\r
 \r
 \r
-       public void prepareCompletionHandlerRequest (Execution execution, isDebugLogEnabled) {\r
+       public void prepareCompletionHandlerRequest (DelegateExecution execution, isDebugLogEnabled) {\r
                def requestId = execution.getVariable("mso-request-id")\r
                def source = execution.getVariable("DELVfModVol_source")\r
 \r
@@ -499,7 +488,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
 \r
 \r
 \r
-       public void prepareFalloutHandler (Execution execution, isDebugEnabled) {\r
+       public void prepareFalloutHandler (DelegateExecution execution, isDebugEnabled) {\r
 \r
                execution.setVariable("DELVfModVol_Success", false)\r
                String requestId = execution.getVariable("DELVfModVol_requestId")\r
@@ -540,7 +529,7 @@ public class DeleteVfModuleVolumeInfraV1 extends AbstractServiceTaskProcessor {
         *\r
         * @param execution The flow's execution instance.\r
         */\r
-       public void handleTenantIdMismatch(Execution execution, isDebugLogEnabled) {\r
+       public void handleTenantIdMismatch(DelegateExecution execution, isDebugLogEnabled) {\r
 \r
                def volumeGroupId = execution.getVariable('DELVfModVol_volumeGroupId')\r
                def aicCloudRegion = execution.getVariable('DELVfModVol_aicCloudRegion')\r