gerrit.onap Code Review - so.git/blob

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * OPENECOMP - SO\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package org.openecomp.mso.bpmn.infrastructure.scripts;\r
  22 \r
  23 import static org.apache.commons.lang3.StringUtils.*;\r
  24 import groovy.xml.XmlUtil\r
  25 import groovy.json.*\r
  26 import org.openecomp.mso.bpmn.common.scripts.AbstractServiceTaskProcessor \r
  27 import org.openecomp.mso.bpmn.common.scripts.ExceptionUtil \r
  28 import org.openecomp.mso.bpmn.common.scripts.VidUtils \r
  29 import org.openecomp.mso.bpmn.core.WorkflowException \r
  30 import org.openecomp.mso.bpmn.core.json.JsonUtils \r
  31 import org.openecomp.mso.rest.APIResponse\r
  32 \r
  33 import java.util.UUID;\r
  34 \r
  35 import org.camunda.bpm.engine.delegate.BpmnError \r
  36 import org.camunda.bpm.engine.runtime.Execution\r
  37 import org.apache.commons.lang3.*\r
  38 import org.apache.commons.codec.binary.Base64;\r
  39 import org.springframework.web.util.UriUtils\r
  40 \r
  41 /**\r
  42  * This groovy class supports the <class>CreateGenericE2EServiceInstance.bpmn</class> process.\r
  43  * flow for E2E ServiceInstance Create\r
  44  */\r
  45 public class CreateGenericE2EServiceInstance extends AbstractServiceTaskProcessor {\r
  46 \r
  47     ExceptionUtil exceptionUtil = new ExceptionUtil()\r
  48 \r
  49     JsonUtils jsonUtil = new JsonUtils()\r
  50 \r
  51     VidUtils vidUtils = new VidUtils()\r
  52 \r
  53     public void preProcessRequest (Execution execution) {\r
  54            def isDebugEnabled=execution.getVariable("isDebugLogEnabled")\r
  55        String msg = ""\r
  56        utils.log("DEBUG", " *** preProcessRequest() *** ", isDebugEnabled)\r
  57        try {\r
  58 \r
  59            String siRequest = execution.getVariable("bpmnRequest")\r
  60            utils.logAudit(siRequest)\r
  61 \r
  62            String requestId = execution.getVariable("mso-request-id")\r
  63            execution.setVariable("msoRequestId", requestId)\r
  64            utils.log("DEBUG", "Input Request:" + siRequest + " reqId:" + requestId, isDebugEnabled)\r
  65 \r
  66            String serviceInstanceId = execution.getVariable("serviceInstanceId")\r
  67            if (isBlank(serviceInstanceId)) {\r
  68                serviceInstanceId = UUID.randomUUID().toString()\r
  69            }\r
  70            utils.log("DEBUG", "Generated new Service Instance:" + serviceInstanceId, isDebugEnabled)\r
  71            serviceInstanceId = UriUtils.encode(serviceInstanceId,"UTF-8")\r
  72            execution.setVariable("serviceInstanceId", serviceInstanceId)\r
  73 \r
  74            //subscriberInfo, TBD , there is no globalSubscriberId in R1 for E2E Service.\r
  75            //requestInfo TBD , there is no requestDetails for R1 E2E service\r
  76 \r
  77            //set service Instance Name\r
  78            execution.setVariable("serviceInstanceName", jsonUtil.getJsonValue(siRequest, "service.name"))\r
  79            execution.setVariable("serviceDescription", jsonUtil.getJsonValue(siRequest, "service.description"))\r
  80            execution.setVariable("templateId", jsonUtil.getJsonValue(siRequest, "service.templateId"))\r
  81      \r
  82            //serviceParamters\r
  83            String serviceParamters = jsonUtil.getJsonValue(siRequest, "service.parameters")\r
  84            if (isBlank(serviceParamters)) {\r
  85                msg = "Input service paramters is null"\r
  86                utils.log("DEBUG", msg, isDebugEnabled)\r
  87                exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg)\r
  88            } else\r
  89            {\r
  90                execution.setVariable("serviceParamters", serviceParamters)\r
  91            }\r
  92 \r
  93            utils.log("DEBUG", "service parameters:" + serviceParamters,  isDebugEnabled)\r
  94        } catch (BpmnError e) {\r
  95            throw e;\r
  96        } catch (Exception ex){\r
  97            msg = "Exception in preProcessRequest " + ex.getMessage()\r
  98            utils.log("DEBUG", msg, isDebugEnabled)\r
  99            exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg)\r
 100        }\r
 101        utils.log("DEBUG"," ***** Exit preProcessRequest *****",  isDebugEnabled)\r
 102         }\r
 103 \r
 104     public void sendSyncResponse(Execution execution) {\r
 105     }\r
 106 \r
 107     public void preCreateRequest(Execution execution) {\r
 108     }\r
 109 \r
 110     public void postConfigRequest(Execution execution) {\r
 111     }\r
 112 \r
 113     public void preVFCRequest(Execution execution) {\r
 114     }\r
 115 \r
 116     public void preAdaptorDataRequest(Execution execution) {\r
 117     }\r
 118 \r
 119     public void preSDNCRequest(Execution execution) {\r
 120     }\r
 121 }\r