gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * OPENECOMP - SO
   4  * ================================================================================
   5  * Copyright (C) 2018 Huawei Technologies Co., Ltd. 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.bpmn.common.scripts.ExternalAPIUtilFactory
  26
  27 import javax.ws.rs.NotFoundException
  28 import javax.ws.rs.core.Response
  29
  30 import org.apache.commons.lang3.StringUtils
  31 import static org.apache.commons.lang3.StringUtils.*
  32 import org.camunda.bpm.engine.delegate.BpmnError
  33 import org.camunda.bpm.engine.delegate.DelegateExecution
  34 import org.json.JSONArray
  35 import org.json.JSONObject
  36 import org.onap.aai.domain.yang.SpPartner
  37 import org.onap.so.bpmn.common.recipe.ResourceInput
  38 import org.onap.so.bpmn.common.resource.ResourceRequestBuilder
  39 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
  40 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  41 import org.onap.so.bpmn.common.scripts.ExternalAPIUtil
  42 import org.onap.so.bpmn.core.json.JsonUtils
  43 import org.onap.so.bpmn.core.UrnPropertiesReader
  44 import org.onap.so.client.aai.AAIObjectType
  45 import org.onap.so.client.aai.AAIResourcesClient
  46 import org.onap.so.client.aai.entities.uri.AAIResourceUri
  47 import org.onap.so.client.aai.entities.uri.AAIUriFactory
  48 import org.slf4j.Logger
  49 import org.slf4j.LoggerFactory
  50
  51 /**
  52  * This groovy class supports the <class>Delete3rdONAPE2EServiceInstance.bpmn</class> process.
  53  * flow for Delete 3rdONAPE2EServiceInstance in 3rdONAP
  54  */
  55 public class Delete3rdONAPE2EServiceInstance extends AbstractServiceTaskProcessor {
  56
  57         String Prefix = "CRE3rdONAPESI_"
  58
  59         ExceptionUtil exceptionUtil = new ExceptionUtil()
  60
  61         JsonUtils jsonUtil = new JsonUtils()
  62
  63     private static final Logger logger = LoggerFactory.getLogger( Delete3rdONAPE2EServiceInstance.class)
  64
  65         public void checkSPPartnerInfoFromAAI (DelegateExecution execution) {
  66                 logger.info(" ***** Started checkSPPartnerInfo *****")
  67                 try {
  68                         //get bpmn inputs from resource request.
  69                         String requestId = execution.getVariable("mso-request-id")
  70                         String requestAction = execution.getVariable("requestAction")
  71                         logger.info("The requestAction is: " + requestAction)
  72                         String recipeParamsFromRequest = execution.getVariable("recipeParams")
  73                         logger.info("The recipeParams is: " + recipeParamsFromRequest)
  74                         String resourceInput = execution.getVariable("resourceInput")
  75                         logger.info("The resourceInput is: " + resourceInput)
  76                         //Get ResourceInput Object
  77                         ResourceInput resourceInputObj = ResourceRequestBuilder.getJsonObject(resourceInput, ResourceInput.class)
  78                         // set local resourceInput
  79                         execution.setVariable(Prefix + "ResourceInput", resourceInputObj)
  80
  81                         String resourceInstanceId = resourceInputObj.getResourceInstancenUuid()
  82                         String sppartnerId = resourceInstanceId
  83                         execution.setVariable(Prefix + "SppartnerId", sppartnerId)
  84
  85                         // Get Sppartner from AAI
  86                         getSPPartnerInAAI(execution)
  87
  88                         String callSource = "UUI"
  89                         String sppartnerUrl = ""
  90                         if(execution.hasVariable(Prefix + "CallSource")) {
  91                                 callSource = execution.getVariable(Prefix + "CallSource")
  92                                 sppartnerUrl = execution.getVariable(Prefix + "SppartnerUrl")
  93                         }
  94
  95                         boolean is3rdONAPExist = false
  96                         if(!isBlank(sppartnerUrl)) {
  97                                 is3rdONAPExist = true
  98                         }
  99
 100                         execution.setVariable("Is3rdONAPExist", is3rdONAPExist)
 101                         execution.setVariable(Prefix + "ServiceInstanceId", resourceInputObj.getServiceInstanceId())
 102                         execution.setVariable("mso-request-id", requestId)
 103                         execution.setVariable("mso-service-instance-id", resourceInputObj.getServiceInstanceId())
 104
 105                 } catch (Exception ex){
 106                         String msg = "Exception in checkSPPartnerInfoFromAAI " + ex.getMessage()
 107                         logger.debug(msg)
 108 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 109                 }
 110         }
 111
 112         public void checkLocallCall (DelegateExecution execution) {
 113                 logger.info(" ***** Started checkLocallCall *****")
 114
 115                 boolean isLocalCall = true
 116                 String callSource = execution.getVariable(Prefix + "CallSource")
 117                 if("ExternalAPI".equalsIgnoreCase(callSource)) {
 118                         isLocalCall = false
 119                 }
 120                 execution.setVariable("IsLocalCall", isLocalCall)
 121         }
 122
 123         public void preProcessRequest(DelegateExecution execution){
 124                 logger.info(" ***** Started preProcessRequest *****")
 125                 String msg = ""
 126
 127                 try {
 128                         ResourceInput resourceInputObj = execution.getVariable(Prefix + "ResourceInput")
 129
 130                         String globalSubscriberId = resourceInputObj.getGlobalSubscriberId()
 131                         if (isBlank(globalSubscriberId)) {
 132                                 msg = "Input globalSubscriberId is null"
 133                                 logger.error(msg)
 134                         }
 135                         //set local variable
 136                         execution.setVariable("globalSubscriberId", globalSubscriberId)
 137                         logger.info( "globalSubscriberId:" + globalSubscriberId)
 138
 139                         String serviceType = resourceInputObj.getServiceType()
 140                         if (isBlank(serviceType)) {
 141                                 msg = "Input serviceType is null"
 142                                 logger.error(msg)
 143                         }
 144                         execution.setVariable("serviceType", serviceType)
 145                         logger.info( "serviceType:" + serviceType)
 146
 147                         String operationId = resourceInputObj.getOperationId()
 148                         if (isBlank(operationId)) {
 149                                 msg = "Input operationId is null"
 150                                 logger.error(msg)
 151                         }
 152                         execution.setVariable("operationId", operationId)
 153                         logger.info( "operationId:" + operationId)
 154
 155                         String resourceName = resourceInputObj.getResourceInstanceName()
 156                         if (isBlank(resourceName)) {
 157                                 msg = "Input resourceName is null"
 158                                 logger.error(msg)
 159                         }
 160                         execution.setVariable("resourceName", resourceName)
 161                         logger.info("resourceName:" + resourceName)
 162
 163                         String resourceTemplateId = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
 164                         if (isBlank(resourceTemplateId)) {
 165                                 msg = "Input resourceTemplateId is null"
 166                                 logger.error(msg)
 167                         }
 168                         execution.setVariable("resourceTemplateId", resourceTemplateId)
 169                         logger.info( "resourceTemplateId:" + resourceTemplateId)
 170
 171                 } catch (Exception ex){
 172                         msg = "Exception in preProcessRequest " + ex.getMessage()
 173                         logger.debug(msg)
 174 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 175                 }
 176         }
 177
 178         public void prepareUpdateProgress(DelegateExecution execution) {
 179                 logger.info(" ***** Started prepareUpdateProgress *****")
 180                 ResourceInput resourceInputObj = execution.getVariable(Prefix + "ResourceInput")
 181                 String operType = resourceInputObj.getOperationType()
 182                 String resourceCustomizationUuid = resourceInputObj.getResourceModelInfo().getModelCustomizationUuid()
 183                 String ServiceInstanceId = resourceInputObj.getServiceInstanceId()
 184                 String modelName = resourceInputObj.getResourceModelInfo().getModelName()
 185                 String operationId = resourceInputObj.getOperationId()
 186                 String progress = execution.getVariable("progress")
 187                 String status = execution.getVariable("status")
 188                 String statusDescription = execution.getVariable("statusDescription")
 189
 190                 String body = """
 191                 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
 192                         xmlns:ns="http://org.onap.so/requestsdb">
 193                         <soapenv:Header/>
 194                 <soapenv:Body>
 195                     <ns:updateResourceOperationStatus>
 196                                <operType>${operType}</operType>
 197                                <operationId>${operationId}</operationId>
 198                                <progress>${progress}</progress>
 199                                <resourceTemplateUUID>${resourceCustomizationUuid}</resourceTemplateUUID>
 200                                <serviceId>${ServiceInstanceId}</serviceId>
 201                                <status>${status}</status>
 202                                <statusDescription>${statusDescription}</statusDescription>
 203                     </ns:updateResourceOperationStatus>
 204                 </soapenv:Body>
 205                 </soapenv:Envelope>"""
 206
 207                 setProgressUpdateVariables(execution, body)
 208                 logger.info(" ***** End prepareUpdateProgress *****")
 209         }
 210
 211         public void prepare3rdONAPRequest(DelegateExecution execution) {
 212                 logger.info(" ***** Started prepare3rdONAPRequest *****")
 213
 214                 String sppartnerUrl = execution.getVariable(Prefix + "SppartnerUrl")
 215                 String extAPIPath = sppartnerUrl + '/serviceOrder'
 216                 execution.setVariable("ExternalAPIURL", extAPIPath)
 217
 218                 // ExternalAPI message format
 219                 String externalId = execution.getVariable("resourceName")
 220                 String serviceType = execution.getVariable("serviceType")
 221                 String category = "E2E Service"
 222                 String description = "Service Order from SPPartner"
 223                 String requestedStartDate = utils.generateCurrentTimeInUtc()
 224                 String requestedCompletionDate = utils.generateCurrentTimeInUtc()
 225                 String priority = "1" // 0-4 0:highest
 226                 String subscriberId = execution.getVariable("globalSubscriberId")
 227                 String customerRole = "ONAPcustomer"
 228                 // Below SO will pass serviceType as subscriberName and externalAPI will use
 229                 // the same serviceType in another domain instead of model name
 230                 String subscriberName = serviceType
 231                 String referredType = "Consumer"
 232                 String orderItemId = "1"
 233                 String action = "delete" //for delete
 234                 String serviceState = "active"
 235                 String serviceName = ""
 236                 String serviceId = execution.getVariable(Prefix + "SppartnerId")
 237
 238                 queryServicefrom3rdONAP(execution)
 239                 String serviceSpecificationId = execution.getVariable(Prefix + "ServiceSpecificationId")
 240
 241                 Map<String, String> valueMap = new HashMap<>()
 242                 valueMap.put("externalId", '"' + externalId + '"')
 243                 valueMap.put("category", '"' + category + '"')
 244                 valueMap.put("description", '"' + description + '"')
 245                 valueMap.put("requestedStartDate", '"' + requestedStartDate + '"')
 246                 valueMap.put("requestedCompletionDate", '"' + requestedCompletionDate + '"')
 247                 valueMap.put("priority", '"'+ priority + '"')
 248                 valueMap.put("subscriberId", '"' + subscriberId + '"')
 249                 valueMap.put("customerRole", '"' + customerRole + '"')
 250                 valueMap.put("subscriberName", '"' + subscriberName + '"')
 251                 valueMap.put("referredType", '"' + referredType + '"')
 252                 valueMap.put("orderItemId", '"' + orderItemId + '"')
 253                 valueMap.put("action", '"' + action + '"')
 254                 valueMap.put("serviceState", '"' + serviceState + '"')
 255                 valueMap.put("serviceId", '"' + serviceId + '"')
 256                 valueMap.put("serviceName", "null")
 257                 valueMap.put("serviceUuId", '"' + serviceSpecificationId + '"')
 258
 259                 ExternalAPIUtil externalAPIUtil = new ExternalAPIUtilFactory().create()
 260
 261                 valueMap.put("_requestInputs_",  "")
 262
 263                 String payload = externalAPIUtil.setTemplate(ExternalAPIUtil.PostServiceOrderRequestsTemplate, valueMap)
 264                 execution.setVariable(Prefix + "Payload", payload)
 265                 logger.info( "***** Exit prepare3rdONAPRequest *****")
 266         }
 267
 268         private void queryServicefrom3rdONAP(DelegateExecution execution)
 269         {
 270                 logger.info(" ***** Started queryServicefrom3rdONAP *****")
 271         try {
 272
 273                 String globalSubscriberId = execution.getVariable("globalSubscriberId")
 274                 String SppartnerServiceId = execution.getVariable(Prefix + "SppartnerId")
 275
 276                 //https://{api_url}/nbi/api/v1/service?relatedParty.id=${globalSubscriberId}
 277                 String sppartnerUrl = execution.getVariable(Prefix + "SppartnerUrl")
 278                 String extAPIPath = sppartnerUrl + "/service?relatedParty.id=" + globalSubscriberId
 279                 logger.debug("queryServicefrom3rdONAP externalAPIURL is: " + extAPIPath)
 280
 281                 ExternalAPIUtil externalAPIUtil = new ExternalAPIUtilFactory().create()
 282
 283                 Response response = externalAPIUtil.executeExternalAPIGetCall(execution, extAPIPath)
 284
 285                 int responseCode = response.getStatus()
 286                 execution.setVariable(Prefix + "GetServiceResponseCode", responseCode)
 287                 logger.debug("Get Service response code is: " + responseCode)
 288
 289                 String extApiResponse = response.readEntity(String.class)
 290
 291                 execution.setVariable(Prefix + "GetServiceResponse", extApiResponse)
 292                 logger.debug("queryServicefrom3rdONAP response body is: " + extApiResponse)
 293
 294                 //Process Response //200 OK 201 CREATED 202 ACCEPTED
 295                 if(responseCode == 200 || responseCode == 201 || responseCode == 202 )
 296                 {
 297                         logger.debug("Get Service Received a Good Response")
 298                         JSONArray responseList = new JSONArray(extApiResponse)
 299                         for(int i=0; i< responseList.length(); i++) {
 300                                 JSONObject obj = responseList.getJSONObject(i)
 301                                 String svcId  = obj.get("id")
 302                                 if(StringUtils.equalsIgnoreCase(SppartnerServiceId, svcId)) {
 303                                         JSONObject serviceSpecification = obj.get("serviceSpecification")
 304                                         String serviceUuid = serviceSpecification.get("id")
 305                                         execution.setVariable(Prefix + "ServiceSpecificationId", serviceUuid)
 306                                         break
 307                                 }
 308                         }
 309                 }
 310                 else{
 311                         logger.error("Get Service Received a Bad Response Code. Response Code is: " + responseCode)
 312 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 500, "Get Service Received a bad response from 3rdONAP External API")
 313                 }
 314         }catch(Exception e) {
 315             logger.error("queryServicefrom3rdONAP exception:" + e.getMessage())
 316         }
 317                 logger.info( "***** Exit queryServicefrom3rdONAP *****")
 318         }
 319
 320         public void doDeleteE2ESIin3rdONAP(DelegateExecution execution) {
 321                 logger.info(" ***** Started doDeleteE2ESIin3rdONAP *****")
 322                 try {
 323                 String extAPIPath = execution.getVariable("ExternalAPIURL")
 324                 String payload = execution.getVariable(Prefix + "Payload")
 325                 logger.debug("doDeleteE2ESIin3rdONAP externalAPIURL is: " + extAPIPath)
 326                 logger.debug("doDeleteE2ESIin3rdONAP payload is: " + payload)
 327
 328                 ExternalAPIUtil externalAPIUtil = new ExternalAPIUtilFactory().create()
 329                 execution.setVariable("ServiceOrderId", "")
 330
 331                 Response response = externalAPIUtil.executeExternalAPIPostCall(execution, extAPIPath, payload)
 332
 333                 int responseCode = response.getStatus()
 334                 execution.setVariable(Prefix + "PostServiceOrderResponseCode", responseCode)
 335                 logger.debug("Post ServiceOrder response code is: " + responseCode)
 336
 337                 String extApiResponse = response.readEntity(String.class)
 338                 JSONObject responseObj = new JSONObject(extApiResponse)
 339                 execution.setVariable(Prefix + "PostServiceOrderResponse", extApiResponse)
 340
 341                 logger.debug("doDeleteE2ESIin3rdONAP response body is: " + extApiResponse)
 342
 343                 //Process Response
 344                 if(responseCode == 200 || responseCode == 201 || responseCode == 202 )
 345                         //200 OK 201 CREATED 202 ACCEPTED
 346                 {
 347                         logger.debug("Post ServiceOrder Received a Good Response")
 348                         String serviceOrderId = responseObj.get("id")
 349                         execution.setVariable(Prefix + "SuccessIndicator", true)
 350                         execution.setVariable("ServiceOrderId", serviceOrderId)
 351                         logger.info("Post ServiceOrderid is: " + serviceOrderId)
 352                 }
 353                 else{
 354                         logger.error("Post ServiceOrder Received a Bad Response Code. Response Code is: " + responseCode)
 355 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 500, "Post ServiceOrder Received a bad response from 3rdONAP External API")
 356                 }
 357                 }catch(Exception e) {
 358                         logger.error("doDeleteE2ESIin3rdONAP exception:" + e.getMessage())
 359                 }
 360                 logger.info( "***** Exit doDeleteE2ESIin3rdONAP *****")
 361         }
 362
 363
 364         public void getE2ESIProgressin3rdONAP(DelegateExecution execution) {
 365                 logger.info(" ***** Started getE2ESIProgressin3rdONAP *****")
 366         try {
 367
 368                 String extAPIPath = execution.getVariable("ExternalAPIURL")
 369                 extAPIPath += "/" + execution.getVariable("ServiceOrderId")
 370                 logger.debug("getE2ESIProgressin3rdONAP delete externalAPIURL is: " + extAPIPath)
 371
 372                 ExternalAPIUtil externalAPIUtil = new ExternalAPIUtilFactory().create()
 373
 374                 Response response = externalAPIUtil.executeExternalAPIGetCall(execution, extAPIPath)
 375
 376                 int responseCode = response.getStatus()
 377                 execution.setVariable(Prefix + "GetServiceOrderResponseCode", responseCode)
 378                 logger.debug("Get ServiceOrder response code is: " + responseCode)
 379
 380                 String extApiResponse = response.readEntity(String.class)
 381                 JSONObject responseObj = new JSONObject(extApiResponse)
 382                 execution.setVariable(Prefix + "GetServiceOrderResponse", extApiResponse)
 383
 384                 logger.debug( "getE2ESIProgressin3rdONAP delete response body is: " + extApiResponse)
 385
 386                 //Process Response //200 OK 201 CREATED 202 ACCEPTED
 387                 if(responseCode == 200 || responseCode == 201 || responseCode == 202 )
 388                 {
 389                         logger.debug("Get ServiceOrder Received a Good Response")
 390
 391                         String orderState = responseObj.get("state")
 392                         if("REJECTED".equalsIgnoreCase(orderState)) {
 393                                 execution.setVariable("progress", 100)
 394                                 execution.setVariable("status", "error")
 395                                 execution.setVariable("statusDescription", "Delete Service Order Status is REJECTED")
 396                                 return
 397                         }
 398
 399                         JSONArray items = responseObj.getJSONArray("orderItem")
 400                         JSONObject item = items[0]
 401                         JSONObject service = item.get("service")
 402                         String sppartnerServiceId = service.get("id")
 403                         if(sppartnerServiceId == null || sppartnerServiceId.equals("null")) {
 404                                 execution.setVariable("progress", 100)
 405                                 execution.setVariable("status", "error")
 406                                 execution.setVariable("statusDescription", "Delete Service Order Status get null sppartnerServiceId")
 407                                 logger.error("null sppartnerServiceId while getting progress from externalAPI")
 408                                 return
 409                         }
 410                         execution.setVariable(Prefix + "SppartnerServiceId", sppartnerServiceId)
 411
 412                         String serviceOrderState = item.get("state")
 413                         execution.setVariable(Prefix + "SuccessIndicator", true)
 414                         execution.setVariable("ServiceOrderState", serviceOrderState)
 415
 416                         // Get serviceOrder State and process progress
 417                         if("ACKNOWLEDGED".equalsIgnoreCase(serviceOrderState)) {
 418                                 execution.setVariable("progress", 15)
 419                                 execution.setVariable("status", "processing")
 420                                 execution.setVariable("statusDescription", "Delete Service Order Status is " + serviceOrderState)
 421                         }
 422                         else if("INPROGRESS".equalsIgnoreCase(serviceOrderState)) {
 423                                 execution.setVariable("progress", 40)
 424                                 execution.setVariable("status", "processing")
 425                                 execution.setVariable("statusDescription", "Delete Service Order Status is " + serviceOrderState)
 426                         }
 427                         else if("COMPLETED".equalsIgnoreCase(serviceOrderState)) {
 428                                 execution.setVariable("progress", 100)
 429                                 execution.setVariable("status", "finished")
 430                                 execution.setVariable("statusDescription", "Delete Service Order Status is " + serviceOrderState)
 431                         }
 432                         else if("FAILED".equalsIgnoreCase(serviceOrderState)) {
 433                                 execution.setVariable("progress", 100)
 434                                 execution.setVariable("status", "error")
 435                                 execution.setVariable("statusDescription", "Delete Service Order Status is " + serviceOrderState)
 436                         }
 437                         else {
 438                                 execution.setVariable("progress", 100)
 439                                 execution.setVariable("status", "error")
 440                                 execution.setVariable("statusDescription", "Delete Service Order Status is unknown")
 441                         }
 442                 }
 443                 else{
 444                         logger.debug("Get ServiceOrder Received a Bad Response Code. Response Code is: " + responseCode)
 445                         execution.setVariable("progress", 100)
 446                         execution.setVariable("status", "error")
 447                         execution.setVariable("statusDescription", "Get Delete ServiceOrder Received a bad response")
 448 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 500, "Get Delete ServiceOrder Received a bad response from 3rdONAP External API")
 449                 }
 450         }catch(Exception e) {
 451             execution.setVariable("progress", 100)
 452             execution.setVariable("status", "error")
 453             execution.setVariable("statusDescription", "Get Delete ServiceOrder Exception")
 454             logger.error("getE2ESIProgressin3rdONAP exception:" + e.getMessage())
 455         }
 456                 logger.info( "***** Exit getE2ESIProgressin3rdONAP *****")
 457         }
 458
 459         /**
 460          * delay 5 sec
 461          */
 462         public void timeDelay(DelegateExecution execution) {
 463                 try {
 464                         Thread.sleep(5000)
 465                 } catch(InterruptedException e) {
 466                         logger.error("Time Delay exception" + e )
 467                 }
 468         }
 469
 470         private void getSPPartnerInAAI(DelegateExecution execution) {
 471                 logger.info(" ***** Started getSPPartnerInAAI *****")
 472         try {
 473                 String id = execution.getVariable(Prefix + "SppartnerId")
 474
 475                 AAIResourcesClient client = new AAIResourcesClient()
 476                 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SP_PARTNER, id)
 477                 SpPartner sp = client.get(uri).asBean(SpPartner.class).get()
 478
 479                 logger.debug("GET sppartner Received a Good Response")
 480                 execution.setVariable(Prefix + "SuccessIndicator", true)
 481                 execution.setVariable(Prefix + "FoundIndicator", true)
 482
 483 //              String sppartnerId = sp.getSpPartnerId()
 484 //              execution.setVariable(Prefix + "SppartnerId", sppartnerId)
 485 //              logger.debug(" SppartnerId is: " + sppartnerId)
 486                 String sppartnerUrl = sp.getUrl()
 487                 execution.setVariable(Prefix + "SppartnerUrl", sppartnerUrl)
 488                 logger.debug(" SppartnerUrl is: " + sppartnerUrl)
 489                 String callSource = sp.getCallsource()
 490                 execution.setVariable(Prefix + "CallSource", callSource)
 491                 logger.debug(" CallSource is: " + callSource)
 492                 String sppartnerVersion = sp.getResourceVersion()
 493                 execution.setVariable(Prefix + "SppartnerVersion", sppartnerVersion)
 494                 logger.debug(" Resource Version is: " + sppartnerVersion)
 495         } catch (Exception ex) {
 496             String msg = "Exception in Delete3rdONAPE2EServiceInstance.saveSPPartnerInAAI. " + ex.getMessage()
 497             logger.debug(msg)
 498 //            throw new BpmnError("MSOWorkflowException")
 499         }
 500
 501                 logger.info( "***** Exit getSPPartnerInAAI *****")
 502         }
 503
 504         public void deleteSPPartnerInAAI(DelegateExecution execution) {
 505                 logger.info(" ***** Started deleteSPPartnerInAAI *****")
 506         try {
 507
 508                 String sppartnerId = execution.getVariable(Prefix + "SppartnerId")
 509
 510                 AAIResourcesClient client = new AAIResourcesClient()
 511                 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SP_PARTNER, sppartnerId)
 512                 client.delete(uri)
 513                 logger.debug("Delete sppartner Received a Good Response")
 514                 execution.setVariable(Prefix + "SuccessIndicator", true)
 515         } catch (Exception ex) {
 516             String msg = "Exception in Delete3rdONAPE2EServiceInstance.deleteSPPartnerInAAI. " + ex.getMessage()
 517             logger.debug(msg)
 518 //            throw new BpmnError("MSOWorkflowException")
 519         }
 520
 521
 522                 logger.info( "**** Exit deleteSPPartnerInAAI ****")
 523         }
 524
 525         private void setProgressUpdateVariables(DelegateExecution execution, String body) {
 526                 def dbAdapterEndpoint = UrnPropertiesReader.getVariable("mso.adapters.openecomp.db.endpoint", execution)
 527                 execution.setVariable("CVFMI_dbAdapterEndpoint", dbAdapterEndpoint)
 528                 execution.setVariable("CVFMI_updateResOperStatusRequest", body)
 529         }
 530
 531         public void postProcess(DelegateExecution execution){
 532                 logger.info(" ***** Started postProcess *****")
 533                 String responseCode = execution.getVariable(Prefix + "PutSppartnerResponseCode")
 534                 String responseObj = execution.getVariable(Prefix + "PutSppartnerResponse")
 535
 536                 logger.info("response from AAI for put sppartner, response code :" + responseCode + "  response object :" + responseObj)
 537                 logger.info(" ***** Exit postProcess *****")
 538         }
 539
 540         public void sendSyncResponse (DelegateExecution execution) {
 541                 logger.debug(" *** sendSyncResponse *** ")
 542
 543                 try {
 544                         String operationStatus = "finished"
 545                         // RESTResponse for main flow
 546                         String resourceOperationResp = """{"operationStatus":"${operationStatus}"}""".trim()
 547                         logger.debug(" sendSyncResponse to APIH:" + "\n" + resourceOperationResp)
 548                         sendWorkflowResponse(execution, 202, resourceOperationResp)
 549                         execution.setVariable("sentSyncResponse", true)
 550
 551                 } catch (Exception ex) {
 552                         String msg = "Exceptuion in sendSyncResponse:" + ex.getMessage()
 553                         logger.debug(msg)
 554 //                      exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 555                 }
 556                 logger.debug(" ***** Exit sendSyncResopnse *****")
 557         }
 558 }