gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
   7  * ================================================================================
   8  * Modifications Copyright (c) 2019 Samsung
   9  * ================================================================================
  10  * Licensed under the Apache License, Version 2.0 (the "License");
  11  * you may not use this file except in compliance with the License.
  12  * You may obtain a copy of the License at
  13  *
  14  *      http://www.apache.org/licenses/LICENSE-2.0
  15  *
  16  * Unless required by applicable law or agreed to in writing, software
  17  * distributed under the License is distributed on an "AS IS" BASIS,
  18  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  19  * See the License for the specific language governing permissions and
  20  * limitations under the License.
  21  * ============LICENSE_END=========================================================
  22  */
  23
  24 package org.onap.so.bpmn.infrastructure.scripts
  25
  26
  27 import static org.apache.commons.lang3.StringUtils.*;
  28
  29 import groovy.xml.XmlUtil
  30 import groovy.json.*
  31
  32 import org.onap.so.bpmn.core.json.JsonUtils
  33 import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor
  34 import org.onap.so.bpmn.common.scripts.SDNCAdapterUtils
  35 import org.onap.so.bpmn.core.RollbackData
  36 import org.onap.so.bpmn.core.WorkflowException
  37 import org.slf4j.Logger
  38 import org.slf4j.LoggerFactory
  39 import org.onap.so.logger.MessageEnum
  40 import org.onap.so.bpmn.common.scripts.ExceptionUtil;
  41 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri
  42 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory
  43 import org.onap.aaiclient.client.aai.AAIObjectType
  44 import org.onap.aaiclient.client.aai.AAIResourcesClient
  45
  46 import java.util.UUID;
  47
  48 import org.camunda.bpm.engine.delegate.BpmnError
  49 import org.camunda.bpm.engine.delegate.DelegateExecution
  50 import org.json.JSONObject;
  51 import org.apache.commons.lang3.*
  52 import org.apache.commons.codec.binary.Base64;
  53 import org.springframework.web.util.UriUtils;
  54 /**
  55  * This groovy class supports the <class>DoCreateServiceInstanceRollback.bpmn</class> process.
  56  *
  57  * Inputs:
  58  * @param - msoRequestId
  59  * @param - rollbackData with
  60  *          globalCustomerId
  61  *                      subscriptionServiceType
  62  *                      serviceInstanceId
  63  *                      disableRollback
  64  *                      rollbackAAI
  65  *                      rollbackSDNC
  66  *                      sdncRollbackRequest
  67  *
  68  *
  69  * Outputs:
  70  * @param - rollbackError
  71  * @param - rolledBack (no localRB->null, localRB F->false, localRB S->true)
  72  *
  73  */
  74 public class DoCreateE2EServiceInstanceRollback extends AbstractServiceTaskProcessor{
  75
  76     private static final Logger logger = LoggerFactory.getLogger( DoCreateE2EServiceInstanceRollback.class);
  77         String Prefix="DCRESIRB_"
  78
  79         public void preProcessRequest(DelegateExecution execution) {
  80                 def isDebugEnabled = execution.getVariable("isDebugLogEnabled")
  81                 execution.setVariable("prefix",Prefix)
  82                 String msg = ""
  83                 logger.trace("Start preProcessRequest")
  84                 execution.setVariable("rollbackAAI",false)
  85                 execution.setVariable("rollbackSDNC",false)
  86
  87                 try {
  88                         def rollbackData = execution.getVariable("rollbackData")
  89                         logger.debug("RollbackData:" + rollbackData)
  90
  91                         if (rollbackData != null) {
  92                                 if (rollbackData.hasType("SERVICEINSTANCE")) {
  93
  94                                         def serviceInstanceId = rollbackData.get("SERVICEINSTANCE", "serviceInstanceId")
  95                                         execution.setVariable("serviceInstanceId", serviceInstanceId)
  96
  97                                         def subscriptionServiceType = rollbackData.get("SERVICEINSTANCE", "subscriptionServiceType")
  98                                         execution.setVariable("subscriptionServiceType", subscriptionServiceType)
  99
 100                                         def globalSubscriberId  = rollbackData.get("SERVICEINSTANCE", "globalSubscriberId")
 101                                         execution.setVariable("globalSubscriberId", globalSubscriberId)
 102
 103                                         def rollbackAAI = rollbackData.get("SERVICEINSTANCE", "rollbackAAI")
 104                                         if ("true".equals(rollbackAAI))
 105                                         {
 106                                                 execution.setVariable("rollbackAAI",true)
 107                                         }
 108
 109                                         def rollbackSDNC = rollbackData.get("SERVICEINSTANCE", "rollbackSDNC")
 110                                         if ("true".equals(rollbackSDNC))
 111                                         {
 112                                                 execution.setVariable("rollbackSDNC", true)
 113                                         }
 114
 115                                         if (execution.getVariable("rollbackAAI") != true && execution.getVariable("rollbackSDNC") != true)
 116                                         {
 117                                                 execution.setVariable("skipRollback", true)
 118                                         }
 119
 120                                         def sdncDelete = rollbackData.get("SERVICEINSTANCE", "sdncDelete")
 121                                         execution.setVariable("sdncDelete", sdncDelete)
 122                                         def sdncDeactivate = rollbackData.get("SERVICEINSTANCE", "sdncDeactivate")
 123                                         execution.setVariable("sdncDeactivate", sdncDeactivate)
 124                                         logger.debug("sdncDeactivate:\n" + sdncDeactivate)
 125                                         logger.debug("sdncDelete:\n" + sdncDelete)
 126                                 }
 127                                 else {
 128                                         execution.setVariable("skipRollback", true)
 129                                 }
 130                         }
 131                         else {
 132                                 execution.setVariable("skipRollback", true)
 133                         }
 134                         if (execution.getVariable("disableRollback").equals("true" ))
 135                         {
 136                                 execution.setVariable("skipRollback", true)
 137                         }
 138
 139                 } catch (BpmnError e) {
 140                         throw e;
 141                 } catch (Exception ex){
 142                         msg = "Exception in Create ServiceInstance Rollback preProcessRequest " + ex.getMessage()
 143                         logger.debug(msg)
 144                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) //TODO how does this even compile without exceptionUtil being declared
 145                 }
 146                 logger.trace("Exit preProcessRequest ")
 147         }
 148
 149         public void validateSDNCResponse(DelegateExecution execution, String response, String method) {
 150
 151                 logger.trace("validateSDNCResponse")
 152                 String msg = ""
 153                 try {
 154                         WorkflowException workflowException = execution.getVariable("WorkflowException")
 155                         boolean successIndicator = execution.getVariable("SDNCA_SuccessIndicator")
 156                         logger.debug("SDNCResponse: " + response)
 157                         logger.debug("workflowException: " + workflowException)
 158
 159                         SDNCAdapterUtils sdncAdapterUtils = new SDNCAdapterUtils()
 160                         sdncAdapterUtils.validateSDNCResponse(execution, response, workflowException, successIndicator)
 161
 162                         if(execution.getVariable(Prefix + 'sdncResponseSuccess') == true){
 163                                 msg = "SDNC Adapter service-instance rollback successful for " + method
 164                                 logger.debug(msg)
 165                         }else{
 166                                 execution.setVariable("rolledBack", false)
 167                                 msg =  "Error Response from SDNC Adapter service-instance rollback for " + method
 168                                 execution.setVariable("rollbackError", msg)
 169                                 logger.debug(msg)
 170                                 throw new BpmnError("MSOWorkflowException")
 171                         }
 172                 } catch (BpmnError e) {
 173                         throw e;
 174                 } catch (Exception ex){
 175                         msg = "Exception in Create ServiceInstance rollback for "  + method  + " Exception:" + ex.getMessage()
 176                         logger.debug(msg)
 177                         exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)
 178                 }
 179                 logger.trace("Exit validateSDNCResponse ")
 180         }
 181
 182         /**
 183          * Deletes the service instance in aai
 184          */
 185         public void deleteServiceInstance(DelegateExecution execution) {
 186                 logger.trace("Started Delete Service Instance")
 187                 try {
 188                         String globalCustId = execution.getVariable("globalSubscriberId")
 189                         String serviceType = execution.getVariable("subscriptionServiceType")
 190                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 191
 192                         AAIResourcesClient resourceClient = new AAIResourcesClient();
 193                         AAIResourceUri serviceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, globalCustId, serviceType, serviceInstanceId)
 194                         resourceClient.delete(serviceInstanceUri)
 195
 196                         logger.trace("Completed Delete Service Instance")
 197                 }catch(Exception e){
 198                         logger.debug("Error occured within deleteServiceInstance method: " + e)
 199                 }
 200         }
 201
 202         public void postProcessRequest(DelegateExecution execution) {
 203
 204                 logger.trace("postProcessRequest")
 205                 String msg = ""
 206                 try {
 207                         execution.setVariable("rollbackData", null)
 208                         String serviceInstanceId = execution.getVariable("serviceInstanceId")
 209                         boolean rollbackAAI = execution.getVariable("rollbackAAI")
 210                         boolean rollbackSDNC = execution.getVariable("rollbackSDNC")
 211                         if (rollbackAAI || rollbackSDNC)
 212                         {
 213                                 execution.setVariable("rolledBack", true)
 214                         }
 215                         if (rollbackAAI)
 216                         {
 217                                 boolean succInAAI = execution.getVariable("GENDS_SuccessIndicator")
 218                                 if(!succInAAI){
 219                                         execution.setVariable("rolledBack", false) //both sdnc and aai must be successful to declare rollback Succesful
 220                                         execution.setVariable("rollbackError", "Error deleting service-instance in AAI for rollback")
 221                                         logger.debug("Error deleting service-instance in AAI for rollback", + serviceInstanceId)
 222                                 }
 223                         }
 224                         logger.trace("Exit postProcessRequest ")
 225
 226                 } catch (BpmnError e) {
 227                         msg = "Exception in Create ServiceInstance Rollback postProcessRequest. " + e.getMessage()
 228                         logger.debug(msg)
 229                 } catch (Exception ex) {
 230                         msg = "Exception in Create ServiceInstance Rollback postProcessRequest. " + ex.getMessage()
 231                         logger.debug(msg)
 232                 }
 233
 234         }
 235
 236         public void processRollbackException(DelegateExecution execution){
 237
 238                 logger.trace("processRollbackException")
 239                 try{
 240                         logger.debug("Caught an Exception in DoCreateServiceInstanceRollback")
 241                         execution.setVariable("rollbackData", null)
 242                         execution.setVariable("rollbackError", "Caught exception in ServiceInstance Create Rollback")
 243                         execution.setVariable("WorkflowException", null)
 244
 245                 }catch(BpmnError b){
 246                         logger.debug("BPMN Error during processRollbackExceptions Method: ")
 247                 }catch(Exception e){
 248                         logger.debug("Caught Exception during processRollbackExceptions Method: " + e.getMessage())
 249                 }
 250
 251                 logger.trace(" Exit processRollbackException")
 252         }
 253
 254         public void processRollbackJavaException(DelegateExecution execution){
 255
 256                 logger.trace("processRollbackJavaException")
 257                 try{
 258                         execution.setVariable("rollbackData", null)
 259                         execution.setVariable("rollbackError", "Caught Java exception in ServiceInstance Create Rollback")
 260                         logger.debug("Caught Exception in processRollbackJavaException")
 261
 262                 }catch(Exception e){
 263                         logger.debug("Caught Exception in processRollbackJavaException " + e.getMessage())
 264                 }
 265                 logger.trace("Exit processRollbackJavaException")
 266         }
 267
 268 }