gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - 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 package org.onap.so.bpmn.infrastructure.scripts
  23 import org.onap.aaiclient.client.aai.AAIResourcesClient
  24 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
  25
  26 import static org.apache.commons.lang3.StringUtils.*;
  27
  28 import org.apache.commons.lang3.*
  29 import org.camunda.bpm.engine.delegate.BpmnError
  30 import org.camunda.bpm.engine.delegate.DelegateExecution
  31 import org.onap.aai.domain.yang.ServiceInstance;
  32 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
  33 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  34 import org.onap.so.bpmn.common.scripts.MsoUtils
  35 import org.onap.so.bpmn.core.RollbackData
  36 import org.onap.so.bpmn.core.WorkflowException
  37 import org.onap.so.bpmn.core.domain.Resource
  38 import org.onap.so.bpmn.core.json.JsonUtils
  39 import org.onap.aaiclient.client.aai.AAIObjectType
  40 import org.onap.aaiclient.client.aai.AAIResourcesClient
  41 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper
  42 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri
  43 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory
  44 import org.springframework.web.util.UriUtils;
  45 import org.slf4j.Logger
  46 import org.slf4j.LoggerFactory
  47
  48 import groovy.json.*
  49
  50
  51 /**
  52  * This groovy class supports the <class>DoUpdateE2EServiceInstance.bpmn</class> process.
  53  *
  54  * Inputs:
  55  * @param - msoRequestId
  56  * @param - globalSubscriberId
  57  * @param - serviceType
  58  * @param - serviceInstanceId
  59  * @param - serviceInstanceName
  60  * @param - serviceModelInfo
  61  * @param - productFamilyId
  62  * @param - uuiRequest
  63  * @param - serviceDecomposition_Target
  64  * @param - serviceDecomposition_Original
  65  * @param - addResourceList
  66  * @param - delResourceList
  67  *
  68  * Outputs:
  69  * @param - rollbackData (localRB->null)
  70  * @param - rolledBack (no localRB->null, localRB F->false, localRB S->true)
  71  * @param - WorkflowException
  72  */
  73 public class DoUpdateE2EServiceInstance extends AbstractServiceTaskProcessor {
  74         private static final Logger logger = LoggerFactory.getLogger( DoUpdateE2EServiceInstance.class);
  75
  76         String Prefix="DUPDSI_"
  77         private static final String DebugFlag = "isDebugEnabled"
  78
  79         ExceptionUtil exceptionUtil = new ExceptionUtil()
  80         JsonUtils jsonUtil = new JsonUtils()
  81
  82         public void preProcessRequest (DelegateExecution execution) {
  83                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
  84                 logger.info(" ***** Enter DoUpdateE2EServiceInstance preProcessRequest *****")
  85
  86                 String msg = ""
  87
  88                 try {
  89                         execution.setVariable("prefix", Prefix)
  90                         //Inputs
  91                         //for AAI GET & PUT & SDNC assignToplology
  92                         String globalSubscriberId = execution.getVariable("globalSubscriberId") //globalCustomerId
  93                         logger.info(" ***** globalSubscriberId *****" + globalSubscriberId)
  94
  95                         //for AAI PUT & SDNC assignTopology
  96                         String serviceType = execution.getVariable("serviceType")
  97                         logger.info(" ***** serviceType *****" + serviceType)
  98
  99                         //for SDNC assignTopology
 100                         String productFamilyId = execution.getVariable("productFamilyId") //AAI productFamilyId
 101
 102                         if (isBlank(globalSubscriberId)) {
 103                                 msg = "Input globalSubscriberId is null"
 104                                 logger.info( msg)
 105                                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 106                         }
 107
 108                         if (isBlank(serviceType)) {
 109                                 msg = "Input serviceType is null"
 110                                 logger.info( msg)
 111                                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 112                         }
 113
 114                         //Generated in parent for AAI
 115                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 116                         if (isBlank(serviceInstanceId)){
 117                                 msg = "Input serviceInstanceId is null"
 118                                 logger.info( msg)
 119                                 exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)
 120                         }
 121
 122                         String serviceInstanceName = execution.getVariable("serviceInstanceName")
 123
 124                         // user params
 125                         String uuiRequest = execution.getVariable("uuiRequest")
 126
 127                         // target model Invariant uuid
 128                         String modelInvariantUuid = jsonUtil.getJsonValue(uuiRequest, "service.serviceInvariantUuid")
 129                         execution.setVariable("modelInvariantUuid", modelInvariantUuid)
 130                         logger.info( "modelInvariantUuid: " + modelInvariantUuid)
 131
 132                         // target model uuid
 133                         String modelUuid = jsonUtil.getJsonValue(uuiRequest, "service.serviceUuid")
 134                         execution.setVariable("modelUuid", modelUuid)
 135
 136                         logger.info("modelUuid: " + modelUuid)
 137
 138                 } catch (BpmnError e) {
 139                         throw e;
 140                 } catch (Exception ex){
 141                         msg = "Exception in preProcessRequest " + ex.getMessage()
 142                         logger.info( msg)
 143                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 144                 }
 145                 logger.info( "======== COMPLETED preProcessRequest Process ======== ")
 146         }
 147
 148
 149         public void preInitResourcesOperStatus(DelegateExecution execution){
 150         def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
 151
 152         logger.info( " ======== STARTED preInitResourcesOperStatus Process ======== ")
 153         try{
 154             String serviceId = execution.getVariable("serviceInstanceId")
 155             String operationId = execution.getVariable("operationId")
 156             String operationType = execution.getVariable("operationType")
 157             String resourceTemplateUUIDs = ""
 158             String result = "processing"
 159             String progress = "0"
 160             String reason = ""
 161             String operationContent = "Prepare service updating"
 162             logger.info( "Generated new operation for Service Instance serviceId:" + serviceId + " operationId:" + operationId + " operationType:" + operationType)
 163             serviceId = UriUtils.encode(serviceId,"UTF-8")
 164             execution.setVariable("serviceInstanceId", serviceId)
 165             execution.setVariable("operationId", operationId)
 166             execution.setVariable("operationType", operationType)
 167
 168                         List<Resource> resourceList = new ArrayList<String>()
 169                         List<Resource> addResourceList =  execution.getVariable("addResourceList")
 170                         List<Resource> delResourceList =  execution.getVariable("delResourceList")
 171                         resourceList.addAll(addResourceList)
 172                         resourceList.addAll(delResourceList)
 173                         for(Resource resource : resourceList){
 174                                 resourceTemplateUUIDs  = resourceTemplateUUIDs + resource.getModelInfo().getModelCustomizationUuid() + ":"
 175                         }
 176
 177             def dbAdapterEndpoint = UrnPropertiesReader.getVariable("mso.adapters.openecomp.db.endpoint", execution)
 178                         execution.setVariable("CVFMI_dbAdapterEndpoint", dbAdapterEndpoint)
 179                         logger.info( "DB Adapter Endpoint is: " + dbAdapterEndpoint)
 180
 181                         String payload =
 182                                 """<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
 183                         xmlns:ns="http://org.onap.so/requestsdb">
 184                         <soapenv:Header/>
 185                         <soapenv:Body>
 186                             <ns:initResourceOperationStatus xmlns:ns="http://org.onap.so/requestsdb">
 187                                                                 <serviceId>${MsoUtils.xmlEscape(serviceId)}</serviceId>
 188                                                                 <operationId>${MsoUtils.xmlEscape(operationId)}</operationId>
 189                                                                 <operationType>${MsoUtils.xmlEscape(operationType)}</operationType>
 190                                                                 <resourceTemplateUUIDs>${MsoUtils.xmlEscape(resourceTemplateUUIDs)}</resourceTemplateUUIDs>
 191                             </ns:initResourceOperationStatus>
 192                         </soapenv:Body>
 193                         </soapenv:Envelope>"""
 194
 195                         payload = utils.formatXml(payload)
 196                         execution.setVariable("CVFMI_initResOperStatusRequest", payload)
 197                         logger.info( "Outgoing initResourceOperationStatus: \n" + payload)
 198
 199         }catch(Exception e){
 200             logger.info( "Exception Occured Processing preInitResourcesOperStatus. Exception is:\n" + e)
 201             execution.setVariable("CVFMI_ErrorResponse", "Error Occurred during preInitResourcesOperStatus Method:\n" + e.getMessage())
 202         }
 203         logger.info( "======== COMPLETED preInitResourcesOperStatus Process ======== ")
 204     }
 205
 206
 207     public void preProcessForAddResource(DelegateExecution execution) {
 208         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 209                 logger.info(" ***** preProcessForAddResource ***** ")
 210
 211             execution.setVariable("operationType", "create")
 212
 213                 execution.setVariable("hasResourcetoAdd", false)
 214                 List<Resource> addResourceList =  execution.getVariable("addResourceList")
 215                 if(addResourceList != null && !addResourceList.isEmpty()) {
 216                         execution.setVariable("hasResourcetoAdd", true)
 217                 }
 218
 219                 logger.info(" *** Exit preProcessForAddResource *** ")
 220     }
 221
 222     public void postProcessForAddResource(DelegateExecution execution) {
 223         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 224                 logger.info(" ***** postProcessForAddResource ***** ")
 225
 226                 execution.setVariable("operationType", "update")
 227
 228                 logger.info(" *** Exit postProcessForAddResource *** ")
 229     }
 230
 231         public void preProcessForDeleteResource(DelegateExecution execution) {
 232                 def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 233                 logger.info(" ***** preProcessForDeleteResource ***** ")
 234
 235                 execution.setVariable("operationType", "delete")
 236
 237                 def  hasResourcetoDelete = false
 238                 List<Resource> delResourceList =  execution.getVariable("delResourceList")
 239                 if(delResourceList != null && !delResourceList.isEmpty()) {
 240                         hasResourcetoDelete = true
 241                 }
 242                 execution.setVariable("hasResourcetoDelete", hasResourcetoDelete)
 243
 244                 if(hasResourcetoDelete) {
 245                         def jsonSlurper = new JsonSlurper()
 246                         String serviceRelationShip = execution.getVariable("serviceRelationShip")
 247                         List relationShipList =  jsonSlurper.parseText(serviceRelationShip)
 248
 249                         //Set the real resource instance id to the decomosed resource list
 250                         for(Resource resource: delResourceList){
 251                                 //reset the resource instance id , because in the decompose flow ,its a random one.
 252                                 resource.setResourceId("");
 253                                 //match the resource-instance-name and the model name
 254                                 if (relationShipList != null) {
 255                                         relationShipList.each {
 256                                                 if(StringUtils.containsIgnoreCase(it.resourceType, resource.getModelInfo().getModelName())){
 257                                                         resource.setResourceId(it.resourceInstanceId);
 258                                                 }
 259                                         }
 260                                 }
 261                         }
 262                 }
 263
 264                 execution.setVariable("deleteResourceList", delResourceList)
 265
 266                 logger.info(" *** Exit preProcessForDeleteResource *** ")
 267         }
 268
 269     public void postProcessForDeleteResource(DelegateExecution execution) {
 270         def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 271                 logger.info(" ***** postProcessForDeleteResource ***** ")
 272
 273                 execution.setVariable("operationType", "update")
 274
 275                 logger.info(" *** Exit postProcessForDeleteResource *** ")
 276     }
 277
 278         public void preProcessAAIPUT(DelegateExecution execution) {
 279                 def method = getClass().getSimpleName() + '.preProcessRequest(' +'execution=' + execution.getId() +')'
 280                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
 281                 logger.info("Entered " + method)
 282                 String msg = ""
 283
 284                 String serviceInstanceVersion = execution.getVariable("serviceInstanceVersion")
 285
 286                 //requestDetails.modelInfo.for AAI PUT servieInstanceData
 287                 //requestDetails.requestInfo. for AAI GET/PUT serviceInstanceData
 288                 String serviceInstanceName = execution.getVariable("serviceInstanceName")
 289                 String serviceInstanceId = execution.getVariable("serviceInstanceId")
 290                 //aai serviceType and Role can be setted as fixed value now.
 291                 String aaiServiceType = "E2E Service"
 292                 String aaiServiceRole = "E2E Service"
 293                 String modelInvariantUuid = execution.getVariable("modelInvariantUuid")
 294                 String modelUuid = execution.getVariable("modelUuid")
 295
 296                 org.onap.aai.domain.yang.ServiceInstance si = new org.onap.aai.domain.yang.ServiceInstance()
 297                 si.setServiceInstanceId(serviceInstanceId)
 298                 si.setServiceInstanceName(serviceInstanceName)
 299                 si.setServiceType(aaiServiceType)
 300                 si.setServiceRole(aaiServiceRole)
 301                 si.setModelInvariantId(modelInvariantUuid)
 302                 si.setModelVersionId(modelUuid)
 303
 304                 execution.setVariable("serviceInstanceData", si)
 305
 306                 logger.info( "Exited " + method)
 307         }
 308
 309         public void updateServiceInstance(DelegateExecution execution) {
 310                 def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 311                 logger.info(" ***** createServiceInstance ***** ")
 312                 String msg = ""
 313                 String serviceInstanceId = execution.getVariable("serviceInstanceId")
 314                 try {
 315                         org.onap.aai.domain.yang.ServiceInstance si = execution.getVariable("serviceInstanceData")
 316
 317             AAIResourcesClient client = new AAIResourcesClient()
 318             AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId)
 319                         client.update(uri, si)
 320
 321                 } catch (BpmnError e) {
 322                         throw e;
 323                 } catch (Exception ex) {
 324                         RollbackData rollbackData = new RollbackData()
 325                         def disableRollback = execution.getVariable("disableRollback")
 326                         rollbackData.put("SERVICEINSTANCE", "disableRollback", disableRollback.toString())
 327                         rollbackData.put("SERVICEINSTANCE", "rollbackAAI", "true")
 328                         rollbackData.put("SERVICEINSTANCE", "serviceInstanceId", serviceInstanceId)
 329                         rollbackData.put("SERVICEINSTANCE", "serviceType", execution.getVariable("serviceType"))
 330                         rollbackData.put("SERVICEINSTANCE", "globalSubscriberId", execution.getVariable("globalSubscriberId"))
 331                         execution.setVariable("rollbackData", rollbackData)
 332
 333                         msg = "Exception in DoCreateServiceInstance.createServiceInstance. " + ex.getMessage()
 334                         logger.info( msg)
 335                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 336                 }
 337                 logger.info(" *** Exit createServiceInstance *** ")
 338         }
 339
 340         public void preProcessRollback (DelegateExecution execution) {
 341                 def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 342                 logger.info(" ***** preProcessRollback ***** ")
 343                 try {
 344
 345                         Object workflowException = execution.getVariable("WorkflowException");
 346
 347                         if (workflowException instanceof WorkflowException) {
 348                                 logger.info( "Prev workflowException: " + workflowException.getErrorMessage())
 349                                 execution.setVariable("prevWorkflowException", workflowException);
 350                                 //execution.setVariable("WorkflowException", null);
 351                         }
 352                 } catch (BpmnError e) {
 353                         logger.info( "BPMN Error during preProcessRollback")
 354                 } catch(Exception ex) {
 355                         String msg = "Exception in preProcessRollback. " + ex.getMessage()
 356                         logger.info( msg)
 357                 }
 358                 logger.info(" *** Exit preProcessRollback *** ")
 359         }
 360
 361         public void postProcessRollback (DelegateExecution execution) {
 362                 def isDebugEnabled=execution.getVariable("isDebugLogEnabled")
 363                 logger.info(" ***** postProcessRollback ***** ")
 364                 String msg = ""
 365                 try {
 366                         Object workflowException = execution.getVariable("prevWorkflowException");
 367                         if (workflowException instanceof WorkflowException) {
 368                                 logger.info( "Setting prevException to WorkflowException: ")
 369                                 execution.setVariable("WorkflowException", workflowException);
 370                         }
 371                         execution.setVariable("rollbackData", null)
 372                 } catch (BpmnError b) {
 373                         logger.info( "BPMN Error during postProcessRollback")
 374                         throw b;
 375                 } catch(Exception ex) {
 376                         msg = "Exception in postProcessRollback. " + ex.getMessage()
 377                         logger.info( msg)
 378                 }
 379                 logger.info(" *** Exit postProcessRollback *** ")
 380         }
 381
 382
 383         public void postConfigRequest(execution){
 384             //now do noting
 385         }
 386
 387
 388 }
 389