bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/DoDeleteE2EServiceInstance.groovy

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2018 Huawei Technologies Co., Ltd. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.openecomp.mso.bpmn.infrastructure.scripts
  21
  22 import org.apache.http.HttpResponse
  23 import org.json.JSONArray
  24 import org.openecomp.mso.bpmn.common.recipe.BpmnRestClient
  25 import org.openecomp.mso.bpmn.common.recipe.ResourceInput
  26 import org.openecomp.mso.bpmn.core.domain.ServiceDecomposition;
  27
  28 import static org.apache.commons.lang3.StringUtils.*;
  29 import groovy.xml.XmlUtil
  30 import groovy.json.*
  31
  32 import org.openecomp.mso.bpmn.core.domain.ModelInfo
  33 import org.openecomp.mso.bpmn.core.domain.Resource
  34 import org.openecomp.mso.bpmn.core.domain.ServiceInstance
  35 import org.openecomp.mso.bpmn.core.json.JsonUtils
  36 import org.openecomp.mso.bpmn.common.scripts.AbstractServiceTaskProcessor
  37 import org.openecomp.mso.bpmn.common.scripts.ExceptionUtil
  38 import org.openecomp.mso.bpmn.common.scripts.SDNCAdapterUtils
  39 import org.openecomp.mso.bpmn.core.WorkflowException
  40 import org.openecomp.mso.rest.APIResponse;
  41 import org.openecomp.mso.rest.RESTClient
  42 import org.openecomp.mso.rest.RESTConfig
  43
  44 import java.util.List;
  45 import java.util.UUID;
  46 import javax.xml.parsers.DocumentBuilder
  47 import javax.xml.parsers.DocumentBuilderFactory
  48
  49 import org.camunda.bpm.engine.delegate.BpmnError
  50 import org.camunda.bpm.engine.delegate.DelegateExecution
  51 import org.camunda.bpm.engine.runtime.Execution
  52 import org.json.JSONObject;
  53 import org.apache.commons.lang3.*
  54 import org.apache.commons.codec.binary.Base64;
  55 import org.springframework.web.util.UriUtils;
  56 import org.w3c.dom.Document
  57 import org.w3c.dom.Element
  58 import org.w3c.dom.Node
  59 import org.w3c.dom.NodeList
  60 import org.xml.sax.InputSource
  61
  62 import com.fasterxml.jackson.jaxrs.json.annotation.JSONP.Def;
  63
  64 /**
  65  * This groovy class supports the <class>DoDeleteE2EServiceInstance.bpmn</class> process.
  66  *
  67  * Inputs:
  68  * @param - msoRequestId
  69  * @param - globalSubscriberId - O
  70  * @param - subscriptionServiceType - O
  71  * @param - serviceInstanceId
  72  * @param - serviceInstanceName - O
  73  * @param - serviceInputParams (should contain aic_zone for serviceTypes TRANSPORT,ATM)
  74  * @param - sdncVersion
  75  * @param - failNotFound - TODO
  76  * @param - serviceInputParams - TODO
  77  *
  78  * @param - delResourceList
  79  * @param - serviceRelationShip
  80  *
  81  * Outputs:
  82  * @param - WorkflowException
  83  *
  84  * Rollback - Deferred
  85  */
  86 public class DoDeleteE2EServiceInstance extends AbstractServiceTaskProcessor {
  87
  88         String Prefix="DDEESI_"
  89     ExceptionUtil exceptionUtil = new ExceptionUtil()
  90     JsonUtils jsonUtil = new JsonUtils()
  91
  92     public void preProcessRequest (DelegateExecution execution) {
  93         def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
  94         utils.log("INFO"," ***** preProcessRequest *****",  isDebugEnabled)
  95         String msg = ""
  96
  97         try {
  98             String requestId = execution.getVariable("msoRequestId")
  99             execution.setVariable("prefix",Prefix)
 100
 101             //Inputs
 102             //requestDetails.subscriberInfo. for AAI GET & PUT & SDNC assignToplology
 103             String globalSubscriberId = execution.getVariable("globalSubscriberId") //globalCustomerId
 104             if (globalSubscriberId == null)
 105             {
 106                 execution.setVariable("globalSubscriberId", "")
 107             }
 108
 109             //requestDetails.requestParameters. for AAI PUT & SDNC assignTopology
 110             String serviceType = execution.getVariable("serviceType")
 111             if (serviceType == null)
 112             {
 113                 execution.setVariable("serviceType", "")
 114             }
 115
 116             //Generated in parent for AAI PUT
 117             String serviceInstanceId = execution.getVariable("serviceInstanceId")
 118             if (isBlank(serviceInstanceId)){
 119                 msg = "Input serviceInstanceId is null"
 120                 utils.log("INFO", msg, isDebugEnabled)
 121                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 122             }
 123
 124             String sdncCallbackUrl = execution.getVariable('URN_mso_workflow_sdncadapter_callback')
 125             if (isBlank(sdncCallbackUrl)) {
 126                 msg = "URN_mso_workflow_sdncadapter_callback is null"
 127                 utils.log("INFO", msg, isDebugEnabled)
 128                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 129             }
 130             execution.setVariable("sdncCallbackUrl", sdncCallbackUrl)
 131             utils.log("INFO","SDNC Callback URL: " + sdncCallbackUrl, isDebugEnabled)
 132
 133             StringBuilder sbParams = new StringBuilder()
 134             Map<String, String> paramsMap = execution.getVariable("serviceInputParams")
 135             if (paramsMap != null)
 136             {
 137                 sbParams.append("<service-input-parameters>")
 138                 for (Map.Entry<String, String> entry : paramsMap.entrySet()) {
 139                     String paramsXml
 140                     String paramName = entry.getKey()
 141                     String paramValue = entry.getValue()
 142                     paramsXml =
 143                             """ <param>
 144                                                         <name>${paramName}</name>
 145                                                         <value>${paramValue}</value>
 146                                                         </param>
 147                                                         """
 148                     sbParams.append(paramsXml)
 149                 }
 150                 sbParams.append("</service-input-parameters>")
 151             }
 152             String siParamsXml = sbParams.toString()
 153             if (siParamsXml == null)
 154                 siParamsXml = ""
 155             execution.setVariable("siParamsXml", siParamsXml)
 156
 157         } catch (BpmnError e) {
 158             throw e;
 159         } catch (Exception ex){
 160             msg = "Exception in preProcessRequest " + ex.getMessage()
 161             utils.log("INFO", msg, isDebugEnabled)
 162             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 163         }
 164         utils.log("INFO"," ***** Exit preProcessRequest *****",  isDebugEnabled)
 165     }
 166
 167     public void postProcessAAIGET(DelegateExecution execution) {
 168         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 169         utils.log("INFO"," ***** postProcessAAIGET ***** ", isDebugEnabled)
 170         String msg = ""
 171
 172         try {
 173             String serviceInstanceId = execution.getVariable("serviceInstanceId")
 174             boolean foundInAAI = execution.getVariable("GENGS_FoundIndicator")
 175             String serviceType = ""
 176
 177             if(foundInAAI){
 178                 utils.log("INFO","Found Service-instance in AAI", isDebugEnabled)
 179
 180                 String siData = execution.getVariable("GENGS_service")
 181                 utils.log("INFO", "SI Data", isDebugEnabled)
 182                 if (isBlank(siData))
 183                 {
 184                     msg = "Could not retrive ServiceInstance data from AAI to delete id:" + serviceInstanceId
 185                     utils.log("INFO", msg, isDebugEnabled)
 186                     exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 187                 }
 188                 else
 189                 {
 190                     InputSource source = new InputSource(new StringReader(siData));
 191                     DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
 192                     DocumentBuilder docBuilder = docFactory.newDocumentBuilder()
 193                     Document serviceXml = docBuilder.parse(source)
 194                     serviceXml.getDocumentElement().normalize()
 195                     // get model invariant id
 196                     // Get Template uuid and version
 197                     if (utils.nodeExists(siData, "model-invariant-id") && utils.nodeExists(siData, "model-version-id") ) {
 198                         utils.log("INFO", "SI Data model-invariant-id and model-version-id exist:", isDebugEnabled)
 199                         def modelInvariantId  = serviceXml.getElementsByTagName("model-invariant-id").item(0).getTextContent()
 200                         def modelVersionId  = serviceXml.getElementsByTagName("model-version-id").item(0).getTextContent()
 201
 202                         // Set Original Template info
 203                         execution.setVariable("model-invariant-id-original", modelInvariantId)
 204                         execution.setVariable("model-version-id-original", modelVersionId)
 205                     }
 206
 207                     utils.log("INFO", "SI Data" + siData, isDebugEnabled)
 208                     //Confirm there are no related service instances (vnf/network or volume)
 209                     if (utils.nodeExists(siData, "relationship-list")) {
 210                         utils.log("INFO", "SI Data relationship-list exists:", isDebugEnabled)
 211                         //test(siData)
 212                         NodeList nodeList = serviceXml.getElementsByTagName("relationship").item(0).getChildNodes()
 213                         JSONArray jArray = new JSONArray()
 214                         for (int x = 0; x < nodeList.getLength(); x++) {
 215                             Node node = nodeList.item(x)
 216                             if (node.getNodeType() == Node.ELEMENT_NODE) {
 217                                 Element eElement = (Element) node
 218                                 def e = eElement.getElementsByTagName("related-to").item(0).getTextContent()                                                                    //for ns
 219                                 if(e.equals("service-instance")){
 220                                     def relatedObject = eElement.getElementsByTagName("related-link").item(0).getTextContent()
 221                                     utils.log("INFO", "ServiceInstance Related NS :" + relatedObject, isDebugEnabled)
 222                                     NodeList dataList = node.getChildNodes()
 223                                     if(null != dataList) {
 224                                         JSONObject jObj = new JSONObject()
 225                                         for (int i = 0; i < dataList.getLength(); i++) {
 226                                             Node dNode = dataList.item(i)
 227                                             if(dNode.getNodeName() == "relationship-data") {
 228
 229                                                 NodeList rdNodes = dNode.getChildNodes()
 230                                                 for(int j = 0; j < rdNodes.getLength(); j++) {
 231                                                     Node rdNode = rdNodes.item(j);
 232                                                     if (rdNode instanceof Element) {
 233                                                         Element rDataEle = (Element) rdNode
 234                                                         def eKey = rDataEle.getElementsByTagName("relationship-key").item(0).getTextContent()
 235                                                         def eValue = rDataEle.getElementsByTagName("relationship-value").item(0).getTextContent()
 236                                                         if (eKey.equals("service-instance.service-instance-id")) {
 237                                                             jObj.put("resourceInstanceId", eValue)
 238                                                         }
 239                                                     }
 240                                                 }
 241
 242                                             }
 243                                             else if(dNode.getNodeName() == "related-to-property"){
 244                                                 Element rDataEle = (Element)dNode
 245                                                 def eKey =  rDataEle.getElementsByTagName("property-key").item(0).getTextContent()
 246                                                 def eValue = rDataEle.getElementsByTagName("property-value").item(0).getTextContent()
 247                                                 if(eKey.equals("service-instance.service-instance-name")){
 248                                                     jObj.put("resourceType", eValue)
 249                                                 }
 250                                             }
 251                                         }
 252                                         utils.log("INFO", "Relationship related to Resource:" + jObj.toString(), isDebugEnabled)
 253                                         jArray.put(jObj)
 254                                     }
 255                                     //for overlay/underlay
 256                                 }else if (e.equals("configuration")){
 257                                     def relatedObject = eElement.getElementsByTagName("related-link").item(0).getTextContent()
 258                                     utils.log("INFO", "ServiceInstance Related Configuration :" + relatedObject, isDebugEnabled)
 259                                     NodeList dataList = node.getChildNodes()
 260                                     if(null != dataList) {
 261                                         JSONObject jObj = new JSONObject()
 262                                         for (int i = 0; i < dataList.getLength(); i++) {
 263                                             Node dNode = dataList.item(i)
 264                                             if(dNode.getNodeName() == "relationship-data") {
 265                                                 Element rDataEle = (Element)dNode
 266                                                 def eKey =  rDataEle.getElementsByTagName("relationship-key").item(0).getTextContent()
 267                                                 def eValue = rDataEle.getElementsByTagName("relationship-value").item(0).getTextContent()
 268                                                 if(eKey.equals("configuration.configuration-id")){
 269                                                     jObj.put("resourceInstanceId", eValue)
 270                                                 }
 271                                             }
 272                                             else if(dNode.getNodeName() == "related-to-property"){
 273                                                 Element rDataEle = (Element)dNode
 274                                                 def eKey =  rDataEle.getElementsByTagName("property-key").item(0).getTextContent()
 275                                                 def eValue = rDataEle.getElementsByTagName("property-value").item(0).getTextContent()
 276                                                 if(eKey.equals("configuration.configuration-type")){
 277                                                     jObj.put("resourceType", eValue)
 278                                                 }
 279                                             }
 280                                         }
 281                                         utils.log("INFO", "Relationship related to Resource:" + jObj.toString(), isDebugEnabled)
 282                                         jArray.put(jObj)
 283                                     }
 284                                 }
 285                             }
 286                         }
 287                         execution.setVariable("serviceRelationShip", jArray.toString())
 288                     }
 289                 }
 290             }else{
 291                 boolean succInAAI = execution.getVariable("GENGS_SuccessIndicator")
 292                 if(!succInAAI){
 293                     utils.log("INFO","Error getting Service-instance from AAI", + serviceInstanceId, isDebugEnabled)
 294                     WorkflowException workflowException = execution.getVariable("WorkflowException")
 295                     utils.logAudit("workflowException: " + workflowException)
 296                     if(workflowException != null){
 297                         exceptionUtil.buildAndThrowWorkflowException(execution, workflowException.getErrorCode(), workflowException.getErrorMessage())
 298                     }
 299                     else
 300                     {
 301                         msg = "Failure in postProcessAAIGET GENGS_SuccessIndicator:" + succInAAI
 302                         utils.log("INFO", msg, isDebugEnabled)
 303                         exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg)
 304                     }
 305                 }
 306
 307                 utils.log("INFO","Service-instance NOT found in AAI. Silent Success", isDebugEnabled)
 308             }
 309         }catch (BpmnError e) {
 310             throw e;
 311         } catch (Exception ex) {
 312             msg = "Exception in DoDeleteE2EServiceInstance.postProcessAAIGET. " + ex.getMessage()
 313             utils.log("INFO", msg, isDebugEnabled)
 314             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 315         }
 316         utils.log("INFO"," *** Exit postProcessAAIGET *** ", isDebugEnabled)
 317     }
 318
 319    public void getCurrentNS(DelegateExecution execution){
 320        def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 321        utils.log("INFO", "======== Start getCurrentNS Process ======== ", isDebugEnabled)
 322
 323        def currentIndex = execution.getVariable("currentNSIndex")
 324        List<String> nsSequence = execution.getVariable("nsSequence")
 325        String nsResourceType =  nsSequence.get(currentIndex)
 326
 327        // GET AAI by Name, not ID, for process convenient
 328        execution.setVariable("GENGS_type", "service-instance")
 329        execution.setVariable("GENGS_serviceInstanceId", "")
 330        execution.setVariable("GENGS_serviceInstanceName", nsResourceType)
 331
 332        utils.log("INFO", "======== COMPLETED getCurrentNS Process ======== ", isDebugEnabled)
 333    }
 334
 335     public void prepareDecomposeService(DelegateExecution execution) {
 336         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 337
 338         try {
 339             utils.log("DEBUG", " ***** Inside prepareDecomposeService of create generic e2e service ***** ", isDebugEnabled)
 340             String modelInvariantUuid = execution.getVariable("model-invariant-id-original")
 341             String modelVersionId = execution.getVariable("model-version-id-original")
 342             //here modelVersion is not set, we use modelUuid to decompose the service.
 343             String serviceModelInfo = """{
 344             "modelInvariantUuid":"${modelInvariantUuid}",
 345             "modelUuid":"",
 346             "modelVersion":"${modelVersionId}"
 347              }"""
 348             execution.setVariable("serviceModelInfo", serviceModelInfo)
 349
 350             utils.log("DEBUG", " ***** Completed prepareDecomposeService of  create generic e2e service ***** ", isDebugEnabled)
 351         } catch (Exception ex) {
 352             // try error in method block
 353             String exceptionMessage = "Bpmn error encountered in  create generic e2e service flow. Unexpected Error from method prepareDecomposeService() - " + ex.getMessage()
 354             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)
 355         }
 356     }
 357
 358     public void postDecomposeService(DelegateExecution execution) {
 359         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 360
 361         utils.log("DEBUG", " ***** Inside processDecomposition() of  delete generic e2e service flow ***** ", isDebugEnabled)
 362         try {
 363             ServiceDecomposition serviceDecomposition = execution.getVariable("serviceDecomposition")
 364             List<Resource> deleteResourceList = serviceDecomposition.getServiceResources()
 365             execution.setVariable("deleteResourceList", deleteResourceList)
 366             execution.setVariable("resourceInstanceIDs", execution.getVariable("serviceRelationShip"))
 367         } catch (Exception ex) {
 368             String exceptionMessage = "Bpmn error encountered in  create generic e2e service flow. processDecomposition() - " + ex.getMessage()
 369             utils.log("DEBUG", exceptionMessage, isDebugEnabled)
 370             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)
 371         }
 372         utils.log("DEBUG", " ***** exit processDecomposition() of  delete generic e2e service flow ***** ", isDebugEnabled)
 373     }
 374
 375     public void preInitResourcesOperStatus(DelegateExecution execution){
 376         def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
 377
 378         utils.log("INFO", " ======== STARTED preInitResourcesOperStatus Process ======== ", isDebugEnabled)
 379         try{
 380             String serviceId = execution.getVariable("serviceInstanceId")
 381             String operationId = execution.getVariable("operationId")
 382             String operationType = execution.getVariable("operationType")
 383             String resourceTemplateUUIDs = ""
 384             String result = "processing"
 385             String progress = "0"
 386             String reason = ""
 387             String operationContent = "Prepare service creation"
 388             utils.log("INFO", "Generated new operation for Service Instance serviceId:" + serviceId + " operationId:" + operationId + " operationType:" + operationType, isDebugEnabled)
 389             serviceId = UriUtils.encode(serviceId,"UTF-8")
 390             execution.setVariable("serviceInstanceId", serviceId)
 391             execution.setVariable("operationId", operationId)
 392             execution.setVariable("operationType", operationType)
 393
 394             String serviceRelationShip = execution.getVariable("serviceRelationShip")
 395
 396             def jsonSlurper = new JsonSlurper()
 397             def jsonOutput = new JsonOutput()
 398             List relationShipList =  jsonSlurper.parseText(serviceRelationShip)
 399
 400             if (relationShipList != null) {
 401                 relationShipList.each {
 402                     resourceTemplateUUIDs  = resourceTemplateUUIDs + it.resourceInstanceId + ":"
 403                 }
 404             }
 405             execution.setVariable("URN_mso_adapters_openecomp_db_endpoint","http://mso.mso.testlab.openecomp.org:8080/dbadapters/RequestsDbAdapter")
 406
 407             String payload =
 408                     """<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
 409                         xmlns:ns="http://org.openecomp.mso/requestsdb">
 410                         <soapenv:Header/>
 411                         <soapenv:Body>
 412                             <ns:initResourceOperationStatus xmlns:ns="http://org.openecomp.mso/requestsdb">
 413                             <serviceId>${serviceId}</serviceId>
 414                             <operationId>${operationId}</operationId>
 415                             <operationType>${operationType}</operationType>
 416                             <resourceTemplateUUIDs>${resourceTemplateUUIDs}</resourceTemplateUUIDs>
 417                         </ns:initResourceOperationStatus>
 418                     </soapenv:Body>
 419                 </soapenv:Envelope>"""
 420
 421             payload = utils.formatXml(payload)
 422             execution.setVariable("CVFMI_initResOperStatusRequest", payload)
 423             utils.log("INFO", "Outgoing initResourceOperationStatus: \n" + payload, isDebugEnabled)
 424             utils.logAudit("CreateVfModuleInfra Outgoing initResourceOperationStatus Request: " + payload)
 425
 426         }catch(Exception e){
 427             utils.log("ERROR", "Exception Occured Processing preInitResourcesOperStatus. Exception is:\n" + e, isDebugEnabled)
 428             execution.setVariable("CVFMI_ErrorResponse", "Error Occurred during preInitResourcesOperStatus Method:\n" + e.getMessage())
 429         }
 430         utils.log("INFO", "======== COMPLETED preInitResourcesOperStatus Process ======== ", isDebugEnabled)
 431     }
 432
 433     public void postProcessAAIDEL(DelegateExecution execution) {
 434         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 435         utils.log("INFO"," ***** postProcessAAIDEL ***** ", isDebugEnabled)
 436         String msg = ""
 437         try {
 438             String serviceInstanceId = execution.getVariable("serviceInstanceId")
 439             boolean succInAAI = execution.getVariable("GENDS_SuccessIndicator")
 440             if(!succInAAI){
 441                 msg = "Error deleting Service-instance in AAI" + serviceInstanceId
 442                 utils.log("INFO", msg, isDebugEnabled)
 443                 WorkflowException workflowException = execution.getVariable("WorkflowException")
 444                 utils.logAudit("workflowException: " + workflowException)
 445                 if(workflowException != null){
 446                     exceptionUtil.buildAndThrowWorkflowException(execution, workflowException.getErrorCode(), workflowException.getErrorMessage())
 447                 }
 448                 else
 449                 {
 450                     exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg)
 451                 }
 452             }
 453         } catch (BpmnError e) {
 454             throw e;
 455         } catch (Exception ex) {
 456             msg = "Exception in DoDeleteE2EServiceInstance.postProcessAAIDEL. " + ex.getMessage()
 457             utils.log("INFO", msg, isDebugEnabled)
 458             exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 459         }
 460         utils.log("INFO"," *** Exit postProcessAAIDEL *** ", isDebugEnabled)
 461     }
 462
 463      /**
 464       * post config request.
 465       */
 466      public void postConfigRequest(execution){
 467          //to do
 468      }
 469
 470 }
 471