gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
   7  * ================================================================================
   8  * Modifications Copyright (c) 2019 Samsung
   9  * ================================================================================
  10  * Licensed under the Apache License, Version 2.0 (the "License");
  11  * you may not use this file except in compliance with the License.
  12  * You may obtain a copy of the License at
  13  *
  14  *      http://www.apache.org/licenses/LICENSE-2.0
  15  *
  16  * Unless required by applicable law or agreed to in writing, software
  17  * distributed under the License is distributed on an "AS IS" BASIS,
  18  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  19  * See the License for the specific language governing permissions and
  20  * limitations under the License.
  21  * ============LICENSE_END=========================================================
  22  */
  23 package org.onap.so.bpmn.infrastructure.scripts
  24
  25 import org.onap.so.logger.LoggingAnchor
  26 import org.onap.so.logger.ErrorCode
  27
  28 import static org.apache.commons.lang3.StringUtils.*;
  29
  30 import javax.xml.parsers.DocumentBuilder
  31 import javax.xml.parsers.DocumentBuilderFactory
  32
  33 import org.apache.commons.lang3.*
  34 import org.camunda.bpm.engine.delegate.BpmnError
  35 import org.camunda.bpm.engine.delegate.DelegateExecution
  36 import org.json.JSONArray;
  37 import org.json.JSONObject;
  38 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
  39 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  40 import org.onap.so.bpmn.common.scripts.MsoUtils
  41 import org.onap.so.bpmn.core.UrnPropertiesReader
  42 import org.onap.so.bpmn.core.WorkflowException
  43 import org.onap.so.bpmn.core.json.JsonUtils
  44 import org.onap.so.logger.MessageEnum
  45 import org.slf4j.Logger
  46 import org.slf4j.LoggerFactory
  47 import org.springframework.web.util.UriUtils;
  48 import org.w3c.dom.Document
  49 import org.w3c.dom.Element
  50 import org.w3c.dom.Node
  51 import org.w3c.dom.NodeList
  52 import org.xml.sax.InputSource
  53 import org.onap.so.client.aai.entities.uri.AAIResourceUri
  54 import org.onap.so.client.aai.entities.uri.AAIUriFactory
  55 import org.onap.so.client.aai.AAIObjectType
  56 import org.onap.so.client.aai.AAIResourcesClient
  57
  58 import groovy.json.*
  59
  60
  61
  62 /**
  63  * This groovy class supports the <class>DoDeleteE2EServiceInstance.bpmn</class> process.
  64  *
  65  * Inputs:
  66  * @param - msoRequestId
  67  * @param - globalSubscriberId - O
  68  * @param - subscriptionServiceType - O
  69  * @param - serviceInstanceId
  70  * @param - serviceInstanceName - O
  71  * @param - serviceInputParams (should contain aic_zone for serviceTypes TRANSPORT,ATM)
  72  * @param - sdncVersion
  73  * @param - failNotFound - TODO
  74  * @param - serviceInputParams - TODO
  75  *
  76  * Outputs:
  77  * @param - WorkflowException
  78  *
  79  * Rollback - Deferred
  80  */
  81 public class DoCustomDeleteE2EServiceInstance extends AbstractServiceTaskProcessor {
  82     private static final Logger logger = LoggerFactory.getLogger( DoCustomDeleteE2EServiceInstance.class);
  83
  84
  85         String Prefix="DDELSI_"
  86         ExceptionUtil exceptionUtil = new ExceptionUtil()
  87         JsonUtils jsonUtil = new JsonUtils()
  88
  89         public void preProcessRequest (DelegateExecution execution) {
  90                 logger.trace("preProcessRequest ")
  91                 String msg = ""
  92
  93                 try {
  94                         String requestId = execution.getVariable("msoRequestId")
  95                         execution.setVariable("prefix",Prefix)
  96
  97                         //Inputs
  98                         //requestDetails.subscriberInfo. for AAI GET & PUT & SDNC assignToplology
  99                         String globalSubscriberId = execution.getVariable("globalSubscriberId") //globalCustomerId
 100                         if (globalSubscriberId == null)
 101                         {
 102                                 execution.setVariable("globalSubscriberId", "")
 103                         }
 104
 105                         //requestDetails.requestParameters. for AAI PUT & SDNC assignTopology
 106                         String serviceType = execution.getVariable("serviceType")
 107                         if (serviceType == null)
 108                         {
 109                                 execution.setVariable("serviceType", "")
 110                         }
 111
 112                         //Generated in parent for AAI PUT
 113                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 114                         if (isBlank(serviceInstanceId)){
 115                                 msg = "Input serviceInstanceId is null"
 116                                 logger.info(msg)
 117                                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 118                         }
 119
 120                         String sdncCallbackUrl = UrnPropertiesReader.getVariable('mso.workflow.sdncadapter.callback',execution)
 121                         if (isBlank(sdncCallbackUrl)) {
 122                                 msg = "URN_mso_workflow_sdncadapter_callback is null"
 123                                 logger.info(msg)
 124                                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 125                         }
 126                         execution.setVariable("sdncCallbackUrl", sdncCallbackUrl)
 127                         logger.info("SDNC Callback URL: " + sdncCallbackUrl)
 128
 129                         StringBuilder sbParams = new StringBuilder()
 130                         Map<String, String> paramsMap = execution.getVariable("serviceInputParams")
 131                         if (paramsMap != null)
 132                         {
 133                                 sbParams.append("<service-input-parameters>")
 134                                 for (Map.Entry<String, String> entry : paramsMap.entrySet()) {
 135                                         String paramsXml
 136                                         String paramName = entry.getKey()
 137                                         String paramValue = entry.getValue()
 138                                         paramsXml =
 139                                                         """     <param>
 140                                                         <name>${MsoUtils.xmlEscape(paramName)}</name>
 141                                                         <value>${MsoUtils.xmlEscape(paramValue)}</value>
 142                                                         </param>
 143                                                         """
 144                                         sbParams.append(paramsXml)
 145                                 }
 146                                 sbParams.append("</service-input-parameters>")
 147                         }
 148                         String siParamsXml = sbParams.toString()
 149                         if (siParamsXml == null)
 150                                 siParamsXml = ""
 151                         execution.setVariable("siParamsXml", siParamsXml)
 152
 153                 } catch (BpmnError e) {
 154                         throw e;
 155                 } catch (Exception ex){
 156                         msg = "Exception in preProcessRequest " + ex.getMessage()
 157                         logger.info(msg)
 158                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 159                 }
 160                 logger.trace("Exit preProcessRequest ")
 161         }
 162
 163
 164         public void preProcessVFCDelete (DelegateExecution execution) {
 165         }
 166
 167         public void postProcessVFCDelete(DelegateExecution execution, String response, String method) {
 168         }
 169
 170         public void preProcessSDNCDelete (DelegateExecution execution) {
 171                 logger.trace("preProcessSDNCDelete ")
 172                 String msg = ""
 173
 174                 try {
 175                         def serviceInstanceId = execution.getVariable("serviceInstanceId")
 176                         def serviceInstanceName = execution.getVariable("serviceInstanceName")
 177                         def callbackURL = execution.getVariable("sdncCallbackUrl")
 178                         def requestId = execution.getVariable("msoRequestId")
 179                         def serviceId = execution.getVariable("productFamilyId")
 180                         def subscriptionServiceType = execution.getVariable("subscriptionServiceType")
 181                         def globalSubscriberId = execution.getVariable("globalSubscriberId") //globalCustomerId
 182
 183                         String serviceModelInfo = execution.getVariable("serviceModelInfo")
 184                         def modelInvariantUuid = ""
 185                         def modelVersion = ""
 186                         def modelUuid = ""
 187                         def modelName = ""
 188                         if (!isBlank(serviceModelInfo))
 189                         {
 190                                 modelInvariantUuid = jsonUtil.getJsonValue(serviceModelInfo, "modelInvariantUuid")
 191                                 modelVersion = jsonUtil.getJsonValue(serviceModelInfo, "modelVersion")
 192                                 modelUuid = jsonUtil.getJsonValue(serviceModelInfo, "modelUuid")
 193                                 modelName = jsonUtil.getJsonValue(serviceModelInfo, "modelName")
 194
 195                                 if (modelInvariantUuid == null) {
 196                                         modelInvariantUuid = ""
 197                                 }
 198                                 if (modelVersion == null) {
 199                                         modelVersion = ""
 200                                 }
 201                                 if (modelUuid == null) {
 202                                         modelUuid = ""
 203                                 }
 204                                 if (modelName == null) {
 205                                         modelName = ""
 206                                 }
 207                         }
 208                         if (serviceInstanceName == null) {
 209                                 serviceInstanceName = ""
 210                         }
 211                         if (serviceId == null) {
 212                                 serviceId = ""
 213                         }
 214
 215                         def siParamsXml = execution.getVariable("siParamsXml")
 216                         def serviceType = execution.getVariable("serviceType")
 217                         if (serviceType == null)
 218                         {
 219                                 serviceType = ""
 220                         }
 221
 222                         def sdncRequestId = UUID.randomUUID().toString()
 223
 224                         String sdncDelete =
 225                                         """<sdncadapterworkflow:SDNCAdapterWorkflowRequest xmlns:ns5="http://org.onap/so/request/types/v1"
 226                                                                                                         xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1"
 227                                                                                                         xmlns:sdncadapter="http://org.onap/workflow/sdnc/adapter/schema/v1">
 228                                    <sdncadapter:RequestHeader>
 229                                                         <sdncadapter:RequestId>${MsoUtils.xmlEscape(sdncRequestId)}</sdncadapter:RequestId>
 230                                                         <sdncadapter:SvcInstanceId>${MsoUtils.xmlEscape(serviceInstanceId)}</sdncadapter:SvcInstanceId>
 231                                                         <sdncadapter:SvcAction>delete</sdncadapter:SvcAction>
 232                                                         <sdncadapter:SvcOperation>service-topology-operation</sdncadapter:SvcOperation>
 233                                                         <sdncadapter:CallbackUrl>${MsoUtils.xmlEscape(callbackURL)}</sdncadapter:CallbackUrl>
 234                                                         <sdncadapter:MsoAction>${MsoUtils.xmlEscape(serviceType)}</sdncadapter:MsoAction>
 235                                         </sdncadapter:RequestHeader>
 236                                 <sdncadapterworkflow:SDNCRequestData>
 237                                         <request-information>
 238                                                 <request-id>${MsoUtils.xmlEscape(requestId)}</request-id>
 239                                                 <source>MSO</source>
 240                                                 <notification-url/>
 241                                                 <order-number/>
 242                                                 <order-version/>
 243                                                 <request-action>DeleteServiceInstance</request-action>
 244                                         </request-information>
 245                                         <service-information>
 246                                                 <service-id>${MsoUtils.xmlEscape(serviceId)}</service-id>
 247                                                 <subscription-service-type>${MsoUtils.xmlEscape(subscriptionServiceType)}</subscription-service-type>
 248                                                 <onap-model-information>
 249                                                  <model-invariant-uuid>${MsoUtils.xmlEscape(modelInvariantUuid)}</model-invariant-uuid>
 250                                                  <model-uuid>${MsoUtils.xmlEscape(modelUuid)}</model-uuid>
 251                                                  <model-version>${MsoUtils.xmlEscape(modelVersion)}</model-version>
 252                                                  <model-name>${MsoUtils.xmlEscape(modelName)}</model-name>
 253                                             </onap-model-information>
 254                                                 <service-instance-id>${MsoUtils.xmlEscape(serviceInstanceId)}</service-instance-id>
 255                                                 <subscriber-name/>
 256                                                 <global-customer-id>${MsoUtils.xmlEscape(globalSubscriberId)}</global-customer-id>
 257                                         </service-information>
 258                                         <service-request-input>
 259                                                 <service-instance-name>${MsoUtils.xmlEscape(serviceInstanceName)}</service-instance-name>
 260                                                 ${siParamsXml}
 261                                         </service-request-input>
 262                                 </sdncadapterworkflow:SDNCRequestData>
 263                                 </sdncadapterworkflow:SDNCAdapterWorkflowRequest>"""
 264
 265                         sdncDelete = utils.formatXml(sdncDelete)
 266                         def sdncRequestId2 = UUID.randomUUID().toString()
 267                         String sdncDeactivate = sdncDelete.replace(">delete<", ">deactivate<").replace(">${sdncRequestId}<", ">${sdncRequestId2}<")
 268                         execution.setVariable("sdncDelete", sdncDelete)
 269                         execution.setVariable("sdncDeactivate", sdncDeactivate)
 270                         logger.info("sdncDeactivate:\n" + sdncDeactivate)
 271                         logger.info("sdncDelete:\n" + sdncDelete)
 272
 273                 } catch (BpmnError e) {
 274                         throw e;
 275                 } catch(Exception ex) {
 276                         msg = "Exception in preProcessSDNCDelete. " + ex.getMessage()
 277                         logger.info(msg)
 278                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, "Exception Occured in preProcessSDNCDelete.\n" + ex.getMessage())
 279                 }
 280                 logger.info(" *****Exit preProcessSDNCDelete *****")
 281         }
 282
 283         public void postProcessSDNCDelete(DelegateExecution execution, String response, String method) {
 284
 285                 logger.trace("postProcessSDNC " + method + " ")
 286                 String msg = ""
 287
 288                 /*try {
 289                         WorkflowException workflowException = execution.getVariable("WorkflowException")
 290                         boolean successIndicator = execution.getVariable("SDNCA_SuccessIndicator")
 291                         logger.info("SDNCResponse: " + response)
 292                         logger.info("workflowException: " + workflowException)
 293
 294                         SDNCAdapterUtils sdncAdapterUtils = new SDNCAdapterUtils(this)
 295                         sdncAdapterUtils.validateSDNCResponse(execution, response, workflowException, successIndicator)
 296                         if(execution.getVariable(Prefix + 'sdncResponseSuccess') == "true"){
 297                                 logger.info("Good response from SDNC Adapter for service-instance " + method + "response:\n" + response)
 298
 299                         }else{
 300                                 msg = "Bad Response from SDNC Adapter for service-instance " + method
 301                                 logger.info(msg)
 302                                 exceptionUtil.buildAndThrowWorkflowException(execution, 3500, msg)
 303                         }
 304                 } catch (BpmnError e) {
 305                         throw e;
 306                 } catch(Exception ex) {
 307                         msg = "Exception in postProcessSDNC " + method + " Exception:" + ex.getMessage()
 308                         logger.info(msg)
 309                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 310                 }*/
 311                 logger.trace("Exit postProcessSDNC " + method + " ")
 312         }
 313
 314         public void postProcessAAIGET(DelegateExecution execution) {
 315                 logger.trace("postProcessAAIGET ")
 316                 String msg = ""
 317
 318                 try {
 319                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 320                         boolean foundInAAI = execution.getVariable("GENGS_FoundIndicator")
 321                         String serviceType = ""
 322
 323                         if(foundInAAI){
 324                                 logger.info("Found Service-instance in AAI")
 325
 326                                 String siData = execution.getVariable("GENGS_service")
 327                                 logger.info("SI Data")
 328                                 if (isBlank(siData))
 329                                 {
 330                                         msg = "Could not retrive ServiceInstance data from AAI to delete id:" + serviceInstanceId
 331                                         logger.info(msg)
 332                                         exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 333                                 }
 334                                 else
 335                                 {
 336                                         logger.info("SI Data" + siData)
 337                                         //Confirm there are no related service instances (vnf/network or volume)
 338                                         if (utils.nodeExists(siData, "relationship-list")) {
 339                                                 logger.info("SI Data relationship-list exists:")
 340                                                 InputSource source = new InputSource(new StringReader(siData));
 341                                                 DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
 342                                                 DocumentBuilder docBuilder = docFactory.newDocumentBuilder()
 343                                                 Document serviceXml = docBuilder.parse(source)
 344                                                 serviceXml.getDocumentElement().normalize()
 345                                                 //test(siData)
 346                                                 NodeList nodeList = serviceXml.getElementsByTagName("relationship")
 347                             JSONArray jArray = new JSONArray()
 348                                                 for (int x = 0; x < nodeList.getLength(); x++) {
 349                                                         Node node = nodeList.item(x)
 350                                                         if (node.getNodeType() == Node.ELEMENT_NODE) {
 351                                                                 Element eElement = (Element) node
 352                                                                 def e = eElement.getElementsByTagName("related-to").item(0).getTextContent()                                                                    //for ns
 353                                                                 if(e.equals("service-instance")){
 354                                                                     def relatedObject = eElement.getElementsByTagName("related-link").item(0).getTextContent()
 355                                                                         logger.info("ServiceInstance Related NS :" + relatedObject)
 356                                     NodeList dataList = node.getChildNodes()
 357                                     if(null != dataList) {
 358                                         JSONObject jObj = new JSONObject()
 359                                         for (int i = 0; i < dataList.getLength(); i++) {
 360                                             Node dNode = dataList.item(i)
 361                                             if(dNode.getNodeName() == "relationship-data") {
 362                                                 Element rDataEle = (Element)dNode
 363                                                 def eKey =  rDataEle.getElementsByTagName("relationship-key").item(0).getTextContent()
 364                                                 def eValue = rDataEle.getElementsByTagName("relationship-value").item(0).getTextContent()
 365                                                 if(eKey.equals("service-instance.service-instance-id")){
 366                                                     jObj.put("resourceInstanceId", eValue)
 367                                                 }
 368                                             }
 369                                             else if(dNode.getNodeName() == "related-to-property"){
 370                                                  Element rDataEle = (Element)dNode
 371                                                  def eKey =  rDataEle.getElementsByTagName("property-key").item(0).getTextContent()
 372                                                  def eValue = rDataEle.getElementsByTagName("property-value").item(0).getTextContent()
 373                                                  if(eKey.equals("service-instance.service-instance-name")){
 374                                                         jObj.put("resourceType", eValue)
 375                                                     }
 376                                             }
 377                                         }
 378                                         logger.info("Relationship related to Resource:" + jObj.toString())
 379                                         jArray.put(jObj)
 380                                     }
 381                                                         //for overlay/underlay
 382                                                                 }else if (e.equals("configuration")){
 383                                     def relatedObject = eElement.getElementsByTagName("related-link").item(0).getTextContent()
 384                                     logger.info("ServiceInstance Related Configuration :" + relatedObject)
 385                                                                         NodeList dataList = node.getChildNodes()
 386                                                                         if(null != dataList) {
 387                                                                                 JSONObject jObj = new JSONObject()
 388                                                                                 for (int i = 0; i < dataList.getLength(); i++) {
 389                                                                                         Node dNode = dataList.item(i)
 390                                                                                         if(dNode.getNodeName() == "relationship-data") {
 391                                                                                                 Element rDataEle = (Element)dNode
 392                                                                                                 def eKey =  rDataEle.getElementsByTagName("relationship-key").item(0).getTextContent()
 393                                                                                                 def eValue = rDataEle.getElementsByTagName("relationship-value").item(0).getTextContent()
 394                                                                                                 if(eKey.equals("configuration.configuration-id")){
 395                                                                                                     jObj.put("resourceInstanceId", eValue)
 396                                                                                                 }
 397                                                                                         }
 398                                                                                         else if(dNode.getNodeName() == "related-to-property"){
 399                                                      Element rDataEle = (Element)dNode
 400                                                      def eKey =  rDataEle.getElementsByTagName("property-key").item(0).getTextContent()
 401                                                      def eValue = rDataEle.getElementsByTagName("property-value").item(0).getTextContent()
 402                                                      if(eKey.equals("configuration.configuration-type")){
 403                                                             jObj.put("resourceType", eValue)
 404                                                         }
 405                                                                                         }
 406                                                                                 }
 407                                                                                 logger.info("Relationship related to Resource:" + jObj.toString())
 408                                         jArray.put(jObj)
 409                                                                         }
 410                                                                 }
 411                                                         }
 412                                                 }
 413                         execution.setVariable("serviceRelationShip", jArray.toString())
 414                                         }
 415                                 }
 416                         }else{
 417                                 boolean succInAAI = execution.getVariable("GENGS_SuccessIndicator")
 418                                 if(!succInAAI){
 419                                         logger.info("Error getting Service-instance from AAI", + serviceInstanceId)
 420                                         WorkflowException workflowException = execution.getVariable("WorkflowException")
 421                                         logger.debug("workflowException: " + workflowException)
 422                                         if(workflowException != null){
 423                                                 exceptionUtil.buildAndThrowWorkflowException(execution, workflowException.getErrorCode(), workflowException.getErrorMessage())
 424                                         }
 425                                         else
 426                                         {
 427                                                 msg = "Failure in postProcessAAIGET GENGS_SuccessIndicator:" + succInAAI
 428                                                 logger.info(msg)
 429                                                 exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg)
 430                                         }
 431                                 }
 432
 433                                 logger.info("Service-instance NOT found in AAI. Silent Success")
 434                         }
 435                 }catch (BpmnError e) {
 436                         throw e;
 437                 } catch (Exception ex) {
 438                         msg = "Exception in DoDeleteE2EServiceInstance.postProcessAAIGET. " + ex.getMessage()
 439                         logger.info(msg)
 440                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 441                 }
 442                 logger.trace("Exit postProcessAAIGET ")
 443         }
 444
 445         /**
 446          * Deletes the service instance in aai
 447          */
 448         public void deleteServiceInstance(DelegateExecution execution) {
 449                 logger.trace("Entered deleteServiceInstance")
 450                 try {
 451                         String globalCustId = execution.getVariable("globalSubscriberId")
 452                         String serviceType = execution.getVariable("serviceType")
 453                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 454
 455                         AAIResourcesClient resourceClient = new AAIResourcesClient();
 456                         AAIResourceUri serviceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, globalCustId, serviceType, serviceInstanceId)
 457                         resourceClient.delete(serviceInstanceUri)
 458
 459                         logger.trace("Exited deleteServiceInstance")
 460                 }catch(Exception e){
 461                         logger.debug("Error occured within deleteServiceInstance method: " + e)
 462                         exceptionUtil.buildAndThrowWorkflowException(execution, 2500, "Error occured during deleteServiceInstance from aai")
 463                 }
 464         }
 465
 466    public void preInitResourcesOperStatus(DelegateExecution execution){
 467         logger.trace("STARTED preInitResourcesOperStatus Process ")
 468         try{
 469             String serviceId = execution.getVariable("serviceInstanceId")
 470             String operationId = execution.getVariable("operationId")
 471             String operationType = execution.getVariable("operationType")
 472             String resourceTemplateUUIDs = ""
 473             String result = "processing"
 474             String progress = "0"
 475             String reason = ""
 476             String operationContent = "Prepare service creation"
 477             logger.info("Generated new operation for Service Instance serviceId:" + serviceId + " operationId:" + operationId + " operationType:" + operationType)
 478             serviceId = UriUtils.encode(serviceId,"UTF-8")
 479             execution.setVariable("serviceInstanceId", serviceId)
 480             execution.setVariable("operationId", operationId)
 481             execution.setVariable("operationType", operationType)
 482             // we use resource instance ids for delete flow as resourceTemplateUUIDs
 483             /*[
 484              {
 485                  "resourceInstanceId":"1111",
 486                  "resourceType":"vIMS"
 487              },
 488              {
 489                  "resourceInstanceId":"222",
 490                  "resourceType":"vEPC"
 491              },
 492              {
 493                  "resourceInstanceId":"3333",
 494                  "resourceType":"overlay"
 495              },
 496              {
 497                  "resourceInstanceId":"4444",
 498                  "resourceType":"underlay"
 499              }
 500          ]*/
 501             String serviceRelationShip = execution.getVariable("serviceRelationShip")
 502
 503             def jsonSlurper = new JsonSlurper()
 504             def jsonOutput = new JsonOutput()
 505             List relationShipList =  jsonSlurper.parseText(serviceRelationShip)
 506
 507             if (relationShipList != null) {
 508                 relationShipList.each {
 509                     resourceTemplateUUIDs  = resourceTemplateUUIDs + it.resourceInstanceId + ":"
 510                 }
 511             }
 512
 513             def dbAdapterEndpoint = UrnPropertiesReader.getVariable("mso.adapters.openecomp.db.endpoint", execution)
 514             execution.setVariable("URN_mso_adapters_openecomp_db_endpoint", dbAdapterEndpoint)
 515
 516             String payload =
 517                 """<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
 518                         xmlns:ns="http://org.onap.so/requestsdb">
 519                         <soapenv:Header/>
 520                         <soapenv:Body>
 521                             <ns:initResourceOperationStatus xmlns:ns="http://org.onap.so/requestsdb">
 522                             <serviceId>${MsoUtils.xmlEscape(serviceId)}</serviceId>
 523                             <operationId>${MsoUtils.xmlEscape(operationId)}</operationId>
 524                             <operationType>${MsoUtils.xmlEscape(operationType)}</operationType>
 525                             <resourceTemplateUUIDs>${MsoUtils.xmlEscape(resourceTemplateUUIDs)}</resourceTemplateUUIDs>
 526                         </ns:initResourceOperationStatus>
 527                     </soapenv:Body>
 528                 </soapenv:Envelope>"""
 529
 530             payload = utils.formatXml(payload)
 531             execution.setVariable("CVFMI_initResOperStatusRequest", payload)
 532             logger.info("Outgoing initResourceOperationStatus: \n" + payload)
 533             logger.debug("CreateVfModuleInfra Outgoing initResourceOperationStatus Request: " + payload)
 534
 535         }catch(Exception e){
 536                         logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(),
 537                                         "Exception Occured Processing preInitResourcesOperStatus.", "BPMN",
 538                                         ErrorCode.UnknownError.getValue(), e);
 539             execution.setVariable("CVFMI_ErrorResponse", "Error Occurred during preInitResourcesOperStatus Method:\n" + e.getMessage())
 540         }
 541         logger.trace("COMPLETED preInitResourcesOperStatus Process ")
 542     }
 543
 544    /**
 545     * prepare delete parameters
 546     */
 547    public void preResourceDelete(execution, resourceName){
 548        // we use resource instance ids for delete flow as resourceTemplateUUIDs
 549        /*[
 550         {
 551             "resourceInstanceId":"1111",
 552             "resourceType":"vIMS"
 553         },
 554         {
 555             "resourceInstanceId":"222",
 556             "resourceType":"vEPC"
 557         },
 558         {
 559             "resourceInstanceId":"3333",
 560             "resourceType":"overlay"
 561         },
 562         {
 563             "resourceInstanceId":"4444",
 564             "resourceType":"underlay"
 565         }
 566     ]*/
 567        logger.trace("STARTED preResourceDelete Process ")
 568        String serviceRelationShip = execution.getVariable("serviceRelationShip")
 569        def jsonSlurper = new JsonSlurper()
 570        def jsonOutput = new JsonOutput()
 571        List relationShipList =  jsonSlurper.parseText(serviceRelationShip)
 572
 573        if (relationShipList != null) {
 574            relationShipList.each {
 575                if(StringUtils.containsIgnoreCase(it.resourceType, resourceName)) {
 576                                    String resourceInstanceUUID = it.resourceInstanceId
 577                                    String resourceTemplateUUID = it.resourceInstanceId
 578                                    execution.setVariable("resourceTemplateId", resourceTemplateUUID)
 579                                    execution.setVariable("resourceInstanceId", resourceInstanceUUID)
 580                                    execution.setVariable("resourceType", resourceName)
 581                                logger.info("Delete Resource Info resourceTemplate Id :" + resourceTemplateUUID + "  resourceInstanceId: " + resourceInstanceUUID + " resourceType: " + resourceName)
 582                            }
 583            }
 584        }
 585        logger.trace("END preResourceDelete Process ")
 586    }
 587
 588    public void sequenceResource(execution){
 589        logger.trace("STARTED sequenceResource Process ")
 590        List<String> nsResources = new ArrayList<String>()
 591        List<String> wanResources = new ArrayList<String>()
 592        List<String> resourceSequence = new  ArrayList<String>()
 593
 594        String serviceRelationShip = execution.getVariable("serviceRelationShip")
 595
 596
 597        def jsonSlurper = new JsonSlurper()
 598        def jsonOutput = new JsonOutput()
 599        List relationShipList =  jsonSlurper.parseText(serviceRelationShip)
 600
 601        if (relationShipList != null) {
 602            relationShipList.each {
 603                if(StringUtils.containsIgnoreCase(it.resourceType, "overlay") || StringUtils.containsIgnoreCase(it.resourceType, "underlay")){
 604                    wanResources.add(it.resourceType)
 605                }else{
 606                    nsResources.add(it.resourceType)
 607                }
 608            }
 609        }
 610        resourceSequence.addAll(wanResources)
 611        resourceSequence.addAll(nsResources)
 612        String isContainsWanResource = wanResources.isEmpty() ? "false" : "true"
 613        execution.setVariable("isContainsWanResource", isContainsWanResource)
 614        execution.setVariable("currentResourceIndex", 0)
 615        execution.setVariable("resourceSequence", resourceSequence)
 616        logger.info("resourceSequence: " + resourceSequence)
 617        execution.setVariable("wanResources", wanResources)
 618        logger.trace("END sequenceResource Process ")
 619    }
 620
 621    public void getCurrentResource(execution){
 622        logger.trace("Start getCurrentResoure Process ")
 623        def currentIndex = execution.getVariable("currentResourceIndex")
 624        List<String> resourceSequence = execution.getVariable("resourceSequence")
 625        List<String> wanResources = execution.getVariable("wanResources")
 626        String resourceName =  resourceSequence.get(currentIndex)
 627        execution.setVariable("resourceType",resourceName)
 628        if(wanResources.contains(resourceName)){
 629            execution.setVariable("controllerInfo", "SDN-C")
 630        }else{
 631            execution.setVariable("controllerInfo", "VF-C")
 632        }
 633        logger.trace("COMPLETED getCurrentResoure Process ")
 634    }
 635
 636    public void parseNextResource(execution){
 637        logger.trace("Start parseNextResource Process ")
 638        def currentIndex = execution.getVariable("currentResourceIndex")
 639        def nextIndex =  currentIndex + 1
 640        execution.setVariable("currentResourceIndex", nextIndex)
 641        List<String> resourceSequence = execution.getVariable("resourceSequence")
 642        if(nextIndex >= resourceSequence.size()){
 643            execution.setVariable("allResourceFinished", "true")
 644        }else{
 645            execution.setVariable("allResourceFinished", "false")
 646        }
 647        logger.trace("COMPLETED parseNextResource Process ")
 648    }
 649
 650 }