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
  24
  25 import static org.apache.commons.lang3.StringUtils.*;
  26
  27 import org.apache.commons.lang3.*
  28 import org.camunda.bpm.engine.delegate.BpmnError
  29 import org.camunda.bpm.engine.delegate.DelegateExecution
  30 import org.onap.so.bpmn.common.scripts.AaiUtil
  31 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
  32 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  33 import org.onap.so.bpmn.common.scripts.MsoUtils
  34 import org.onap.so.bpmn.core.WorkflowException
  35 import org.onap.aaiclient.client.aai.AAIObjectType
  36 import org.onap.aaiclient.client.aai.AAIResourcesClient
  37 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper
  38 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri
  39 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory
  40 import org.slf4j.Logger
  41 import org.slf4j.LoggerFactory
  42 import org.onap.so.bpmn.common.scripts.ExceptionUtil;
  43 import groovy.json.*
  44 import org.onap.so.bpmn.common.scripts.AaiUtil;
  45
  46 /**
  47  * This groovy class supports the <class>DoUpdateE2EServiceInstanceRollback.bpmn</class> process.
  48  *
  49  * Inputs:
  50  * @param - msoRequestId
  51  * @param - rollbackData with
  52  *          globalCustomerId
  53  *                      subscriptionServiceType
  54  *                      serviceInstanceId
  55  *                      disableRollback
  56  *                      rollbackAAI
  57  *                      rollbackAdded
  58  *                      rollbackDeleted
  59  *
  60  *
  61  * Outputs:
  62  * @param - rollbackError
  63  * @param - rolledBack (no localRB->null, localRB F->false, localRB S->true)
  64  *
  65  */
  66 public class DoUpdateE2EServiceInstanceRollback extends AbstractServiceTaskProcessor{
  67     private static final Logger logger = LoggerFactory.getLogger( DoUpdateE2EServiceInstanceRollback.class);
  68
  69
  70         String Prefix="DUPDSIRB_"
  71         ExceptionUtil exceptionUtil = new ExceptionUtil()
  72
  73         public void preProcessRequest(DelegateExecution execution) {
  74                 execution.setVariable("prefix",Prefix)
  75                 String msg = ""
  76                 logger.trace("preProcessRequest ")
  77                 execution.setVariable("rollbackAAI",false)
  78                 execution.setVariable("rollbackAdded",false)
  79                 execution.setVariable("rollbackDeleted",false)
  80
  81                 List addResourceList = execution.getVariable("addResourceList")
  82         List delResourceList = execution.getVariable("delResourceList")
  83         execution.setVariable("addResourceList_o",  addResourceList)
  84         execution.setVariable("delResourceList_o",  delResourceList)
  85         //exchange add and delete resource list
  86         execution.setVariable("addResourceList",  delResourceList)
  87         execution.setVariable("delResourceList",  addResourceList)
  88
  89                 try {
  90                         def rollbackData = execution.getVariable("rollbackData")
  91                         logger.debug("RollbackData:" + rollbackData)
  92
  93                         if (rollbackData != null) {
  94                                 if (rollbackData.hasType("SERVICEINSTANCE")) {
  95
  96                                         def serviceInstanceId = rollbackData.get("SERVICEINSTANCE", "serviceInstanceId")
  97                                         execution.setVariable("serviceInstanceId", serviceInstanceId)
  98
  99                                         def subscriptionServiceType = rollbackData.get("SERVICEINSTANCE", "subscriptionServiceType")
 100                                         execution.setVariable("subscriptionServiceType", subscriptionServiceType)
 101
 102                                         def globalSubscriberId  = rollbackData.get("SERVICEINSTANCE", "globalSubscriberId")
 103                                         execution.setVariable("globalSubscriberId", globalSubscriberId)
 104
 105                                         def rollbackAAI = rollbackData.get("SERVICEINSTANCE", "rollbackAAI")
 106                                         if ("true".equals(rollbackAAI))
 107                                         {
 108                                                 execution.setVariable("rollbackAAI",true)
 109                                         }
 110
 111                                         def rollbackAdded = rollbackData.get("SERVICEINSTANCE", "rollbackAdded")
 112                                         if ("true".equals(rollbackAdded))
 113                                         {
 114                                                 execution.setVariable("rollbackAdded", true)
 115                                         }
 116
 117                                         def rollbackDeleted = rollbackData.get("SERVICEINSTANCE", "rollbackDeleted")
 118                                         if ("true".equals(rollbackDeleted))
 119                                         {
 120                                                 execution.setVariable("rollbackDeleted", true)
 121                                         }
 122
 123                                         if (execution.getVariable("rollbackAAI") != true && execution.getVariable("rollbackAdded") != true
 124                                           && execution.getVariable("rollbackDeleted") != true)
 125                                         {
 126                                                 execution.setVariable("skipRollback", true)
 127                                         }
 128
 129                                 }
 130                                 else {
 131                                         execution.setVariable("skipRollback", true)
 132                                 }
 133                         }
 134                         else {
 135                                 execution.setVariable("skipRollback", true)
 136                         }
 137                         if (execution.getVariable("disableRollback").equals("true" ))
 138                         {
 139                                 execution.setVariable("skipRollback", true)
 140                         }
 141
 142                 } catch (BpmnError e) {
 143                         throw e;
 144                 } catch (Exception ex){
 145                         msg = "Exception in Update ServiceInstance Rollback preProcessRequest " + ex.getMessage()
 146                         logger.debug(msg)
 147                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 148                 }
 149                 logger.trace("Exit preProcessRequest ")
 150         }
 151
 152         public void postProcessRequest(DelegateExecution execution) {
 153                 logger.trace("postProcessRequest ")
 154                 String msg = ""
 155                 try {
 156                         execution.setVariable("rollbackData", null)
 157                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 158                         boolean rollbackAAI = execution.getVariable("rollbackAAI")
 159                         boolean rollbackAdded = execution.getVariable("rollbackAdded")
 160                         boolean rollbackDeleted = execution.getVariable("rollbackDeleted")
 161
 162                         List addResourceList = execution.getVariable("addResourceList_o")
 163                         List delResourceList = execution.getVariable("delResourceList_o")
 164                         execution.setVariable("addResourceList",  addResourceList)
 165                         execution.setVariable("delResourceList",  delResourceList)
 166
 167                         if (rollbackAAI || rollbackAdded || rollbackDeleted)
 168                         {
 169                                 execution.setVariable("rolledBack", true)
 170                         }
 171                         if (rollbackAAI)
 172                         {
 173                                 boolean succInAAI = execution.getVariable("GENDS_SuccessIndicator")
 174                                 if(!succInAAI){
 175                                         execution.setVariable("rolledBack", false) //both sdnc and aai must be successful to declare rollback Succesful
 176                                         execution.setVariable("rollbackError", "Error deleting service-instance in AAI for rollback")
 177                                         logger.debug("Error deleting service-instance in AAI for rollback", + serviceInstanceId)
 178                                 }
 179                         }
 180                         logger.trace("Exit postProcessRequest ")
 181
 182                 } catch (BpmnError e) {
 183                         msg = "Exception in Create ServiceInstance Rollback postProcessRequest. " + e.getMessage()
 184                         logger.debug(msg)
 185                 } catch (Exception ex) {
 186                         msg = "Exception in Create ServiceInstance Rollback postProcessRequest. " + ex.getMessage()
 187                         logger.debug(msg)
 188                 }
 189         }
 190
 191
 192     public void preProcessForAddResource(DelegateExecution execution) {
 193     }
 194
 195     public void postProcessForAddResource(DelegateExecution execution) {
 196     }
 197
 198     public void preProcessForDeleteResource(DelegateExecution execution) {
 199     }
 200
 201     public void postProcessForDeleteResource(DelegateExecution execution) {
 202     }
 203
 204         public void preProcessAAIPUT(DelegateExecution execution) {
 205                 def method = getClass().getSimpleName() + '.preProcessRequest(' +'execution=' + execution.getId() +')'
 206                 logger.info("Entered " + method)
 207                 String msg = ""
 208                 logger.trace("preProcessAAIPUT ")
 209
 210                 String serviceInstanceVersion = execution.getVariable("serviceInstanceVersion_n")
 211 //              execution.setVariable("GENPS_serviceResourceVersion", serviceInstanceVersion)
 212
 213                 //requestDetails.modelInfo.for AAI PUT servieInstanceData
 214                 //requestDetails.requestInfo. for AAI GET/PUT serviceInstanceData
 215                 String serviceInstanceName = execution.getVariable("serviceInstanceName")
 216                 String serviceInstanceId = execution.getVariable("serviceInstanceId")
 217                 //aai serviceType and Role can be setted as fixed value now.
 218                 String aaiServiceType = "E2E Service"
 219                 String aaiServiceRole = "E2E Service"
 220                 String modelInvariantUuid = execution.getVariable("modelInvariantUuid")
 221                 String modelUuid = execution.getVariable("model-version-id-original")
 222
 223                 org.onap.aai.domain.yang.ServiceInstance si = new org.onap.aai.domain.yang.ServiceInstance()
 224                 si.setServiceInstanceId(serviceInstanceId)
 225                 si.setServiceInstanceName(serviceInstanceName)
 226                 si.setServiceType(aaiServiceType)
 227                 si.setServiceRole(aaiServiceRole)
 228                 si.setModelInvariantId(modelInvariantUuid)
 229                 si.setModelVersionId(modelUuid)
 230
 231                 execution.setVariable("serviceInstanceData", si)
 232
 233                 logger.info("Exited " + method)
 234         }
 235
 236         public void updateServiceInstance(DelegateExecution execution) {
 237                 logger.trace("updateServiceInstance ")
 238                 String msg = ""
 239                 try {
 240                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 241                         org.onap.aai.domain.yang.ServiceInstance si = execution.getVariable("serviceInstanceData")
 242
 243                         AAIResourcesClient client = new AAIResourcesClient()
 244                         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId)
 245                         client.update(uri, si)
 246
 247                 } catch (BpmnError e) {
 248                         throw e;
 249                 } catch (Exception ex) {
 250                         msg = "Exception in DoCreateServiceInstance.updateServiceInstance. " + ex.getMessage()
 251                         logger.info(msg)
 252                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 253                 }
 254                 logger.trace("Exit updateServiceInstance ")
 255         }
 256
 257         public void processRollbackException(DelegateExecution execution){
 258                 logger.trace("processRollbackException ")
 259                 try{
 260                         logger.debug("Caught an Exception in DoUpdateE2EServiceInstanceRollback")
 261                         execution.setVariable("rollbackData", null)
 262                         execution.setVariable("rollbackError", "Caught exception in ServiceInstance Update Rollback")
 263                         execution.setVariable("WorkflowException", null)
 264
 265                 }catch(BpmnError b){
 266                         logger.debug("BPMN Error during processRollbackExceptions Method: ")
 267                 }catch(Exception e){
 268                         logger.debug("Caught Exception during processRollbackExceptions Method: " + e.getMessage())
 269                 }
 270
 271                 logger.debug(" Exit processRollbackException")
 272         }
 273
 274         public void processRollbackJavaException(DelegateExecution execution){
 275                 logger.trace("processRollbackJavaException ")
 276                 try{
 277                         execution.setVariable("rollbackData", null)
 278                         execution.setVariable("rollbackError", "Caught Java exception in ServiceInstance Update Rollback")
 279                         logger.debug("Caught Exception in processRollbackJavaException")
 280
 281                 }catch(Exception e){
 282                         logger.debug("Caught Exception in processRollbackJavaException " + e.getMessage())
 283                 }
 284                 logger.trace("Exit processRollbackJavaException ")
 285         }
 286
 287 }