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  * ================================================================================
   7  * Modifications Copyright (c) 2019 Samsung
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.bpmn.infrastructure.scripts
  24
  25 import org.onap.so.logger.LoggingAnchor
  26 import org.onap.aai.domain.yang.GenericVnf
  27 import org.onap.aai.domain.yang.NetworkPolicies
  28 import org.onap.aai.domain.yang.NetworkPolicy
  29 import org.onap.aai.domain.yang.VfModule
  30 import org.onap.logging.filter.base.ErrorCode
  31
  32 import static org.apache.commons.lang3.StringUtils.*
  33 import org.camunda.bpm.engine.delegate.BpmnError
  34 import org.camunda.bpm.engine.delegate.DelegateExecution
  35 import org.onap.so.bpmn.common.scripts.AaiUtil
  36 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  37 import org.onap.so.bpmn.common.scripts.MsoUtils
  38 import org.onap.so.bpmn.common.scripts.SDNCAdapterUtils
  39 import org.onap.so.bpmn.common.scripts.VfModuleBase
  40 import org.onap.so.bpmn.core.UrnPropertiesReader
  41 import org.onap.so.bpmn.core.WorkflowException
  42 import org.onap.so.bpmn.core.json.JsonUtils
  43 import org.onap.so.client.graphinventory.entities.uri.Depth
  44 import org.onap.so.client.aai.AAIObjectPlurals
  45 import org.onap.so.client.aai.AAIObjectType
  46 import org.onap.so.client.aai.entities.uri.AAIPluralResourceUri
  47 import org.onap.so.client.aai.entities.uri.AAIResourceUri
  48 import org.onap.so.client.aai.entities.uri.AAIUriFactory
  49 import org.onap.so.logger.MessageEnum
  50 import org.slf4j.Logger
  51 import org.slf4j.LoggerFactory
  52
  53 public class DoDeleteVfModuleFromVnf extends VfModuleBase {
  54     private static final Logger logger = LoggerFactory.getLogger( DoDeleteVfModuleFromVnf.class);
  55
  56         def Prefix="DDVFMV_"
  57         ExceptionUtil exceptionUtil = new ExceptionUtil()
  58         JsonUtils jsonUtil = new JsonUtils()
  59
  60         public void initProcessVariables(DelegateExecution execution) {
  61                 execution.setVariable("prefix",Prefix)
  62                 execution.setVariable("DDVFMV_contrailNetworkPolicyFqdnList", null)
  63         }
  64
  65         // parse the incoming request
  66         public void preProcessRequest(DelegateExecution execution) {
  67
  68                 initProcessVariables(execution)
  69
  70                 try {
  71
  72                                 // Building Block-type request
  73
  74                                 // Set mso-request-id to request-id for VNF Adapter interface
  75                                 String requestId = execution.getVariable("msoRequestId")
  76                                 execution.setVariable("mso-request-id", requestId)
  77                                 execution.setVariable("requestId", requestId)
  78                                 logger.debug("msoRequestId: " + requestId)
  79                                 String tenantId = execution.getVariable("tenantId")
  80                                 logger.debug("tenantId: " + tenantId)
  81                                 String cloudSiteId = execution.getVariable("lcpCloudRegionId")
  82                                 execution.setVariable("cloudSiteId", cloudSiteId)
  83                                 logger.debug("cloudSiteId: " + cloudSiteId)
  84                                 String cloudOwner = execution.getVariable("cloudOwner")
  85                                 execution.setVariable("cloudOwner", cloudOwner)
  86                                 logger.debug("cloudOwner: " + cloudOwner)
  87                                 // Source is HARDCODED
  88                                 String source = "VID"
  89                                 execution.setVariable("source", source)
  90                                 // isVidRequest is hardcoded to "true"
  91                                 execution.setVariable("isVidRequest", "true")
  92                                 // SrvInstId is hardcoded to empty
  93                                 execution.setVariable("srvInstId", "")
  94                                 // ServiceId is hardcoded to empty
  95                                 execution.setVariable("serviceId", "")
  96                                 String serviceInstanceId = execution.getVariable("serviceInstanceId")
  97                                 logger.debug("serviceInstanceId: " + serviceInstanceId)
  98                                 String vnfId = execution.getVariable("vnfId")
  99                                 logger.debug("vnfId: " + vnfId)
 100                                 String vfModuleId = execution.getVariable("vfModuleId")
 101                                 logger.debug("vfModuleId: " + vfModuleId)
 102                                 if (serviceInstanceId == null || serviceInstanceId.isEmpty()) {
 103                                         execution.setVariable(Prefix + "serviceInstanceIdToSdnc", vfModuleId)
 104                                 }
 105                                 else {
 106                                         execution.setVariable(Prefix + "serviceInstanceIdToSdnc", serviceInstanceId)
 107                                 }
 108
 109                                 String sdncVersion = execution.getVariable("sdncVersion")
 110                                 if (sdncVersion == null) {
 111                                         sdncVersion = "1707"
 112                                 }
 113                                 execution.setVariable(Prefix + "sdncVersion", sdncVersion)
 114                                 logger.debug("Incoming Sdnc Version is: " + sdncVersion)
 115
 116                                 String sdncCallbackUrl = (String) UrnPropertiesReader.getVariable("mso.workflow.sdncadapter.callback",execution)
 117                                 if (sdncCallbackUrl == null || sdncCallbackUrl.trim().isEmpty()) {
 118                                         def msg = 'Required variable \'mso.workflow.sdncadapter.callback\' is missing'
 119                                         logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(), msg, "BPMN",
 120                                                         ErrorCode.UnknownError.getValue(), "Exception");
 121                                         exceptionUtil.buildAndThrowWorkflowException(execution, 2000, msg)
 122                                 }
 123                                 execution.setVariable("sdncCallbackUrl", sdncCallbackUrl)
 124                                 logger.debug("SDNC Callback URL: " + sdncCallbackUrl)
 125                                 logger.debug("SDNC Callback URL is: " + sdncCallbackUrl)
 126
 127                 }catch(BpmnError b){
 128                         throw b
 129                 }catch(Exception e){
 130                         logger.debug("Exception is: " + e.getMessage())
 131                         exceptionUtil.buildAndThrowWorkflowException(execution, 2000, "Internal Error encountered in PreProcess method!")
 132                 }
 133         }
 134
 135         public void queryAAIForVfModule(DelegateExecution execution) {
 136                 def method = getClass().getSimpleName() + '.queryAAIForVfModule(' +
 137                         'execution=' + execution.getId() +
 138                         ')'
 139
 140                 logger.trace('Entered ' + method)
 141
 142                 try {
 143                         def vnfId = execution.getVariable('vnfId')
 144
 145                         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId).depth(Depth.ONE)
 146                         try {
 147                                 Optional<GenericVnf> genericVnf = getAAIClient().get(GenericVnf.class,uri)
 148
 149                                 if(genericVnf.isPresent()){
 150                                         execution.setVariable('DDVMFV_getVnfResponseCode', 200)
 151                                         execution.setVariable('DDVMFV_getVnfResponse', genericVnf.get())
 152                                 }else{
 153                                         execution.setVariable('DDVMFV_getVnfResponseCode', 404)
 154                                         execution.setVariable('DDVMFV_getVnfResponse', "Generic Vnf not found!")
 155                                 }
 156                         } catch (Exception ex) {
 157                                 logger.debug('Exception occurred while executing AAI GET: {}', ex.getMessage(), ex)
 158                                 execution.setVariable('DDVMFV_getVnfResponseCode', 500)
 159                                 execution.setVariable('DDVFMV_getVnfResponse', 'AAI GET Failed:' + ex.getMessage())
 160                         }
 161                         logger.trace('Exited ' + method)
 162                 } catch (BpmnError e) {
 163                         throw e;
 164                 } catch (Exception e) {
 165                         logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(),
 166                                         'Caught exception in ' + method, "BPMN",
 167                                         ErrorCode.UnknownError.getValue(), "Exception is:\n" + e);
 168                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in queryAAIForVfModule(): ' + e.getMessage())
 169                 }
 170         }
 171
 172         /**
 173          * Validate the VF Module.  That is, confirm that a VF Module with the input VF Module ID
 174          * exists in the retrieved Generic VNF.  Then, check to make sure that if that VF Module
 175          * is the base VF Module and it's not the only VF Module for this Generic VNF, that we're not
 176          * attempting to delete it.
 177          *
 178          * @param execution The flow's execution instance.
 179          */
 180         public void validateVfModule(DelegateExecution execution) {
 181                 def method = getClass().getSimpleName() + '.validateVfModule(' +
 182                         'execution=' + execution.getId() +
 183                         ')'
 184                 def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
 185                 logger.trace('Entered ' + method)
 186
 187                 try {
 188                         GenericVnf genericVnf = execution.getVariable('DDVMFV_getVnfResponse')
 189                         def vnfId = execution.getVariable('_vnfId')
 190                         def vfModuleId = execution.getVariable('vfModuleId')
 191             Optional<VfModule> vfModule = Optional.empty()
 192             if(genericVnf.getVfModules()!=null && ! genericVnf.getVfModules().getVfModule().isEmpty()) {
 193                 vfModule = genericVnf.getVfModules().getVfModule().stream().filter { v -> v.getVfModuleId().equals(vfModuleId) }.findFirst()
 194             }
 195                         if (!vfModule.isPresent()) {
 196                                 String msg = 'VF Module \'' + vfModuleId + '\' does not exist in Generic VNF \'' + vnfId + '\''
 197                                 logger.debug(msg)
 198                                 exceptionUtil.buildAndThrowWorkflowException(execution, 1002, msg)
 199                         } else {
 200                 Boolean isOnlyVfModule = (genericVnf.getVfModules().getVfModule().size() == 1)
 201                                 if (isDebugLogEnabled) {
 202                                         logger.debug('VF Module \'' + vfModuleId + '\': isBaseVfModule=' + vfModule.get().isIsBaseVfModule() + ', isOnlyVfModule=' + isOnlyVfModule)
 203                                 }
 204                                 if (vfModule.get().isIsBaseVfModule() && !isOnlyVfModule) {
 205                     String msg = 'Cannot delete VF Module \'' + vfModuleId +
 206                             '\'since it is the base VF Module and it\'s not the only VF Module in Generic VNF \'' + vnfId + '\''
 207                     logger.debug(msg)
 208                     exceptionUtil.buildAndThrowWorkflowException(execution, 1002,msg)
 209                                 }
 210                                 def heatStackId = vfModule.get().getHeatStackId()
 211                                 execution.setVariable('DDVMFV_heatStackId', heatStackId)
 212                                 logger.debug('VF Module heatStackId retrieved from AAI: ' + heatStackId)
 213                         }
 214                         logger.trace('Exited ' + method)
 215                 } catch (BpmnError e) {
 216                         throw e;
 217                 } catch (Exception e) {
 218                         logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(),
 219                                         'Caught exception in ' + method, "BPMN",
 220                                         ErrorCode.UnknownError.getValue(), "Exception is:\n" + e);
 221                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in validateVfModule(): ' + e.getMessage())
 222                 }
 223         }
 224
 225
 226         public void preProcessSDNCDeactivateRequest(DelegateExecution execution){
 227
 228                 execution.setVariable("prefix", Prefix)
 229                 logger.trace("STARTED preProcessSDNCDeactivateRequest ")
 230
 231                 def serviceInstanceId = execution.getVariable("serviceInstanceId")
 232
 233                 try{
 234                         //Build SDNC Request
 235
 236                         String deactivateSDNCRequest = buildSDNCRequest(execution, serviceInstanceId, "deactivate")
 237
 238                         deactivateSDNCRequest = utils.formatXml(deactivateSDNCRequest)
 239                         execution.setVariable("DDVMFV_deactivateSDNCRequest", deactivateSDNCRequest)
 240                         logger.debug("Outgoing DeactivateSDNCRequest is: \n" + deactivateSDNCRequest)
 241
 242
 243                 }catch(Exception e){
 244                         logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(),
 245                                         "Exception Occured Processing preProcessSDNCDeactivateRequest. Exception is:\n" + e, "BPMN",
 246                                         ErrorCode.UnknownError.getValue(), "Exception is:\n" + e);
 247                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, "Error Occurred during preProcessSDNCDeactivateRequest Method:\n" + e.getMessage())
 248                 }
 249                 logger.trace("COMPLETED preProcessSDNCDeactivateRequest ")
 250         }
 251
 252         public void preProcessSDNCUnassignRequest(DelegateExecution execution) {
 253                 def method = getClass().getSimpleName() + '.preProcessSDNCUnassignRequest(' +
 254                         'execution=' + execution.getId() +
 255                         ')'
 256
 257                 logger.trace('Entered ' + method)
 258                 execution.setVariable("prefix", Prefix)
 259                 logger.trace("STARTED preProcessSDNCUnassignRequest Process ")
 260                 try{
 261                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 262
 263                         String unassignSDNCRequest = buildSDNCRequest(execution, serviceInstanceId, "unassign")
 264
 265                         execution.setVariable("DDVMFV_unassignSDNCRequest", unassignSDNCRequest)
 266                         logger.debug("Outgoing UnassignSDNCRequest is: \n" + unassignSDNCRequest)
 267
 268
 269                 }catch(Exception e){
 270                         logger.debug("Exception Occured Processing preProcessSDNCUnassignRequest. Exception is:\n" + e)
 271                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, "Error Occured during  preProcessSDNCUnassignRequest Method:\n" + e.getMessage())
 272                 }
 273                 logger.trace("COMPLETED  preProcessSDNCUnassignRequest Process ")
 274         }
 275
 276         public String buildSDNCRequest(DelegateExecution execution, String svcInstId, String action){
 277
 278                         String uuid = execution.getVariable('testReqId') // for junits
 279                         if(uuid==null){
 280                                 uuid = execution.getVariable("msoRequestId") + "-" +    System.currentTimeMillis()
 281                         }
 282                         def callbackURL = execution.getVariable("sdncCallbackUrl")
 283                         def requestId = execution.getVariable("msoRequestId")
 284                         def serviceId = execution.getVariable("serviceId")
 285                         def serviceInstanceId = execution.getVariable("serviceInstanceId")
 286                         def vfModuleId = execution.getVariable("vfModuleId")
 287                         def source = execution.getVariable("source")
 288                         def vnfId = execution.getVariable("vnfId")
 289
 290                         def sdncVersion = execution.getVariable(Prefix + "sdncVersion")
 291
 292                         String sdncRequest =
 293                         """<sdncadapterworkflow:SDNCAdapterWorkflowRequest xmlns:ns5="http://org.onap/so/request/types/v1"
 294                                                                                                         xmlns:sdncadapterworkflow="http://org.onap/so/workflow/schema/v1"
 295                                                                                                         xmlns:sdncadapter="http://org.onap.so/workflow/sdnc/adapter/schema/v1">
 296            <sdncadapter:RequestHeader>
 297                                 <sdncadapter:RequestId>${MsoUtils.xmlEscape(uuid)}</sdncadapter:RequestId>
 298                                 <sdncadapter:SvcInstanceId>${MsoUtils.xmlEscape(svcInstId)}</sdncadapter:SvcInstanceId>
 299                                 <sdncadapter:SvcAction>${MsoUtils.xmlEscape(action)}</sdncadapter:SvcAction>
 300                                 <sdncadapter:SvcOperation>vf-module-topology-operation</sdncadapter:SvcOperation>
 301                                 <sdncadapter:CallbackUrl>${MsoUtils.xmlEscape(callbackURL)}</sdncadapter:CallbackUrl>
 302                                 <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
 303                 </sdncadapter:RequestHeader>
 304         <sdncadapterworkflow:SDNCRequestData>
 305                 <request-information>
 306                         <request-id>${MsoUtils.xmlEscape(requestId)}</request-id>
 307                         <request-action>DeleteVfModuleInstance</request-action>
 308                         <source>${MsoUtils.xmlEscape(source)}</source>
 309                         <notification-url/>
 310                         <order-number/>
 311                         <order-version/>
 312                 </request-information>
 313                 <service-information>
 314                         <service-id/>
 315                         <subscription-service-type/>
 316                         <service-instance-id>${MsoUtils.xmlEscape(serviceInstanceId)}</service-instance-id>
 317                         <global-customer-id/>
 318                 </service-information>
 319                 <vnf-information>
 320                         <vnf-id>${MsoUtils.xmlEscape(vnfId)}</vnf-id>
 321                         <vnf-type/>
 322                 </vnf-information>
 323                 <vf-module-information>
 324                         <vf-module-id>${MsoUtils.xmlEscape(vfModuleId)}</vf-module-id>
 325                 </vf-module-information>
 326                 <vf-module-request-input/>
 327         </sdncadapterworkflow:SDNCRequestData>
 328         </sdncadapterworkflow:SDNCAdapterWorkflowRequest>"""
 329
 330                 logger.debug("sdncRequest:  " + sdncRequest)
 331                 return sdncRequest
 332         }
 333
 334         public void validateSDNCResponse(DelegateExecution execution, String response, String method){
 335
 336                 execution.setVariable("prefix",Prefix)
 337                 logger.trace("STARTED ValidateSDNCResponse Process")
 338
 339                 WorkflowException workflowException = execution.getVariable("WorkflowException")
 340                 boolean successIndicator = execution.getVariable("SDNCA_SuccessIndicator")
 341
 342                 logger.debug("workflowException: " + workflowException)
 343
 344                 SDNCAdapterUtils sdncAdapterUtils = new SDNCAdapterUtils()
 345                 sdncAdapterUtils.validateSDNCResponse(execution, response, workflowException, successIndicator)
 346
 347                 logger.debug("SDNCResponse: " + response)
 348
 349                 String sdncResponse = response
 350                 if(execution.getVariable(Prefix + 'sdncResponseSuccess') == true){
 351                         logger.debug("Received a Good Response from SDNC Adapter for " + method + " SDNC Call.  Response is: \n" + sdncResponse)
 352                 }else{
 353                         logger.debug("Received a BAD Response from SDNC Adapter for " + method + " SDNC Call.")
 354                         throw new BpmnError("MSOWorkflowException")
 355                 }
 356                 logger.trace("COMPLETED ValidateSDNCResponse Process")
 357         }
 358
 359
 360         // parse the incoming DELETE_VF_MODULE request
 361         // and formulate the outgoing VnfAdapterDeleteV1 request
 362         public void prepVNFAdapterRequest(DelegateExecution execution) {
 363
 364                 def requestId = UUID.randomUUID().toString()
 365                 def origRequestId = execution.getVariable('requestId')
 366                 def srvInstId = execution.getVariable("serviceInstanceId")
 367                 def aicCloudRegion = execution.getVariable("cloudSiteId")
 368                 def cloudOwner = execution.getVariable("cloudOwner")
 369                 def vnfId = execution.getVariable("vnfId")
 370                 def vfModuleId = execution.getVariable("vfModuleId")
 371                 def vfModuleStackId = execution.getVariable('DDVMFV_heatStackId')
 372                 def tenantId = execution.getVariable("tenantId")
 373                 def messageId = execution.getVariable('requestId') + '-' +
 374                         System.currentTimeMillis()
 375                 def notificationUrl = createCallbackURL(execution, "VNFAResponse", messageId)
 376                 def useQualifiedHostName = UrnPropertiesReader.getVariable("mso.use.qualified.host",execution)
 377                 if ('true'.equals(useQualifiedHostName)) {
 378                         notificationUrl = utils.getQualifiedHostNameForCallback(notificationUrl)
 379                 }
 380
 381                 String request = """
 382                         <deleteVfModuleRequest>
 383                             <cloudSiteId>${MsoUtils.xmlEscape(aicCloudRegion)}</cloudSiteId>
 384                             <cloudOwner>${MsoUtils.xmlEscape(cloudOwner)}</cloudOwner>
 385                             <tenantId>${MsoUtils.xmlEscape(tenantId)}</tenantId>
 386                             <vnfId>${MsoUtils.xmlEscape(vnfId)}</vnfId>
 387                             <vfModuleId>${MsoUtils.xmlEscape(vfModuleId)}</vfModuleId>
 388                             <vfModuleStackId>${MsoUtils.xmlEscape(vfModuleStackId)}</vfModuleStackId>
 389                             <skipAAI>true</skipAAI>
 390                             <msoRequest>
 391                                 <requestId>${MsoUtils.xmlEscape(origRequestId)}</requestId>
 392                                 <serviceInstanceId>${MsoUtils.xmlEscape(srvInstId)}</serviceInstanceId>
 393                             </msoRequest>
 394                             <messageId>${MsoUtils.xmlEscape(messageId)}</messageId>
 395                             <notificationUrl>${MsoUtils.xmlEscape(notificationUrl)}</notificationUrl>
 396                         </deleteVfModuleRequest>
 397                         """ as String
 398
 399                 logger.debug("vnfAdapterRestV1Request: " + request)
 400                 logger.debug("deleteVfModuleRequest: " + request)
 401                 execution.setVariable("vnfAdapterRestV1Request", request)
 402         }
 403
 404
 405         // generates a WorkflowException if
 406         //              -
 407         public void handleDoDeleteVfModuleFailure(DelegateExecution execution) {
 408                 logger.error(LoggingAnchor.FIVE, MessageEnum.BPMN_GENERAL_EXCEPTION_ARG.toString(),
 409                                 "AAI error occurred deleting the Generic Vnf: " + execution.getVariable("DDVFMV_deleteGenericVnfResponse"),
 410                                 "BPMN", ErrorCode.UnknownError.getValue(), "Exception");
 411                 String processKey = getProcessKey(execution);
 412                 WorkflowException exception = new WorkflowException(processKey, 5000,
 413                         execution.getVariable("DDVFMV_deleteGenericVnfResponse"))
 414                 execution.setVariable("WorkflowException", exception)
 415         }
 416
 417         public void postProcessVNFAdapterRequest(DelegateExecution execution) {
 418                 def method = getClass().getSimpleName() + '.postProcessVNFAdapterRequest(' +
 419                         'execution=' + execution.getId() +
 420                         ')'
 421
 422                 logger.trace('Entered ' + method)
 423                 execution.setVariable("prefix",Prefix)
 424                 try{
 425                 logger.trace("STARTED postProcessVNFAdapterRequest Process")
 426
 427                 String vnfResponse = execution.getVariable("DDVMFV_doDeleteVfModuleResponse")
 428                 logger.debug("VNF Adapter Response is: " + vnfResponse)
 429                 logger.debug("deleteVnfAResponse is: \n"  + vnfResponse)
 430
 431                 if(vnfResponse != null){
 432
 433                         if(vnfResponse.contains("deleteVfModuleResponse")){
 434                                 logger.debug("Received a Good Response from VNF Adapter for DELETE_VF_MODULE Call.")
 435                                 execution.setVariable("DDVFMV_vnfVfModuleDeleteCompleted", true)
 436
 437                                 // Parse vnfOutputs for contrail network polcy FQDNs
 438                                 def vfModuleOutputsXml = utils.getNodeXml(vnfResponse, "vfModuleOutputs")
 439                                 if(!isBlank(vfModuleOutputsXml)) {
 440                                         vfModuleOutputsXml = utils.removeXmlNamespaces(vfModuleOutputsXml)
 441                                         List contrailNetworkPolicyFqdnList = []
 442                                         for(Node node: utils.getMultNodeObjects(vfModuleOutputsXml, "entry")) {
 443                                                 String key = utils.getChildNodeText(node, "key")
 444                                                 if(key == null) {
 445
 446                                                 } else if (key.endsWith("contrail_network_policy_fqdn")) {
 447                                                         String contrailNetworkPolicyFqdn = utils.getChildNodeText(node, "value")
 448                                                         logger.debug("Obtained contrailNetworkPolicyFqdn: " + contrailNetworkPolicyFqdn)
 449                                                         contrailNetworkPolicyFqdnList.add(contrailNetworkPolicyFqdn)
 450                                                 }
 451                                                 else if (key.equals("oam_management_v4_address")) {
 452                                                         String oamManagementV4Address = utils.getChildNodeText(node, "value")
 453                                                         logger.debug("Obtained oamManagementV4Address: " + oamManagementV4Address)
 454                                                         execution.setVariable(Prefix + "oamManagementV4Address", oamManagementV4Address)
 455                                                 }
 456                                                 else if (key.equals("oam_management_v6_address")) {
 457                                                         String oamManagementV6Address = utils.getChildNodeText(node, "value")
 458                                                         logger.debug("Obtained oamManagementV6Address: " + oamManagementV6Address)
 459                                                         execution.setVariable(Prefix + "oamManagementV6Address", oamManagementV6Address)
 460                                                 }
 461                                         }
 462                                         if (!contrailNetworkPolicyFqdnList.isEmpty()) {
 463                                                 logger.debug("Setting the fqdn list")
 464                                                 execution.setVariable("DDVFMV_contrailNetworkPolicyFqdnList", contrailNetworkPolicyFqdnList)
 465                                         }
 466                                 }
 467                         }else{
 468                                 logger.debug("Received a BAD Response from VNF Adapter for DELETE_VF_MODULE Call.")
 469                                 exceptionUtil.buildAndThrowWorkflowException(execution, 1002, "VNF Adapter Error")
 470                         }
 471                 }else{
 472                         logger.debug("Response from VNF Adapter is Null for DELETE_VF_MODULE Call.")
 473                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, "Empty response from VNF Adapter")
 474                 }
 475
 476                 }catch(BpmnError b){
 477                         throw b
 478                 }catch(Exception e){
 479                         logger.debug("Internal Error Occured in PostProcess Method")
 480                         exceptionUtil.buildAndThrowWorkflowException(execution, 1002, "Internal Error Occured in PostProcess Method")
 481                 }
 482                 logger.trace("COMPLETED postProcessVnfAdapterResponse Process")
 483         }
 484
 485         public void deleteNetworkPoliciesFromAAI(DelegateExecution execution) {
 486                 def method = getClass().getSimpleName() + '.deleteNetworkPoliciesFromAAI(' +
 487                 'execution=' + execution.getId() +
 488                 ')'
 489
 490                 logger.trace('Entered ' + method)
 491                 execution.setVariable("prefix", Prefix)
 492                 logger.trace("STARTED deleteNetworkPoliciesFromAAI ")
 493
 494                 try {
 495                         // get variables
 496                         List fqdnList = execution.getVariable("DDVFMV_contrailNetworkPolicyFqdnList")
 497                         if (fqdnList == null) {
 498                                 logger.debug("No network policies to delete")
 499                                 return
 500                         }
 501                         int fqdnCount = fqdnList.size()
 502
 503                         execution.setVariable("DDVFMV_networkPolicyFqdnCount", fqdnCount)
 504                         logger.debug("DDVFMV_networkPolicyFqdnCount - " + fqdnCount)
 505
 506                         AaiUtil aaiUriUtil = new AaiUtil(this)
 507
 508                         if (fqdnCount > 0) {
 509                                 // AII loop call over contrail network policy fqdn list
 510                                 for (i in 0..fqdnCount-1) {
 511
 512                                         int counting = i+1
 513                                         String fqdn = fqdnList[i]
 514
 515                                         // Query AAI for this network policy FQDN
 516
 517                                         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectPlurals.NETWORK_POLICY)
 518                                         uri.queryParam("network-policy-fqdn", fqdn)
 519
 520                     try {
 521                         Optional<NetworkPolicies> networkPolicies = getAAIClient().get(NetworkPolicies.class, uri)
 522
 523                         if (networkPolicies.isPresent() && !networkPolicies.get().getNetworkPolicy().isEmpty()) {
 524                             NetworkPolicy networkPolicy = networkPolicies.get().getNetworkPolicy().get(0)
 525                             execution.setVariable("DCVFM_aaiQueryNetworkPolicyByFqdnReturnCode", 200)
 526                             // This network policy FQDN exists in AAI - need to delete it now
 527                             // Retrieve the network policy id for this FQDN
 528                             def networkPolicyId = networkPolicy.getNetworkPolicyId()
 529                             logger.debug("Deleting network-policy with network-policy-id " + networkPolicyId)
 530
 531                             // Retrieve the resource version for this network policy
 532                             try {
 533                                 AAIResourceUri delUri = AAIUriFactory.createResourceUri(AAIObjectType.NETWORK_POLICY, networkPolicyId)
 534                                 getAAIClient().delete(delUri)
 535                                 execution.setVariable("DDVFMV_aaiDeleteNetworkPolicyReturnCode", 200)
 536                                 logger.debug(" ***** AAI delete network policy Response Code, NetworkPolicy #" + counting + " : " + 200)
 537                                 // This network policy was deleted from AAI successfully
 538                                 logger.debug(" DelAAINetworkPolicy Success REST Response, , NetworkPolicy #" + counting + " : ")
 539                             } catch (Exception e) {
 540                                 // aai all errors
 541                                 String delErrorMessage = "Unable to delete network-policy to AAI deleteNetworkPoliciesFromAAI - " + e.getMessage()
 542                                 logger.debug(delErrorMessage)
 543                                 exceptionUtil.buildAndThrowWorkflowException(execution, 2500, delErrorMessage)
 544                             }
 545                         } else {
 546                             execution.setVariable("DCVFM_aaiQueryNetworkPolicyByFqdnReturnCode", 404)
 547                             // This network policy FQDN is not in AAI. No need to delete.
 548                             logger.debug("This network policy FQDN is not in AAI: " + fqdn)
 549                             logger.debug("Network policy FQDN is not in AAI")
 550                         }
 551                     } catch (Exception e) {
 552                         // aai all errors
 553                         String dataErrorMessage = "Unexpected Response from deleteNetworkPoliciesFromAAI - " + e.getMessage()
 554                         logger.debug(dataErrorMessage)
 555                         exceptionUtil.buildAndThrowWorkflowException(execution, 2500, dataErrorMessage)
 556                     }
 557                 } // end loop
 558                         } else {
 559                                    logger.debug("No contrail network policies to query/create")
 560
 561                         }
 562
 563                 } catch (BpmnError e) {
 564                         throw e;
 565
 566                 } catch (Exception ex) {
 567                         String exceptionMessage = "Bpmn error encountered in DoDeletVfModule flow. deleteNetworkPoliciesFromAAI() - " + ex.getMessage()
 568                         logger.debug(exceptionMessage)
 569                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, exceptionMessage)
 570                 }
 571
 572         }
 573
 574         // and formulate the outgoing DeleteAAIVfModuleRequest request
 575         public void prepDeleteAAIVfModule(DelegateExecution execution) {
 576
 577
 578                 def vnfId = execution.getVariable("vnfId")
 579                 def vfModuleId = execution.getVariable("vfModuleId")
 580                 // formulate the request for UpdateAAIVfModule
 581                 String request = """<DeleteAAIVfModuleRequest>
 582                                                                 <vnf-id>${MsoUtils.xmlEscape(vnfId)}</vnf-id>
 583                                                                 <vf-module-id>${MsoUtils.xmlEscape(vfModuleId)}</vf-module-id>
 584                                                         </DeleteAAIVfModuleRequest>""" as String
 585                 logger.debug("DeleteAAIVfModuleRequest :" + request)
 586
 587                 execution.setVariable("DeleteAAIVfModuleRequest", request)
 588         }
 589 }