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
  30 import javax.json.Json;
  31 import javax.json.JsonObjectBuilder;
  32 import javax.servlet.http.HttpServletRequest;
  33
  34 import org.apache.camel.Exchange;
  35 import org.onap.aai.cl.api.Logger;
  36 import org.onap.aai.cl.eelf.LoggerFactory;
  37 import org.onap.aai.cl.mdc.MdcContext;
  38 import org.onap.aai.restclient.client.OperationResult;
  39 import org.onap.aai.restclient.client.RestClient;
  40 import org.onap.aai.restclient.rest.HttpUtil;
  41 import org.onap.aai.sparky.dal.rest.RestClientConstructionException;
  42 import org.onap.aai.sparky.dal.rest.RestClientFactory;
  43 import org.onap.aai.sparky.dal.rest.config.RestEndpointConfig;
  44 import org.onap.aai.sparky.logging.AaiUiMsgs;
  45 import org.onap.aai.sparky.util.NodeUtils;
  46 import org.onap.aai.sparky.viewandinspect.config.SparkyConstants;
  47 import org.slf4j.MDC;
  48
  49 /**
  50  * The Class AaiUiProxyProcessor.
  51  */
  52 public class AaiUiProxyProcessor {
  53   private static final Logger LOG =
  54       LoggerFactory.getInstance().getLogger(AaiUiProxyProcessor.class);
  55   private static Logger auditLogger =
  56       LoggerFactory.getInstance().getAuditLogger(AaiUiProxyProcessor.class.getName());
  57
  58   private RestClient client;
  59   private String synapseBaseUrl;
  60
  61   private OperationResult operationResult = null;
  62
  63   private String xTransactionId;
  64   private String xFromAppId;
  65
  66   private static final String ROUTER_SERVICE = "routerService";
  67
  68
  69   /**
  70    * Instantiates a new AaiUiProxyProcessor.
  71    *
  72    * @throws RestClientConstructionException
  73    */
  74
  75   public AaiUiProxyProcessor(RestEndpointConfig endpointConfig, String apiGatewayEndpoint)
  76       throws RestClientConstructionException {
  77     client = RestClientFactory.buildClient(endpointConfig);
  78     synapseBaseUrl = "https://" + endpointConfig.getEndpointIpAddress() + ":"
  79         + endpointConfig.getEndpointServerPort() + "/" + apiGatewayEndpoint;
  80   }
  81
  82
  83   void setUpMdcContext(final Exchange exchange, final HttpServletRequest request) {
  84
  85     Object xTransactionId = exchange.getIn().getHeader("X-TransactionId");
  86     if (xTransactionId == null) {
  87       this.xTransactionId = NodeUtils.getRandomTxnId();
  88     } else {
  89       this.xTransactionId = (String) xTransactionId;
  90     }
  91
  92     Object partnerName = exchange.getIn().getHeader("X-FromAppId");
  93     if (partnerName == null) {
  94       xFromAppId = "Browser";
  95     } else {
  96       xFromAppId = (String) partnerName;
  97     }
  98
  99     MdcContext.initialize((String) xTransactionId, "AAI-UI", "", xFromAppId,
 100         request.getRequestURI() + ":" + request.getLocalPort());
 101   }
 102
 103   private Map<String, List<String>> getHeaders() {
 104     Map<String, List<String>> headers = new HashMap<>();
 105     headers.put("X-FromAppId", Arrays.asList(SparkyConstants.APP_NAME));
 106     headers.put("X-TransactionId", Arrays.asList(MDC.get(MdcContext.MDC_REQUEST_ID)));
 107     headers.put("X-FromAppId", Arrays.asList(MDC.get(MdcContext.MDC_PARTNER_NAME)));
 108     return headers;
 109   }
 110
 111   private String getProxyPayloadAsString(final Exchange exchange) {
 112     JsonObjectBuilder jsonBuilder = Json.createObjectBuilder();
 113     String srcUri = "";
 114     try {
 115       srcUri = (String) exchange.getIn().getHeader(Exchange.HTTP_URI);
 116       jsonBuilder.add("origin-uri", srcUri);
 117
 118       String body = exchange.getIn().getBody(String.class);
 119
 120       if (body != null && body.length() != 0) {
 121         jsonBuilder.add("origin-payload", body);
 122       }
 123
 124     } catch (Exception e) {
 125       LOG.error(AaiUiMsgs.ERROR_GENERIC,
 126           "Failed to extract payload for proxying.\n" + "Requestor URL: " + srcUri);
 127     }
 128
 129     return jsonBuilder.build().toString();
 130   }
 131
 132   private String getSynapseUrl(String requestUri) {
 133     String url = "";
 134     int pos = requestUri.indexOf(ROUTER_SERVICE);
 135     if (pos != -1) {
 136       url = synapseBaseUrl + requestUri.substring(pos + ROUTER_SERVICE.length());
 137     } else {
 138       LOG.error(AaiUiMsgs.DR_REQUEST_URI_FOR_PROXY_UNKNOWN, requestUri);
 139     }
 140     return url;
 141   }
 142
 143   public void proxyMessage(Exchange exchange) {
 144     HttpServletRequest request = exchange.getIn().getBody(HttpServletRequest.class);
 145
 146     setUpMdcContext(exchange, request);
 147
 148     try {
 149       Map<String, List<String>> headers = getHeaders();
 150       String proxyPayload = getProxyPayloadAsString(exchange);
 151       String fromUrl = (String) exchange.getIn().getHeader(Exchange.HTTP_URI);
 152       String toUrl = getSynapseUrl(fromUrl);
 153       auditLogger.info(AaiUiMsgs.DR_PROXY_FROM_TO, fromUrl, toUrl);
 154       LOG.debug(AaiUiMsgs.DEBUG_GENERIC,
 155           "Proxying request:\n" + proxyPayload + "\n" + "Target URL:\n" + toUrl);
 156
 157       long startTimeInMs = System.currentTimeMillis();
 158
 159       operationResult = client.post(toUrl, proxyPayload, headers,
 160           javax.ws.rs.core.MediaType.APPLICATION_JSON_TYPE,
 161           javax.ws.rs.core.MediaType.APPLICATION_JSON_TYPE);
 162
 163       long drOpTime = (System.currentTimeMillis() - startTimeInMs);
 164       int rc = operationResult.getResultCode();
 165       String result = "";
 166
 167       if (HttpUtil.isHttpResponseClassSuccess(rc)) {
 168         result = operationResult.getResult();
 169       } else {
 170         result = operationResult.getFailureCause();
 171         LOG.info(AaiUiMsgs.DR_PROCESSING_FAILURE, String.valueOf(rc), proxyPayload);
 172       }
 173
 174       auditLogger.info(AaiUiMsgs.DR_PROCESSING_TIME, String.valueOf(drOpTime));
 175
 176       exchange.getOut().setHeader("X-TransactionId", xTransactionId);
 177       exchange.getOut().setHeader("X-FromAppId", xFromAppId);
 178       exchange.getOut().setHeader("RequestUrl", request.getRequestURI());
 179       exchange.getOut().setHeader("RequestPort", request.getLocalPort());
 180       exchange.getOut().setBody(result);
 181     } catch (Exception exc) {
 182       LOG.error(AaiUiMsgs.ERROR_PROCESSING_REQUEST, exc);
 183     }
 184   }
 185
 186   public String getSynapseBaseUrl() {
 187     return synapseBaseUrl;
 188   }
 189
 190   public void setSynapseBaseUrl(String synapseBaseUrl) {
 191     this.synapseBaseUrl = synapseBaseUrl;
 192   }
 193
 194   public RestClient getClient() {
 195     return client;
 196   }
 197
 198   public void setClient(RestClient client) {
 199     this.client = client;
 200   }
 201
 202   protected OperationResult getOperationResult() {
 203     return operationResult;
 204   }
 205 }