[so.git] /

/*-\r
 * ============LICENSE_START=======================================================\r
 * OPENECOMP - SO\r
 * ================================================================================\r
 * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.\r
 * ================================================================================\r
 * Licensed under the Apache License, Version 2.0 (the "License");\r
 * you may not use this file except in compliance with the License.\r
 * You may obtain a copy of the License at\r
 * \r
 *      http://www.apache.org/licenses/LICENSE-2.0\r
 * \r
 * Unless required by applicable law or agreed to in writing, software\r
 * distributed under the License is distributed on an "AS IS" BASIS,\r
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
 * See the License for the specific language governing permissions and\r
 * limitations under the License.\r
 * ============LICENSE_END=========================================================\r
 */\r
\r
package org.openecomp.mso.bpmn.infrastructure.scripts;\r
\r
import static org.apache.commons.lang3.StringUtils.*;\r
import groovy.xml.XmlUtil\r
import groovy.json.*\r
import org.openecomp.mso.bpmn.common.scripts.AbstractServiceTaskProcessor \r
import org.openecomp.mso.bpmn.common.scripts.ExceptionUtil \r
import org.openecomp.mso.bpmn.core.WorkflowException \r
import org.openecomp.mso.bpmn.core.json.JsonUtils \r
import org.openecomp.mso.rest.APIResponse\r
\r
import java.util.UUID;\r
\r
import org.camunda.bpm.engine.delegate.BpmnError \r
import org.camunda.bpm.engine.runtime.Execution\r
import org.apache.commons.lang3.*\r
import org.apache.commons.codec.binary.Base64;\r
import org.springframework.web.util.UriUtils \r
import org.openecomp.mso.rest.RESTClient \r
import org.openecomp.mso.rest.RESTConfig\r
import org.openecomp.mso.rest.APIResponse;\r
\r
/**\r
 * This groovy class supports the <class>DODeleteVFCNetworkServiceInstance.bpmn</class> process.\r
 * flow for E2E ServiceInstance Delete\r
 */\r
public class DODeleteVFCNetworkServiceInstance extends AbstractServiceTaskProcessor {\r
\r
    String deleteUrl = "/vfc/vfcadapters/v1/ns/{nsInstanceId}"\r
            \r
    String terminateUrl = "/vfcvfcadatpers/v1/ns/{nsInstanceId}/terminate"\r
    \r
    String queryJobUrl = "/vfc/vfcadatpers/v1/jobs/{jobId}"\r
    \r
    ExceptionUtil exceptionUtil = new ExceptionUtil()\r
\r
    JsonUtils jsonUtil = new JsonUtils()\r
\r
    /**\r
     * Pre Process the BPMN Flow Request\r
     * Inclouds:\r
     * generate the nsOperationKey\r
     * generate the nsParameters\r
     */\r
    public void preProcessRequest (Execution execution) {         \r
        }\r
\r
    /**\r
     * delete NS task\r
     */\r
    public void deleteNetworkService(Execution execution) {\r
                \r
    }\r
\r
    /**\r
     * instantiate NS task\r
     */\r
    public void terminateNetworkService(Execution execution) {\r
\r
    }\r
\r
    /**\r
     * query NS task\r
     */\r
    public void queryNSProgress(Execution execution) {\r
        String jobId = execution.getVariable("jobId")\r
        String nsOperationKey = excution.getVariable("nsOperationKey");\r
        String url = queryJobUrl.replaceAll("{jobId}", execution.getVariable("jobId")) \r
        APIResponse createRsp = postRequest(url, nsOperationKey)\r
        String returnCode = apiResponse.getStatusCode()\r
        String aaiResponseAsString = apiResponse.getResponseBodyAsString()\r
        String operationStatus = "error"\r
        if(returnCode== "200"){\r
            operationStatus = jsonUtil.getJsonValue(aaiResponseAsString, "responseDescriptor.status")\r
        }\r
        exection.setVariable("operationStatus", operationStatus)\r
    }\r
\r
    /**\r
     * delay 5 sec \r
     */\r
    public void timeDelay(Execution execution) {\r
        try {\r
            Thread.sleep(5000);\r
        } catch(InterruptedException e) {           \r
            taskProcessor.utils.log("ERROR", "Time Delay exception" + e , isDebugEnabled)\r
        }\r
    }\r
\r
    /**\r
     * finish NS task\r
     */\r
    public void finishNSCreate(Execution execution) {\r
        //no need to do anything util now\r
    }\r
\r
    /**\r
     * post request\r
     * url: the url of the request\r
     * requestBody: the body of the request\r
     */\r
    private APIResponse postRequest(String url, String requestBody){\r
        def isDebugEnabled = execution.getVariable("isDebugLogEnabled")\r
        taskProcessor.logDebug( " ======== Started Execute VFC adapter Post Process ======== ", isDebugEnabled)\r
        taskProcessor.logDebug( "url:"+url +"\nrequestBody:"+ requestBody, isDebugEnabled)\r
        APIResponse apiResponse = null\r
        try{\r
            RESTConfig config = new RESTConfig(url);\r
            RESTClient client = new RESTClient(config).addHeader("X-FromAppId", "MSO").addHeader("X-TransactionId", uuid).addHeader("Accept","application/json");\r
            apiResponse = client.httpPost(requestBody)\r
            taskProcessor.logDebug( "response code:"+ apiResponse.getStatusCode() +"\nresponse body:"+ apiResponse.getResponseBodyAsString(), isDebugEnabled)\r
            taskProcessor.logDebug( "======== Completed Execute VF-C adapter Post Process ======== ", isDebugEnabled)\r
        }catch(Exception e){\r
            taskProcessor.utils.log("ERROR", "Exception occured while executing AAI Post Call. Exception is: \n" + e, isDebugEnabled)\r
            throw new BpmnError("MSOWorkflowException")\r
        }        \r
        return apiResponse\r
    }\r
}\r