src/main/java/org/onap/aai/sparky/dal/proxy/processor/AaiUiProxyProcessor.java

   1 /**
   2  * ============LICENSE_START=======================================================
   3  * org.onap.aai
   4  * ================================================================================
   5  * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
   6  * Copyright © 2017 Amdocs
   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  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  22  */
  23 package org.onap.aai.sparky.dal.proxy.processor;
  24
  25 import java.util.Arrays;
  26 import java.util.HashMap;
  27 import java.util.List;
  28 import java.util.Map;
  29 import java.util.Properties;
  30
  31 import javax.json.Json;
  32 import javax.json.JsonObjectBuilder;
  33 import javax.servlet.http.HttpServletRequest;
  34
  35 import org.apache.camel.Exchange;
  36 import org.onap.aai.cl.api.Logger;
  37 import org.onap.aai.cl.eelf.LoggerFactory;
  38 import org.onap.aai.cl.mdc.MdcContext;
  39 import org.onap.aai.restclient.client.OperationResult;
  40 import org.onap.aai.restclient.client.RestClient;
  41 import org.onap.aai.restclient.rest.HttpUtil;
  42 import org.onap.aai.sparky.dal.proxy.config.DataRouterConfig;
  43 import org.onap.aai.sparky.logging.AaiUiMsgs;
  44 import org.onap.aai.sparky.util.ConfigHelper;
  45 import org.onap.aai.sparky.util.Encryptor;
  46 import org.onap.aai.sparky.util.NodeUtils;
  47 import org.onap.aai.sparky.viewandinspect.config.TierSupportUiConstants;
  48 import org.slf4j.MDC;
  49
  50 /**
  51  * The Class AaiUiProxyProcessor.
  52  */
  53 public class AaiUiProxyProcessor {
  54   private static final Logger LOG =
  55       LoggerFactory.getInstance().getLogger(AaiUiProxyProcessor.class);
  56   private static Logger auditLogger =
  57       LoggerFactory.getInstance().getAuditLogger(AaiUiProxyProcessor.class.getName());
  58   public String configFile =
  59       TierSupportUiConstants.DYNAMIC_CONFIG_APP_LOCATION + "data-router.properties";
  60
  61   private RestClient client;
  62   private DataRouterConfig config;
  63   private String drBaseUrl;
  64   private OperationResult operationResult = null;
  65
  66   private String xTransactionId;
  67   private String xFromAppId;
  68
  69   private static final String ROUTER_SERVICE = "routerService";
  70
  71   public String getDrBaseUrl() {
  72     return drBaseUrl;
  73   }
  74
  75   public void setDrBaseUrl(String drBaseUrl) {
  76     this.drBaseUrl = drBaseUrl;
  77   }
  78
  79   /**
  80    * Instantiates a new AaiUiProxyProcessor.
  81    */
  82
  83   public AaiUiProxyProcessor() {
  84     Properties props = ConfigHelper.loadConfigFromExplicitPath(configFile);
  85     config = new DataRouterConfig(props);
  86     initializeProxyProcessor(config);
  87   }
  88
  89   public AaiUiProxyProcessor(DataRouterConfig config) {
  90     initializeProxyProcessor(config);
  91   }
  92
  93   private void initializeProxyProcessor(DataRouterConfig config) {
  94     Encryptor encryptor = new Encryptor();
  95     client = new RestClient().validateServerHostname(false).validateServerCertChain(false)
  96         .clientCertFile(TierSupportUiConstants.CONFIG_AUTH_LOCATION + config.getCertName())
  97         .clientCertPassword(encryptor.decryptValue(config.getKeystorePassword()))
  98         .trustStore(TierSupportUiConstants.CONFIG_AUTH_LOCATION + config.getKeystore())
  99         .connectTimeoutMs(config.getConnectTimeout()).readTimeoutMs(config.getReadTimeout());
 100
 101     drBaseUrl =
 102         "https://" + config.getHost() + ":" + config.getPort() + "/" + config.getDrUriSuffix();
 103   }
 104
 105   void setUpMdcContext(final Exchange exchange, final HttpServletRequest request) {
 106
 107     Object xTransactionId = exchange.getIn().getHeader("X-TransactionId");
 108     if (xTransactionId == null) {
 109       this.xTransactionId = NodeUtils.getRandomTxnId();
 110     } else {
 111       this.xTransactionId = (String) xTransactionId;
 112     }
 113
 114     Object partnerName = exchange.getIn().getHeader("X-FromAppId");
 115     if (partnerName == null) {
 116       xFromAppId = "Browser";
 117     } else {
 118       xFromAppId = (String) partnerName;
 119     }
 120
 121     MdcContext.initialize((String) xTransactionId, "AAI-UI", "", xFromAppId,
 122         request.getRequestURI() + ":" + request.getLocalPort());
 123   }
 124
 125   private Map<String, List<String>> getHeaders() {
 126     Map<String, List<String>> headers = new HashMap<>();
 127     headers.put("X-FromAppId", Arrays.asList(TierSupportUiConstants.APP_NAME));
 128     headers.put("X-TransactionId", Arrays.asList(MDC.get(MdcContext.MDC_REQUEST_ID)));
 129     headers.put("X-FromAppId", Arrays.asList(MDC.get(MdcContext.MDC_PARTNER_NAME)));
 130     return headers;
 131   }
 132
 133   private String getProxyPayloadAsString(final Exchange exchange) {
 134     JsonObjectBuilder jsonBuilder = Json.createObjectBuilder();
 135     String srcUri = "";
 136     try {
 137       srcUri = (String) exchange.getIn().getHeader(Exchange.HTTP_URI);
 138       jsonBuilder.add("origin-uri", srcUri);
 139
 140       String body = exchange.getIn().getBody(String.class);
 141
 142       if (body != null && body.length() != 0) {
 143         jsonBuilder.add("origin-payload", body);
 144       }
 145
 146     } catch (Exception e) {
 147       LOG.error(AaiUiMsgs.ERROR_GENERIC,
 148           "Failed to extract payload for proxying.\n" + "Requestor URL: " + srcUri);
 149     }
 150
 151     return jsonBuilder.build().toString();
 152   }
 153
 154   private String getDrUrl(String requestUri) {
 155     String url = "";
 156     int pos = requestUri.indexOf(ROUTER_SERVICE);
 157     if (pos != -1) {
 158       url = drBaseUrl + requestUri.substring(pos + ROUTER_SERVICE.length());
 159     } else {
 160       LOG.error(AaiUiMsgs.DR_REQUEST_URI_FOR_PROXY_UNKNOWN, requestUri);
 161     }
 162     return url;
 163   }
 164
 165   public void proxyMessage(Exchange exchange) {
 166     HttpServletRequest request = exchange.getIn().getBody(HttpServletRequest.class);
 167
 168     setUpMdcContext(exchange, request);
 169
 170     try {
 171       Map<String, List<String>> headers = getHeaders();
 172       String proxyPayload = getProxyPayloadAsString(exchange);
 173       String fromUrl = (String) exchange.getIn().getHeader(Exchange.HTTP_URI);
 174       String toUrl = getDrUrl(fromUrl);
 175       auditLogger.info(AaiUiMsgs.DR_PROXY_FROM_TO, fromUrl, toUrl);
 176       LOG.debug(AaiUiMsgs.DEBUG_GENERIC,
 177           "Proxying request:\n" + proxyPayload + "\n" + "Target URL:\n" + toUrl);
 178
 179       long startTimeInMs = System.currentTimeMillis();
 180
 181       operationResult = client.post(toUrl, proxyPayload, headers,
 182           javax.ws.rs.core.MediaType.APPLICATION_JSON_TYPE,
 183           javax.ws.rs.core.MediaType.APPLICATION_JSON_TYPE);
 184
 185       long drOpTime = (System.currentTimeMillis() - startTimeInMs);
 186       int rc = operationResult.getResultCode();
 187       String result = "";
 188
 189       if (HttpUtil.isHttpResponseClassSuccess(rc)) {
 190         result = operationResult.getResult();
 191       } else {
 192         result = operationResult.getFailureCause();
 193         LOG.info(AaiUiMsgs.DR_PROCESSING_FAILURE, String.valueOf(rc), proxyPayload);
 194       }
 195
 196       auditLogger.info(AaiUiMsgs.DR_PROCESSING_TIME, String.valueOf(drOpTime));
 197
 198       exchange.getOut().setHeader("X-TransactionId", xTransactionId);
 199       exchange.getOut().setHeader("X-FromAppId", xFromAppId);
 200       exchange.getOut().setHeader("RequestUrl", request.getRequestURI());
 201       exchange.getOut().setHeader("RequestPort", request.getLocalPort());
 202       exchange.getOut().setBody(result);
 203     } catch (Exception exc) {
 204       LOG.error(AaiUiMsgs.ERROR_PROCESSING_REQUEST, exc);
 205     }
 206   }
 207
 208   public RestClient getClient() {
 209     return client;
 210   }
 211
 212   public void setClient(RestClient client) {
 213     this.client = client;
 214   }
 215
 216   public DataRouterConfig getConfig() {
 217     return config;
 218   }
 219
 220   public void setConfig(DataRouterConfig config) {
 221     this.config = config;
 222   }
 223
 224   protected OperationResult getOperationResult() {
 225     return operationResult;
 226   }
 227 }