bpmn/MSOCommonBPMN/src/main/groovy/org/openecomp/mso/bpmn/common/scripts/ConfirmVolumeGroupTenant.groovy

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * ONAP - SO\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package org.openecomp.mso.bpmn.common.scripts\r
  22 \r
  23 import javax.xml.parsers.DocumentBuilder\r
  24 import javax.xml.parsers.DocumentBuilderFactory\r
  25 \r
  26 import org.apache.commons.lang3.*\r
  27 import org.camunda.bpm.engine.delegate.BpmnError\r
  28 import org.camunda.bpm.engine.runtime.Execution\r
  29 import org.openecomp.mso.bpmn.core.WorkflowException\r
  30 import org.openecomp.mso.rest.APIResponse\r
  31 import org.w3c.dom.Document\r
  32 import org.w3c.dom.Element\r
  33 import org.w3c.dom.Node\r
  34 import org.w3c.dom.NodeList\r
  35 import org.xml.sax.InputSource\r
  36 \r
  37 \r
  38 /**\r
  39  * Vnf Module Subflow for confirming the volume group belongs\r
  40  * to the tenant\r
  41  *\r
  42  * @param tenantId\r
  43  * @param volumeGroupId\r
  44  *\r
  45  */\r
  46 class ConfirmVolumeGroupTenant extends AbstractServiceTaskProcessor{\r
  47 \r
  48         String Prefix="CVGT_"\r
  49         ExceptionUtil exceptionUtil = new ExceptionUtil()\r
  50 \r
  51         public void preProcessRequest(Execution execution){\r
  52                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")\r
  53                 execution.setVariable("prefix", Prefix)\r
  54                 utils.log("DEBUG", " ======== STARTED Confirm Volume Group Tenant Subflow ======== ", isDebugEnabled)\r
  55                 String processKey = getProcessKey(execution);\r
  56                 try{\r
  57                         utils.log("DEBUG", " === Started QueryAAIForVolumeGroup Process === ", isDebugEnabled)\r
  58 \r
  59                         String volumeGroupId = execution.getVariable("volumeGroupId")\r
  60                         String incomingGroupName = execution.getVariable("volumeGroupName")\r
  61                         String incomingTenantId = execution.getVariable("tenantId")\r
  62                         def aicCloudRegion = execution.getVariable("aicCloudRegion")\r
  63                         String aai = execution.getVariable("URN_aai_endpoint")\r
  64 \r
  65                         AaiUtil aaiUriUtil = new AaiUtil(this)\r
  66                         def aai_uri = aaiUriUtil.getCloudInfrastructureCloudRegionUri(execution)\r
  67                         logDebug('AAI URI is: ' + aai_uri, isDebugEnabled)\r
  68 \r
  69                         String path = aai + "${aai_uri}/${aicCloudRegion}/volume-groups/volume-group/" + volumeGroupId\r
  70 \r
  71                         APIResponse queryAAIForVolumeGroupResponse = aaiUriUtil.executeAAIGetCall(execution, path)\r
  72 \r
  73                         def responseCode = queryAAIForVolumeGroupResponse.getStatusCode()\r
  74                         execution.setVariable("queryVolumeGroupResponseCode", responseCode)\r
  75                         String response = queryAAIForVolumeGroupResponse.getResponseBodyAsString()\r
  76                         response = StringEscapeUtils.unescapeXml(response)\r
  77 \r
  78                         utils.logAudit("ConfirmVolumeGroup Response: " + response)\r
  79                         utils.logAudit("ConfirmVolumeGroup Response Code: " + responseCode)\r
  80 \r
  81                         if(responseCode == 200 && response != null){\r
  82                                 execution.setVariable("queryAAIVolumeGroupResponse", response)\r
  83                                 utils.log("DEBUG", "QueryAAIForVolumeGroup Received a Good REST Response is: \n" + response, isDebugEnabled)\r
  84 \r
  85                                 String volumeGroupTenantId = ""\r
  86                                 InputSource source = new InputSource(new StringReader(response));\r
  87                                 DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();\r
  88                                 docFactory.setNamespaceAware(true)\r
  89                                 DocumentBuilder docBuilder = docFactory.newDocumentBuilder()\r
  90                                 Document createVCERequestXml = docBuilder.parse(source)\r
  91                                 NodeList nodeList = createVCERequestXml.getElementsByTagNameNS("*", "relationship")\r
  92                                 for (int x = 0; x < nodeList.getLength(); x++) {\r
  93                                         Node node = nodeList.item(x)\r
  94                                         if (node.getNodeType() == Node.ELEMENT_NODE) {\r
  95                                                 Element eElement = (Element) node\r
  96                                                 String e = eElement.getElementsByTagNameNS("*", "related-to").item(0).getTextContent()\r
  97                                                 if(e.equals("tenant")){\r
  98                                                         NodeList relationDataList = eElement.getElementsByTagNameNS("*", "relationship-data")\r
  99                                                         for (int d = 0; d < relationDataList.getLength(); d++) {\r
 100                                                                 Node dataNode = relationDataList.item(d)\r
 101                                                                 if (dataNode.getNodeType() == Node.ELEMENT_NODE) {\r
 102                                                                         Element dElement = (Element) dataNode\r
 103                                                                         String key = dElement.getElementsByTagNameNS("*", "relationship-key").item(0).getTextContent()\r
 104                                                                         if(key.equals("tenant.tenant-id")){\r
 105                                                                                 volumeGroupTenantId = dElement.getElementsByTagNameNS("*", "relationship-value").item(0).getTextContent()\r
 106                                                                         }\r
 107                                                                 }\r
 108                                                         }\r
 109                                                 }\r
 110                                         }\r
 111                                 }\r
 112 \r
 113                                 //Determine if Tenant Ids match\r
 114                                 if(incomingTenantId.equals(volumeGroupTenantId)){\r
 115                                         utils.log("DEBUG", "Tenant Ids Match", isDebugEnabled)\r
 116                                         execution.setVariable("tenantIdsMatch", true)\r
 117                                 }else{\r
 118                                         utils.log("DEBUG", "Tenant Ids DO NOT Match", isDebugEnabled)\r
 119                                         execution.setVariable("tenantIdsMatch", false)\r
 120                                 }\r
 121 \r
 122                                 //Determine if Volume Group Names match\r
 123                                 String volumeGroupName = utils.getNodeText1(response, "volume-group-name")\r
 124                                 if(incomingGroupName == null || incomingGroupName.length() < 1){\r
 125                                         utils.log("DEBUG", "Incoming Volume Group Name is NOT Provided.", isDebugEnabled)\r
 126                                         execution.setVariable("groupNamesMatch", true)\r
 127                                 }else{\r
 128                                         utils.log("DEBUG", "Incoming Volume Group Name is: " + incomingGroupName, isDebugEnabled)\r
 129                                         if(volumeGroupName.equals(incomingGroupName)){\r
 130                                                 utils.log("DEBUG", "Volume Group Names Match.", isDebugEnabled)\r
 131                                                 execution.setVariable("groupNamesMatch", true)\r
 132                                         }else{\r
 133                                                 utils.log("DEBUG", "Volume Group Names DO NOT Match.", isDebugEnabled)\r
 134                                                 execution.setVariable("groupNamesMatch", false)\r
 135                                         }\r
 136                                 }\r
 137                         }else{\r
 138                                 utils.log("DEBUG", "QueryAAIForVolumeGroup Bad REST Response!", isDebugEnabled)\r
 139                                 exceptionUtil.buildAndThrowWorkflowException(execution, 1, "Error Searching AAI for Volume Group. Received a Bad Response.")\r
 140                         }\r
 141 \r
 142                 }catch(BpmnError b){\r
 143                         throw b\r
 144                 }catch(Exception e){\r
 145                         utils.log("ERROR", "Exception Occured Processing queryAAIForVolumeGroup. Exception is:\n" + e, isDebugEnabled)\r
 146                         exceptionUtil.buildAndThrowWorkflowException(execution, 5000, "Internal Error - Occured in preProcessRequest.")\r
 147                 }\r
 148                 utils.log("DEBUG", "=== COMPLETED queryAAIForVolumeGroup Process === ", isDebugEnabled)\r
 149         }\r
 150 \r
 151         public void assignVolumeHeatId(Execution execution){\r
 152                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")\r
 153                 execution.setVariable("prefix", Prefix)\r
 154                 try{\r
 155                         utils.log("DEBUG", " === Started assignVolumeHeatId Process === ", isDebugEnabled)\r
 156 \r
 157                         String response = execution.getVariable("queryAAIVolumeGroupResponse")\r
 158                         String heatStackId = utils.getNodeText1(response, "heat-stack-id")\r
 159                         execution.setVariable("volumeHeatStackId", heatStackId)\r
 160                         execution.setVariable("ConfirmVolumeGroupTenantResponse", heatStackId)\r
 161                         // TODO: Should deprecate use of processKey+Response variable for the response. Will use "WorkflowResponse" instead\r
 162                         execution.setVariable("WorkflowResponse", heatStackId)\r
 163                         utils.log("DEBUG", "Volume Heat Stack Id is: " + heatStackId, isDebugEnabled)\r
 164 \r
 165                 }catch(Exception e){\r
 166                 utils.log("ERROR", "Exception Occured Processing assignVolumeHeatId. Exception is:\n" + e, isDebugEnabled)\r
 167                 exceptionUtil.buildAndThrowWorkflowException(execution, 5000, "Internal Error - Occured in assignVolumeHeatId.")\r
 168         }\r
 169         utils.log("DEBUG", "=== COMPLETED assignVolumeHeatId Process === ", isDebugEnabled)\r
 170         utils.log("DEBUG", "======== COMPLETED Confirm Volume Group Tenant Subflow ======== ", isDebugEnabled)\r
 171 }\r
 172 \r
 173         public void assignWorkflowException(Execution execution, String message){\r
 174                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")\r
 175                 execution.setVariable("prefix", Prefix)\r
 176                 String processKey = getProcessKey(execution);\r
 177                 utils.log("DEBUG", " === STARTED Assign Workflow Exception === ", isDebugEnabled)\r
 178                 try{\r
 179                         String volumeGroupId = execution.getVariable("volumeGroupId")\r
 180                         int errorCode = 1\r
 181                         String errorMessage = "Volume Group " + volumeGroupId + " " + message\r
 182 \r
 183                         exceptionUtil.buildWorkflowException(execution, errorCode, errorMessage)\r
 184                 }catch(Exception e){\r
 185                         utils.log("ERROR", "Exception Occured Processing assignWorkflowException. Exception is:\n" + e, isDebugEnabled)\r
 186                 }\r
 187                 utils.log("DEBUG", "=== COMPLETED Assign Workflow Exception ==== ", isDebugEnabled)\r
 188         }\r
 189 \r
 190 \r
 191 \r
 192 }\r
 193 \r