bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/AbstractSdncOperationTask.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask;
  22
  23 import com.fasterxml.jackson.annotation.JsonInclude;
  24 import com.fasterxml.jackson.core.JsonProcessingException;
  25 import com.fasterxml.jackson.databind.ObjectMapper;
  26 import org.apache.commons.lang3.StringUtils;
  27 import org.apache.http.client.ClientProtocolException;
  28 import org.apache.http.client.methods.CloseableHttpResponse;
  29 import org.apache.http.client.methods.HttpGet;
  30 import org.apache.http.client.methods.HttpPost;
  31 import org.apache.http.entity.ContentType;
  32 import org.apache.http.entity.StringEntity;
  33 import org.apache.http.impl.client.CloseableHttpClient;
  34 import org.apache.http.impl.client.HttpClients;
  35 import org.apache.http.util.EntityUtils;
  36 import org.camunda.bpm.engine.delegate.DelegateExecution;
  37 import org.json.JSONObject;
  38 import org.onap.msb.sdk.discovery.common.RouteException;
  39 import org.onap.msb.sdk.httpclient.RestServiceCreater;
  40 import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
  41 import org.openecomp.mso.bpmn.core.BaseTask;
  42 import org.openecomp.mso.bpmn.core.PropertyConfiguration;
  43 import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.GenericResourceApi;
  44 import org.openecomp.mso.logger.MessageEnum;
  45 import org.openecomp.mso.logger.MsoLogger;
  46 import org.openecomp.mso.requestsdb.RequestsDatabase;
  47 import org.openecomp.mso.requestsdb.RequestsDbConstant;
  48 import org.openecomp.mso.requestsdb.ResourceOperationStatus;
  49 import org.slf4j.Logger;
  50 import org.slf4j.LoggerFactory;
  51
  52 import java.io.IOException;
  53 import java.util.HashMap;
  54 import java.util.Iterator;
  55 import java.util.Map;
  56
  57 /**
  58  * Created by 10112215 on 2017/9/16.
  59  */
  60 public abstract class AbstractSdncOperationTask extends BaseTask {
  61
  62     private static final Logger logger = LoggerFactory.getLogger(AbstractSdncOperationTask.class);
  63
  64     private static final String DEFAULT_MSB_IP = "127.0.0.1";
  65     private static final int DEFAULT_MSB_Port = 80;
  66     private static final String SDCADAPTOR_INPUTS = "resourceParameters";
  67     public static final String ONAP_IP = "ONAP_IP";
  68     private RequestsDatabase requestsDB = RequestsDatabase.getInstance();
  69
  70     private static final String postBodyTemplate = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ns=\"http://org.openecomp.mso/requestsdb\"><soapenv:Header/><soapenv:Body>\n"+
  71             "     <ns:updateResourceOperationStatus>\n"+
  72             "                <errorCode>$errorCode</errorCode>\n"+
  73             "                <jobId>$jobId</jobId>\n"+
  74             "                <operType>$operType</operType>\n"+
  75             "                <operationId>$operationId</operationId>\n"+
  76             "                <progress>$progress</progress>\n"+
  77             "                <resourceTemplateUUID>$resourceTemplateUUID</resourceTemplateUUID>\n"+
  78             "                <serviceId>$serviceId</serviceId>\n"+
  79             "                <status>$status</status>\n"+
  80             "                <statusDescription>$statusDescription</statusDescription>\n"+
  81             "     </ns:updateResourceOperationStatus></soapenv:Body></soapenv:Envelope>";
  82
  83     private static final String getBodyTemplate = " <soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ns=\"http://org.openecomp.mso/requestsdb\"><soapenv:Header/><soapenv:Body>\n" +
  84             "     <ns:getResourceOperationStatus>\n" +
  85             "                <operationId>$operationId</operationId>\n" +
  86             "                <resourceTemplateUUID>$resourceTemplateUUID</resourceTemplateUUID>\n" +
  87             "                <serviceId>$serviceId</serviceId>\n" +
  88             "     </ns:getResourceOperationStatus></soapenv:Body></soapenv:Envelope>";
  89
  90
  91     private void updateResOperStatus(ResourceOperationStatus resourceOperationStatus) throws RouteException {
  92         logger.info("AbstractSdncOperationTask.updateResOperStatus begin!");
  93         String url = "http://mso:8080/dbadapters/RequestsDbAdapter";
  94         HttpPost httpPost = new HttpPost(url);
  95         httpPost.addHeader("Authorization", "Basic QlBFTENsaWVudDpwYXNzd29yZDEk");
  96         httpPost.addHeader("Content-type", "application/soap+xml");
  97         String postBody = getPostStringBody(resourceOperationStatus);
  98         httpPost.setEntity(new StringEntity(postBody, ContentType.APPLICATION_XML));
  99         httpPost(url, httpPost);
 100         logger.info("AbstractSdncOperationTask.updateResOperStatus end!");
 101         //requestsDB.updateResOperStatus(resourceOperationStatus);
 102     }
 103
 104     protected String getPostbody(Object inputEntity) {
 105         ObjectMapper objectMapper = new ObjectMapper();
 106         String postBody = null;
 107         try {
 108             objectMapper.setSerializationInclusion(JsonInclude.Include.NON_EMPTY);
 109             postBody = objectMapper.writeValueAsString(inputEntity);
 110         } catch (JsonProcessingException e) {
 111             e.printStackTrace();
 112         }
 113         return postBody;
 114     }
 115
 116     protected String httpPost(String url, HttpPost httpPost) throws RouteException {
 117         logger.info("AbstractSdncOperationTask.httpPost begin!");
 118         String result = null;
 119
 120         String errorMsg;
 121         label91: {
 122             try(CloseableHttpClient httpClient = HttpClients.createDefault()) {
 123                 CloseableHttpResponse closeableHttpResponse = httpClient.execute(httpPost);
 124                 result = EntityUtils.toString(closeableHttpResponse.getEntity());
 125                 logger.info("result = {}", result);
 126 //                LOGGER.info(MessageEnum.RA_RESPONSE_FROM_SDNC, result.toString(), "SDNC", "");
 127                 if(closeableHttpResponse.getStatusLine().getStatusCode() != 200) {
 128                     logger.info("exception: fail for status code = {}", closeableHttpResponse.getStatusLine().getStatusCode());
 129                     throw new RouteException(result, "SERVICE_GET_ERR");
 130                 }
 131
 132                 closeableHttpResponse.close();
 133                 break label91;
 134             } catch (IOException e) {
 135                 errorMsg = url + ":httpPostWithJSON connect faild";
 136                 logger.info("exception: POST_CONNECT_FAILD : {}", errorMsg);
 137                 throwsRouteException(errorMsg, e, "POST_CONNECT_FAILD");
 138             }
 139         }
 140
 141         logger.info("AbstractSdncOperationTask.httpPost end!");
 142         return result;
 143     }
 144
 145     private static void throwsRouteException(String errorMsg, Exception e, String errorCode) throws RouteException {
 146         String msg = errorMsg + ".errorMsg:" + e.getMessage();
 147         logger.info("exception: {}", msg);
 148         throw new RouteException(errorMsg, errorCode);
 149     }
 150
 151     private String getPostStringBody(ResourceOperationStatus resourceOperationStatus) {
 152         logger.info("AbstractSdncOperationTask.getPostStringBody begin!");
 153         String postBody = new String(postBodyTemplate);
 154         postBody = postBody.replace("$errorCode", resourceOperationStatus.getErrorCode());
 155         postBody = postBody.replace("$jobId", resourceOperationStatus.getJobId());
 156         postBody = postBody.replace("$operType", resourceOperationStatus.getOperType());
 157         postBody = postBody.replace("$operationId", resourceOperationStatus.getOperationId());
 158         postBody = postBody.replace("$progress", resourceOperationStatus.getProgress());
 159         postBody = postBody.replace("$resourceTemplateUUID", resourceOperationStatus.getResourceTemplateUUID());
 160         postBody = postBody.replace("$serviceId", resourceOperationStatus.getServiceId());
 161         postBody = postBody.replace("$status", resourceOperationStatus.getStatus());
 162         postBody = postBody.replace("$statusDescription", resourceOperationStatus.getStatusDescription());
 163         logger.info("AbstractSdncOperationTask.getPostStringBody end!");
 164         return postBody;
 165     }
 166
 167     private String getGetStringBody(String serviceId, String operationId, String resourceTemplateUUID) {
 168         logger.info("AbstractSdncOperationTask.getGetStringBody begin!");
 169         String getBody = new String(getBodyTemplate);
 170         getBody = getBody.replace("$operationId", operationId);
 171         getBody = getBody.replace("$resourceTemplateUUID", resourceTemplateUUID);
 172         getBody = getBody.replace("$serviceId", serviceId);
 173         logger.info("AbstractSdncOperationTask.getGetStringBody end!");
 174         return getBody;
 175     }
 176
 177     private ResourceOperationStatus getResourceOperationStatus(String serviceId, String operationId, String resourceTemplateUUID) throws RouteException {
 178         logger.info("AbstractSdncOperationTask.getResourceOperationStatus begin!");
 179         String url = "http://mso:8080/dbadapters/RequestsDbAdapter";
 180         HttpPost httpPost = new HttpPost(url);
 181         httpPost.addHeader("Authorization", "Basic QlBFTENsaWVudDpwYXNzd29yZDEk");
 182         httpPost.addHeader("Content-type", "application/soap+xml");
 183         String getBody = getGetStringBody(serviceId, operationId, resourceTemplateUUID);
 184         httpPost.setEntity(new StringEntity(getBody, ContentType.APPLICATION_XML));
 185         String result = httpPost(url, httpPost);
 186         ResourceOperationStatus resourceOperationStatus = getResourceOperationStatusFromXmlString(result);
 187         logger.info("AbstractSdncOperationTask.getResourceOperationStatus end!");
 188         return resourceOperationStatus;
 189
 190         //return requestsDB.getResourceOperationStatus(serviceId, operationId, resourceTemplateUUID);
 191     }
 192
 193     private String httpGet(String url, HttpGet httpGet) throws RouteException {
 194         logger.info("AbstractSdncOperationTask.httpGet begin!");
 195         String result = "";
 196         String errorMsg;
 197         try(CloseableHttpClient httpClient = HttpClients.createDefault()) {
 198                     CloseableHttpResponse e = httpClient.execute(httpGet);
 199                     result = EntityUtils.toString(e.getEntity());
 200                     logger.info("result = {}", result);
 201                 if (e.getStatusLine().getStatusCode() != 200) {
 202                         logger.info("exception: fail for status code = {}", e.getStatusLine().getStatusCode());
 203                         throw new RouteException(result, "SERVICE_GET_ERR");
 204                     }
 205                     e.close();
 206             } catch (ClientProtocolException e) {
 207                     errorMsg = url + ":httpGetWithJSON connect faild";
 208                     logger.info("exception: GET_CONNECT_FAILD {}", errorMsg);
 209                     throwsRouteException(errorMsg, e, "GET_CONNECT_FAILD");
 210             } catch (IOException e) {
 211                     errorMsg = url + ":httpGetWithJSON connect faild";
 212                     logger.info("exception: GET_CONNECT_FAILD {}", errorMsg);
 213                     throwsRouteException(errorMsg, e, "GET_CONNECT_FAILD");
 214             }
 215
 216         logger.info("AbstractSdncOperationTask.httpGet end!");
 217         return result;
 218     }
 219
 220     private ResourceOperationStatus getResourceOperationStatusFromXmlString(String result) {
 221         logger.info("AbstractSdncOperationTask.getResourceOperationStatusFromXmlString begin!");
 222         ResourceOperationStatus resourceOperationStatus = new ResourceOperationStatus();
 223         resourceOperationStatus.setErrorCode(getValueByName("errorCode", result));
 224         resourceOperationStatus.setJobId(getValueByName("jobId", result));
 225         resourceOperationStatus.setOperType(getValueByName("operType", result));
 226         resourceOperationStatus.setOperationId(getValueByName("operationId", result));
 227         resourceOperationStatus.setProgress(getValueByName("progress", result));
 228         resourceOperationStatus.setResourceTemplateUUID(getValueByName("resourceTemplateUUID", result));
 229         resourceOperationStatus.setServiceId(getValueByName("serviceId", result));
 230         resourceOperationStatus.setStatus(getValueByName("status", result));
 231         resourceOperationStatus.setStatusDescription(getValueByName("statusDescription", result));
 232         logger.info("AbstractSdncOperationTask.getResourceOperationStatusFromXmlString end!");
 233         return resourceOperationStatus;
 234     }
 235
 236     private String getValueByName(String Name, String xml) {
 237         if (!StringUtils.isBlank(xml) && xml.contains(Name)) {
 238             String start = "<" + Name + ">";
 239             String end = "</" + Name + ">";
 240             return xml.substring(xml.indexOf(start), xml.indexOf(end)).replace(start, "");
 241         }
 242         return "";
 243     }
 244
 245     protected static MsoLogger LOGGER = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
 246
 247     @Override
 248     public void execute(DelegateExecution execution) {
 249         logger.info("AbstractSdncOperationTask.execute begin!");
 250         GenericResourceApi genericResourceApiClient = getGenericResourceApiClient(execution);
 251 //        updateProgress(execution, RequestsDbConstant.Status.PROCESSING, null, "10", "execute begin!");
 252         try {
 253             Map<String, String> inputs = getInputs(execution);
 254 //        updateProgress(execution, null, null, "30", "getGenericResourceApiClient finished!");
 255
 256             sendRestrequestAndHandleResponse(execution, inputs, genericResourceApiClient);
 257             execution.setVariable("SDNCA_SuccessIndicator", true);
 258 //            updateProgress(execution, RequestsDbConstant.Status.FINISHED, null, RequestsDbConstant.Progress.ONE_HUNDRED, "execute finished!");
 259         } catch (Exception e) {
 260             logger.info("exception: AbstractSdncOperationTask.fail!");
 261             logger.error("exception: AbstractSdncOperationTask.fail!:", e);
 262             e.printStackTrace();
 263             execution.setVariable("SDNCA_SuccessIndicator", false);
 264             updateProgress(execution, RequestsDbConstant.Status.ERROR, null, "100", "sendRestrequestAndHandleResponse finished!");
 265
 266         }
 267         logger.info("AbstractSdncOperationTask.execute end!");
 268     }
 269
 270     protected Map<String, String> getInputs(DelegateExecution execution) {
 271         logger.info("AbstractSdncOperationTask.getInputs begin!");
 272         Map<String, String> inputs = new HashMap<>();
 273         String json = (String) execution.getVariable(SDCADAPTOR_INPUTS);
 274         if (!StringUtils.isBlank(json)) {
 275             JSONObject jsonObject = new JSONObject(json);
 276             JSONObject paras = jsonObject.getJSONObject("additionalParamForNs");
 277             Iterator<String> iterator = paras.keys();
 278             while (iterator.hasNext()) {
 279                 String key = iterator.next();
 280                 inputs.put(key, paras.getString(key));
 281             }
 282 /*        if (paras.keys().hasNext()) {
 283             paras.keySet().stream().forEach(key -> inputs.put(key, paras.getString((String) key)));
 284         }*/
 285         }
 286         logger.info("AbstractSdncOperationTask.getInputs end!");
 287         return inputs;
 288     }
 289
 290     public abstract void sendRestrequestAndHandleResponse(DelegateExecution execution,
 291                                                           Map<String, String> inputs,
 292                                                           GenericResourceApi genericResourceApiClient) throws Exception;
 293
 294     public void updateProgress(DelegateExecution execution,
 295                                String status,
 296                                String errorCode,
 297                                String progress,
 298                                String statusDescription) {
 299         logger.info("AbstractSdncOperationTask.updateProgress begin!");
 300         String serviceId = (String) execution.getVariable("serviceId");
 301         serviceId = StringUtils.isBlank(serviceId) ? (String) execution.getVariable("serviceInstanceId") : serviceId;
 302         String operationId = (String) execution.getVariable("operationId");
 303         String resourceTemplateUUID = (String) execution.getVariable("resourceUUID");
 304         resourceTemplateUUID = StringUtils.isBlank(resourceTemplateUUID) ? (String) execution.getVariable("resourceTemplateId") : resourceTemplateUUID;
 305         try {
 306             ResourceOperationStatus resourceOperationStatus = getResourceOperationStatus(serviceId, operationId, resourceTemplateUUID);
 307             if (!StringUtils.isBlank(status)) {
 308                 resourceOperationStatus.setStatus(status);
 309             }
 310             if (!StringUtils.isBlank(errorCode)) {
 311                 resourceOperationStatus.setErrorCode(errorCode);
 312             }
 313             if (!StringUtils.isBlank(progress)) {
 314                 resourceOperationStatus.setProgress(progress);
 315             }
 316             if (!StringUtils.isBlank(statusDescription)) {
 317                 resourceOperationStatus.setStatusDescription(statusDescription);
 318             }
 319             updateResOperStatus(resourceOperationStatus);
 320             logger.info("AbstractSdncOperationTask.updateProgress end!");
 321         } catch (Exception exception) {
 322             logger.info("exception: AbstractSdncOperationTask.updateProgress fail!");
 323             logger.error("exception: AbstractSdncOperationTask.updateProgress fail:", exception);
 324             LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " updateProgress catch exception: ", "", this.getTaskName(), MsoLogger.ErrorCode.UnknownError, exception.getClass().toString());
 325         }
 326     }
 327
 328
 329     protected boolean isSend2SdncDirectly() {
 330         logger.info("AbstractSdncOperationTask.isSend2SdncDirectly begin!");
 331         Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
 332         if (properties != null) {
 333             String sdncIp = properties.get("sdnc-ip");
 334             String sdncPort = properties.get("sdnc-port");
 335             if (!StringUtils.isBlank(sdncIp) && isIp(sdncIp) && !StringUtils.isBlank(sdncPort)) {
 336                 logger.info("AbstractSdncOperationTask.isSend2SdncDirectly = true.");
 337                 return true;
 338             }
 339         }
 340         logger.info("AbstractSdncOperationTask.isSend2SdncDirectly = false.");
 341         return false;
 342     }
 343
 344     protected String getSdncIp() {
 345         logger.info("AbstractSdncOperationTask.getSdncIp begin.");
 346         String sdncIp = null;
 347         Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
 348         if (properties != null) {
 349             sdncIp = properties.get("sdnc-ip");
 350         }
 351         String returnIp = StringUtils.isBlank(sdncIp) || !isIp(sdncIp) ? null : sdncIp;
 352         logger.info("AbstractSdncOperationTask.getSdncIp: sdncIp = {}", returnIp);
 353         return returnIp;
 354     }
 355
 356     protected String getSdncPort() {
 357         logger.info("AbstractSdncOperationTask.getSdncPort begin.");
 358         String sdncPort = null;
 359         Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
 360         if (properties != null) {
 361             sdncPort = properties.get("sdnc-port");
 362         }
 363         String returnPort = StringUtils.isBlank(sdncPort) ? null : sdncPort;
 364         logger.info("AbstractSdncOperationTask.getSdncPort: returnPort = {}", sdncPort);
 365         return returnPort;
 366     }
 367
 368     private GenericResourceApi getGenericResourceApiClient(DelegateExecution execution) {
 369         logger.info("AbstractSdncOperationTask.getGenericResourceApiClient begin!");
 370 //        updateProgress(execution, null, null, "20", "getGenericResourceApiClient begin!");
 371         String msbIp = System.getenv().get(ONAP_IP);
 372         int msbPort = DEFAULT_MSB_Port;
 373         Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
 374         if (properties != null) {
 375             if (StringUtils.isBlank(msbIp) || !isIp(msbIp)) {
 376                 msbIp = properties.get("msb-ip");
 377                 if (StringUtils.isBlank(msbIp)) {
 378                     msbIp = getString(properties, "msb.address", DEFAULT_MSB_IP);
 379                 }
 380             }
 381             String strMsbPort = properties.get("msb-port");
 382             if (StringUtils.isBlank(strMsbPort)) {
 383                 strMsbPort = getString(properties, "msb.port", String.valueOf(DEFAULT_MSB_Port));
 384             }
 385             msbPort = Integer.valueOf(strMsbPort);
 386         }
 387         logger.info("AbstractSdncOperationTask.getGenericResourceApiClient msbIp = " + msbIp + " msbPort = " + msbPort);
 388         MSBServiceClient msbClient = new MSBServiceClient(msbIp, msbPort);
 389         RestServiceCreater restServiceCreater = new RestServiceCreater(msbClient);
 390         logger.info("AbstractSdncOperationTask.getGenericResourceApiClient end!");
 391         return restServiceCreater.createService(GenericResourceApi.class);
 392     }
 393
 394     protected boolean isIp(String msbIp) {
 395         return !StringUtils.isBlank(msbIp) && msbIp.split("\\.").length == 4;
 396     }
 397
 398     private String getString(Map<String, String> properties, String name, String defaultValue) {
 399         String vlaue = properties.get(name);
 400         try {
 401             if (!StringUtils.isBlank(vlaue)) {
 402                 return vlaue;
 403             }
 404         } catch (Exception e) {
 405             LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " getMsbIp catch exception: ", "", this.getTaskName(), MsoLogger.ErrorCode.UnknownError, e.getClass().toString());
 406         }
 407         return defaultValue;
 408     }
 409
 410     private Integer getInteger(DelegateExecution execution, String name, Integer defaultValue) {
 411         Integer vlaue = (Integer) execution.getVariable(name);
 412         try {
 413             if (vlaue != null) {
 414                 return vlaue;
 415             }
 416         } catch (Exception e) {
 417             LOGGER.error(MessageEnum.GENERAL_EXCEPTION, " getMsbIp catch exception: ", "", this.getTaskName(), MsoLogger.ErrorCode.UnknownError, e.getClass().toString());
 418         }
 419         return defaultValue;
 420     }
 421
 422     public String getProcessKey(DelegateExecution execution) {
 423         return execution.getProcessEngineServices().getRepositoryService().getProcessDefinition(execution.getProcessDefinitionId()).getKey();
 424     }
 425 }