adapters/mso-sdnc-adapter/src/main/java/org/openecomp/mso/adapters/sdnc/impl/SDNCRestClient.java

   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  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.openecomp.mso.adapters.sdnc.impl;
  23
  24
  25 import java.io.BufferedReader;
  26 import java.io.DataOutputStream;
  27 import java.io.InputStream;
  28 import java.io.InputStreamReader;
  29 import java.net.HttpURLConnection;
  30 import java.net.MalformedURLException;
  31 import java.net.URL;
  32 import java.util.Collections;
  33 import java.util.HashMap;
  34 import java.util.List;
  35 import java.util.Map;
  36
  37 import javax.xml.XMLConstants;
  38 import javax.xml.bind.DatatypeConverter;
  39 import javax.xml.parsers.DocumentBuilder;
  40 import javax.xml.parsers.DocumentBuilderFactory;
  41 import javax.xml.ws.BindingProvider;
  42 import javax.xml.ws.handler.MessageContext;
  43 import javax.xml.xpath.XPath;
  44 import javax.xml.xpath.XPathConstants;
  45 import javax.xml.xpath.XPathFactory;
  46
  47 import org.w3c.dom.Document;
  48 import org.w3c.dom.Element;
  49 import org.w3c.dom.Node;
  50 import org.w3c.dom.NodeList;
  51 import org.openecomp.mso.adapters.sdnc.SDNCAdapterRequest;
  52 import org.openecomp.mso.adapters.sdnc.client.CallbackHeader;
  53 import org.openecomp.mso.adapters.sdnc.client.SDNCAdapterCallbackRequest;
  54 import org.openecomp.mso.adapters.sdnc.client.SDNCCallbackAdapterPortType;
  55 import org.openecomp.mso.adapters.sdnc.client.SDNCCallbackAdapterService;
  56 import org.openecomp.mso.adapters.sdnc.util.SDNCRequestIdUtil;
  57 import org.openecomp.mso.logger.MsoAlarmLogger;
  58 import org.openecomp.mso.logger.MsoLogger;
  59 import org.openecomp.mso.logger.MessageEnum;
  60 import org.openecomp.mso.properties.MsoPropertiesFactory;
  61
  62 //SDNCAdapter to SDNC Rest Client
  63 public class SDNCRestClient implements Runnable {
  64
  65         private MsoPropertiesFactory msoPropertiesFactory;
  66
  67         private SDNCAdapterRequest bpelRequest;
  68
  69         private static MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
  70         private static MsoAlarmLogger alarmLogger = new MsoAlarmLogger();
  71         public static final String MSO_PROP_SDNC_ADAPTER="MSO_PROP_SDNC_ADAPTER";
  72
  73
  74         public SDNCRestClient(SDNCAdapterRequest bpelRequest,MsoPropertiesFactory msoPropFactory) {
  75                 this.bpelRequest = bpelRequest;
  76                 msoPropertiesFactory = msoPropFactory;
  77         }
  78
  79         @Override
  80         public void run()
  81         {
  82
  83                 String action = bpelRequest.getRequestHeader().getSvcAction();
  84                 String operation = bpelRequest.getRequestHeader().getSvcOperation();
  85                 String bpelReqId = bpelRequest.getRequestHeader().getRequestId();
  86                 String callbackUrl = bpelRequest.getRequestHeader().getCallbackUrl();
  87                 MsoLogger.setLogContext(SDNCRequestIdUtil.getSDNCOriginalRequestId (bpelReqId), bpelRequest.getRequestHeader().getSvcInstanceId());
  88                 MsoLogger.setServiceName("SDNCRestClient");
  89
  90                 String sdncReqBody = null;
  91
  92                 msoLogger.debug("BPEL Request:" + bpelRequest.toString());
  93
  94                 RequestTunables rt = new RequestTunables(bpelReqId,
  95                                 bpelRequest.getRequestHeader().getMsoAction(),
  96                                 bpelRequest.getRequestHeader().getSvcOperation(),
  97                                 bpelRequest.getRequestHeader().getSvcAction(),msoPropertiesFactory);
  98                 rt.setTunables();
  99                 rt.setSdncaNotificationUrl(SDNCAdapterPortTypeImpl.getProperty(Constants.MY_URL_PROP, Constants.DEFAULT_MY_URL,msoPropertiesFactory));
 100
 101
 102                 if ("POST".equals(rt.getReqMethod()))
 103                 {
 104                         /* TODO Hibernate
 105                         try {
 106                                 RequestsDatabase.updateBpelUrl(bpelReqId, callbackUrl);
 107                         }
 108                         catch (Exception e1)
 109                         {
 110                                 logger.error("Failed to update DB ActiveRequests with SDNC_CALLBACK_BPEL_URL. Default CallbackUrl will be used for SDNC async notifications", e1);
 111                         }
 112                         */
 113
 114                         Node node = (Node)      bpelRequest.getRequestData();
 115                 Document reqDoc = node.getOwnerDocument();
 116                         sdncReqBody = Utils.genSdncReq(reqDoc, rt);
 117
 118                 }
 119                 //should be more generic if we do RPC then we add the input tags etc, if it is pure REST this is not needed
 120                 else if("PUT".equals(rt.getReqMethod())){
 121                         Node node = (Node)      bpelRequest.getRequestData();
 122                 Document reqDoc = node.getOwnerDocument();
 123                         sdncReqBody = Utils.genSdncPutReq(reqDoc, rt);
 124                 }
 125                 long sdncStartTime = System.currentTimeMillis();
 126                 SDNCResponse sdncResp = getSdncResp(sdncReqBody, rt, msoPropertiesFactory);
 127                 msoLogger.recordMetricEvent (sdncStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully received response from SDNC", "SDNC", action + "." + operation, null);
 128
 129                 msoLogger.debug ("Got the SDNC Response: " + sdncResp.getSdncRespXml());
 130                 msoLogger.debug("Sending reponse to bpel from SDNC rest client");
 131                 long bpelStartTime = System.currentTimeMillis();
 132                 sendRespToBpel(callbackUrl, sdncResp,msoPropertiesFactory);
 133                 msoLogger.recordMetricEvent (bpelStartTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "Successfully send reauest to BPEL", "BPMN", callbackUrl, null);
 134                 return;
 135         }
 136
 137         public static SDNCResponse getSdncResp(String sdncReqBody, RequestTunables rt, MsoPropertiesFactory msoPropertiesFactoryp)
 138         {
 139
 140                 URL url;
 141                 HttpURLConnection con = null;
 142                 DataOutputStream out = null;
 143                 BufferedReader in = null;
 144                 SDNCResponse sdncResp = new SDNCResponse(rt.getReqId());
 145                 StringBuilder response = new StringBuilder();
 146
 147                 msoLogger.info(MessageEnum.RA_SEND_REQUEST_SDNC, rt.toString(), "SDNC", "");
 148                 msoLogger.debug("SDNC Request Body:\n" + sdncReqBody);
 149
 150                 try {
 151
 152                         url = new URL(rt.getSdncUrl());
 153
 154                         con = (HttpURLConnection) url.openConnection();
 155                     con.setConnectTimeout(Integer.parseInt(SDNCAdapterPortTypeImpl.getProperty(Constants.SDNC_CONNECTTIME_PROP, "2000",msoPropertiesFactoryp)));
 156                     con.setReadTimeout(Integer.parseInt(rt.getTimeout()));
 157                         con.setRequestProperty("Accept", "application/yang.data+xml"); //for response in xml
 158                         String userCredentials = msoPropertiesFactoryp.getMsoJavaProperties(MSO_PROP_SDNC_ADAPTER).getEncryptedProperty(Constants.SDNC_AUTH_PROP, Constants.DEFAULT_SDNC_AUTH, Constants.ENCRYPTION_KEY);
 159
 160                         String basicAuth = "Basic " + DatatypeConverter.printBase64Binary(userCredentials.getBytes());
 161                         con.setRequestProperty ("Authorization", basicAuth);
 162                     con.setRequestMethod(rt.getReqMethod());
 163
 164                         // Add request headers
 165                     if ("POST".equals(rt.getReqMethod()) || "PUT".equals(rt.getReqMethod()))
 166                     {
 167                         con.setRequestProperty("Content-type", "application/xml");
 168                         con.setRequestProperty("Content-length",String.valueOf(sdncReqBody.length()));
 169                                 con.setDoOutput(true);
 170                                 out = new DataOutputStream(con.getOutputStream());
 171                                 out.writeBytes(sdncReqBody);
 172                                 out.flush();
 173                                 out.close();
 174                     }
 175
 176                         //Get response
 177                         sdncResp.setRespCode(con.getResponseCode());
 178                         sdncResp.setRespMsg(con.getResponseMessage());
 179
 180                         if (con.getResponseCode()>= 200 && con.getResponseCode()<=299) {
 181                                 in = new BufferedReader(new InputStreamReader(con.getInputStream()));
 182                                 String inputLine;
 183                                 //Not parsing the response -it contains a responseHdr section and data section
 184                                 while ((inputLine = in.readLine()) != null) {
 185                                         response.append(inputLine);
 186                                 }
 187                                 in.close();
 188                         }
 189
 190                         sdncResp.setSdncRespXml(response.toString());
 191                         msoLogger.info(MessageEnum.RA_RESPONSE_FROM_SDNC, sdncResp.toString(), "SDNC", "");
 192                         return(sdncResp);
 193                 }
 194                 catch (Exception e)
 195                 {
 196                         msoLogger.error(MessageEnum.RA_EXCEPTION_COMMUNICATE_SDNC, "SDNC", "", MsoLogger.ErrorCode.BusinessProcesssError, "Exception processing request to SDNC", e);
 197                         //default
 198                         sdncResp.setRespCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
 199                         String respMsg = "Error processing request to SDNC. ";
 200                         StringBuilder sdncErrMsg = new StringBuilder();
 201
 202                         if (e instanceof java.net.SocketTimeoutException )
 203                         {
 204                                 sdncResp.setRespCode(HttpURLConnection.HTTP_CLIENT_TIMEOUT);
 205                                 respMsg = "Request to SDNC timed out. ";
 206                         }
 207                         if (con != null)
 208                         {
 209                                 try { //e1
 210                                         if (con.getResponseCode() != HttpURLConnection.HTTP_OK) //seen in SocketException connection reset
 211                                                 sdncResp.setRespCode(con.getResponseCode());
 212                                         respMsg = respMsg + con.getResponseMessage() + ". ";
 213                                         InputStream is = con.getErrorStream();
 214                                         if (is != null)
 215                                         {
 216                                                 XPathFactory xpathFactory = XPathFactory.newInstance();
 217                                             XPath xpath = xpathFactory.newXPath();
 218                                                 DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
 219                         dbf.setFeature (XMLConstants.FEATURE_SECURE_PROCESSING, true);
 220                                                 DocumentBuilder db;
 221                                                 Document doc = null;
 222                                                 try { //e2
 223                                                         db = dbf.newDocumentBuilder();
 224                                                         doc = db.parse(is);
 225                                                         NodeList errors = (NodeList)xpath.evaluate("errors/error", doc, XPathConstants.NODESET);
 226                                                         for (int i = 0; i < errors.getLength(); i++)
 227                                                         {
 228                                                                 Element error = (Element) errors.item(i);
 229                                                                 String eType = null;
 230                                                                 try {
 231                                                                         eType = xpath.evaluate("error-type", error);
 232                                                                         sdncErrMsg = new StringBuilder(". SDNC Returned-[error-type:" + eType);
 233                                                                 } catch (Exception e3) {
 234                                                                     msoLogger.error (MessageEnum.RA_EVALUATE_XPATH_ERROR, "error-type", error.toString(), "SDNC", "", MsoLogger.ErrorCode.DataError, "Exception while evaluate xpath", e3);
 235                                                                 }
 236
 237                                                                 String eTag = null;
 238                                                                 try {
 239                                                                         eTag = xpath.evaluate( "error-tag", error);
 240                                                                         sdncErrMsg.append(", error-tag:").append(eTag);
 241                                                                 } catch (Exception e3) {
 242                                                                         msoLogger.error (MessageEnum.RA_EVALUATE_XPATH_ERROR, "error-tag", error.toString(), "SDNC", "", MsoLogger.ErrorCode.DataError, "Exception while evaluate xpath", e3);
 243                                                                 }
 244
 245                                                                 String eMsg = null;
 246                                                                 try {
 247                                                                         eMsg = xpath.evaluate("error-message", error);
 248                                                                         sdncErrMsg.append(", error-message:").append(eMsg).append("]");
 249                                                                 } catch (Exception e3) {
 250                                                                         msoLogger.error (MessageEnum.RA_EVALUATE_XPATH_ERROR, "error-message", error.toString(), "SDNC", "", MsoLogger.ErrorCode.DataError, "Exception while evaluate xpath", e3);
 251                                                                 }
 252                                                         }
 253                                                 } catch (Exception e2) {
 254                                                     msoLogger.error (MessageEnum.RA_ANALYZE_ERROR_EXC, "SDNC", "", MsoLogger.ErrorCode.DataError, "Exception while analyse error", e2);
 255                                                 }
 256                                         } //is != null
 257                                 } catch (Exception e1) {
 258                                         msoLogger.error (MessageEnum.RA_ERROR_GET_RESPONSE_SDNC, "SDNC", "", MsoLogger.ErrorCode.BusinessProcesssError, "Exception while get SDNC response", e1);
 259                                 }
 260                         } //con != null
 261
 262                         if (e.getMessage() != null) {
 263                 respMsg = respMsg + e.getMessage();
 264             }
 265             respMsg = respMsg + sdncErrMsg;
 266
 267                         sdncResp.setRespMsg(respMsg);
 268
 269                         msoLogger.error(MessageEnum.RA_EXCEPTION_COMMUNICATE_SDNC, "SDNC", "", MsoLogger.ErrorCode.AvailabilityError, "Exception while communicate with SDNC", e);
 270                         alarmLogger.sendAlarm("MsoInternalError", MsoAlarmLogger.CRITICAL, respMsg);
 271                         return sdncResp;
 272                 }
 273                 finally
 274                 {
 275                         if (con != null) {
 276                 con.disconnect();
 277             }
 278                 }
 279         }
 280
 281         public static void sendRespToBpel(String bpelUrl, SDNCResponse sdncResp,MsoPropertiesFactory msoPropertiesFactoryp)
 282         {
 283                 String error;
 284                 try
 285                 {
 286                         SDNCAdapterCallbackRequest cbReq = new SDNCAdapterCallbackRequest();
 287                         cbReq.setCallbackHeader(new CallbackHeader(sdncResp.getReqId(), Integer.toString(sdncResp.getRespCode()), sdncResp.getRespMsg()));
 288                         if (sdncResp.getSdncRespXml() != null)
 289                         {
 290                                 cbReq.setRequestData(sdncResp.getSdncRespXml());
 291                         }
 292                         msoLogger.info(MessageEnum.RA_CALLBACK_BPEL, cbReq.toString(), "Camunda", "");
 293
 294                         URL wsdlUrl = null;
 295                         try {
 296                                 wsdlUrl = new URL (bpelUrl);
 297                         } catch (MalformedURLException e1) {
 298                                 error = "Caught exception initializing Callback wsdl " + e1.getMessage();
 299                                 msoLogger.error(MessageEnum.RA_INIT_CALLBACK_WSDL_ERR, "Camunda", "", MsoLogger.ErrorCode.DataError, "Exception initializing Callback wsdl", e1);
 300                                 alarmLogger.sendAlarm("MsoInternalError", MsoAlarmLogger.CRITICAL, error);
 301                         }
 302
 303                         SDNCCallbackAdapterService cbSvc = new SDNCCallbackAdapterService();
 304
 305                         SDNCCallbackAdapterPortType cbPort = cbSvc.getSDNCCallbackAdapterSoapHttpPort();
 306
 307                         BindingProvider bp = (BindingProvider)cbPort;
 308
 309                         if(null != wsdlUrl) {
 310                         bp.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, wsdlUrl.toExternalForm());
 311                         }
 312                         else {
 313                             msoLogger.debug("wsdlUrl is NULL:");
 314                         }
 315
 316                         //authentication
 317                         try
 318                         {
 319                                 Map<String, Object> reqCtx = bp.getRequestContext();
 320                                 Map<String, List<String>> headers = new HashMap<>();
 321                                 String userCredentials = msoPropertiesFactoryp.getMsoJavaProperties(MSO_PROP_SDNC_ADAPTER).getEncryptedProperty(Constants.BPEL_AUTH_PROP, Constants.DEFAULT_BPEL_AUTH, Constants.ENCRYPTION_KEY);
 322
 323                                 String basicAuth = "Basic " + DatatypeConverter.printBase64Binary(userCredentials.getBytes());
 324                                 reqCtx.put(MessageContext.HTTP_REQUEST_HEADERS, headers);
 325                                 headers.put ("Authorization", Collections.singletonList(basicAuth));
 326                         }
 327                         catch (Exception e2) {
 328                                 error = "Unable to set authorization in callback request " + e2.getMessage();
 329                                 msoLogger.error(MessageEnum.RA_SET_CALLBACK_AUTH_EXC, "Camunda", "", MsoLogger.ErrorCode.BusinessProcesssError, "Exception - Unable to set authorization in callback request", e2);
 330                                 alarmLogger.sendAlarm("MsoInternalError", MsoAlarmLogger.CRITICAL, error);
 331                         }
 332
 333                         msoLogger.debug("Invoking Bpel Callback. BpelCallbackUrl:" + bpelUrl);
 334                         cbPort.sdncAdapterCallback(cbReq);
 335
 336                 }
 337                 catch (Exception e)
 338                 {
 339                         error = "Error sending BpelCallback request" + e.getMessage();
 340                         msoLogger.error(MessageEnum.RA_CALLBACK_BPEL_EXC, "Camunda", "", MsoLogger.ErrorCode.BusinessProcesssError, "Exception sending BpelCallback request", e);
 341                         alarmLogger.sendAlarm("MsoInternalError", MsoAlarmLogger.CRITICAL, error);
 342                 }
 343                 msoLogger.info(MessageEnum.RA_CALLBACK_BPEL_COMPLETE, "Camunda", "");
 344                 return;
 345         }
 346
 347 }