src/main/java/org/onap/aai/datarouter/util/client/NoAuthRestClient.java

   1 /**
   2  * ============LICENSE_START=======================================================
   3  * org.onap.aai
   4  * ================================================================================
   5  * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * Copyright © 2017-2018 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 package org.onap.aai.datarouter.util.client;
  22
  23 import com.fasterxml.jackson.databind.JsonNode;
  24 import org.apache.camel.Exchange;
  25 import org.apache.camel.Message;
  26 import org.onap.aai.cl.api.Logger;
  27 import org.onap.aai.cl.eelf.LoggerFactory;
  28 import org.onap.aai.cl.mdc.MdcContext;
  29 import org.onap.aai.datarouter.logging.DataRouterMsgs;
  30 import org.onap.aai.datarouter.util.AaiUiSvcPolicyUtil;
  31 import org.onap.aai.datarouter.util.NodeUtils;
  32 import org.onap.aai.datarouter.util.RouterServiceUtil;
  33 import org.onap.aai.restclient.client.Headers;
  34 import org.onap.aai.restclient.client.OperationResult;
  35 import org.onap.aai.restclient.client.RestClient;
  36 import org.onap.aai.restclient.enums.RestAuthenticationMode;
  37 import org.onap.aai.restclient.rest.HttpUtil;
  38 import org.slf4j.MDC;
  39 import org.springframework.http.HttpStatus;
  40
  41 import javax.ws.rs.core.MediaType;
  42 import java.util.Arrays;
  43 import java.util.HashMap;
  44 import java.util.List;
  45 import java.util.Map;
  46
  47 public class NoAuthRestClient implements SvcRoutingRestClient {
  48
  49     private RestClient restClient;
  50
  51     private String host;
  52     private String port;
  53     private String originUrl;
  54     private String targetUri;
  55     private JsonNode targetPayload;
  56     private Logger logger;
  57     private Logger auditLogger;
  58
  59     public NoAuthRestClient(int connectTimeOut, int readTimeOut) {
  60         LoggerFactory loggerFactoryInstance = LoggerFactory.getInstance();
  61         logger = loggerFactoryInstance.getLogger(NoAuthRestClient.class.getName());
  62         auditLogger = loggerFactoryInstance.getAuditLogger(NoAuthRestClient.class.getName());
  63         restClient = new RestClient().authenticationMode(RestAuthenticationMode.HTTP_NOAUTH)
  64                 .connectTimeoutMs(connectTimeOut).readTimeoutMs(readTimeOut);
  65     }
  66
  67
  68     private OperationResult getResults(String url, JsonNode payload) {
  69         Map<String, List<String>> headers = new HashMap<>();
  70         headers.put(Headers.FROM_APP_ID, Arrays.asList("Synapse"));
  71         headers.put(Headers.TRANSACTION_ID, Arrays.asList(MDC.get(MdcContext.MDC_REQUEST_ID)));
  72         return this.getRestClient().post(url, payload.asText(),
  73                                          headers, MediaType.APPLICATION_JSON_TYPE,
  74                                          MediaType.APPLICATION_JSON_TYPE);
  75     }
  76
  77     public final void handleRequest(String host, String port, Exchange exchange) throws Exception {
  78         RouterServiceUtil.setMdcContext(exchange);
  79         Message message = exchange.getIn();
  80         String body = message.getBody(String.class);
  81         OperationResult result = new OperationResult();
  82
  83         this.setHost(host);
  84         this.setPort(port);
  85
  86         this.setOriginUrl(message.getHeader(Exchange.HTTP_URL).toString());
  87         if (body != null && body.length() != 0) {
  88             JsonNode node = NodeUtils.convertJsonStrToJsonNode(body);
  89             this.setTargetPayload(AaiUiSvcPolicyUtil.getOriginPayload(node));
  90             this.setTargetUri(AaiUiSvcPolicyUtil.getTargetUri(node));
  91         }
  92
  93         if (this.getTargetPayload() == null || this.getTargetUri() == null) {
  94             logger.error(DataRouterMsgs.INVALID_ORIGIN_PAYLOAD, body);
  95             result.setResultCode(HttpStatus.BAD_REQUEST.value());
  96             result.setFailureCause("Invalid payload");
  97         }
  98
  99         String targetUrl = "http://" + host + ":" + port + "/" + this.targetUri;
 100         auditLogger.info(DataRouterMsgs.ROUTING_FROM_TO, this.getOriginUrl(), targetUrl);
 101         long startTimeInMs = System.currentTimeMillis();
 102
 103         result = this.getResults(targetUrl, targetPayload);
 104
 105         long targetMsOpTime = System.currentTimeMillis() - startTimeInMs;
 106         auditLogger.info(DataRouterMsgs.OP_TIME, "Target service at " + targetUrl, String.valueOf(targetMsOpTime));
 107
 108         int rc = result.getResultCode();
 109         String resultStr;
 110         if (HttpUtil.isHttpResponseClassSuccess(rc)) {
 111             resultStr = result.getResult();
 112         } else {
 113             resultStr = result.getFailureCause();
 114         }
 115
 116         logger.debug(DataRouterMsgs.ROUTING_RESPONSE, targetUrl, result.toString());
 117         exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, rc);
 118         exchange.getOut().setBody(resultStr);
 119     }
 120
 121
 122     /* (non-Javadoc)
 123      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#getHost()
 124      */
 125     @Override
 126     public String getHost() {
 127         return host;
 128     }
 129
 130     /* (non-Javadoc)
 131      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#setHost(java.lang.String)
 132      */
 133     @Override
 134     public void setHost(String host) {
 135         this.host = host;
 136     }
 137
 138
 139     /* (non-Javadoc)
 140      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#getPort()
 141      */
 142     @Override
 143     public String getPort() {
 144         return port;
 145     }
 146
 147
 148     /* (non-Javadoc)
 149      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#setPort(java.lang.String)
 150      */
 151     @Override
 152     public void setPort(String port) {
 153         this.port = port;
 154     }
 155
 156
 157     /* (non-Javadoc)
 158      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#getTargetUri()
 159      */
 160     @Override
 161     public String getTargetUri() {
 162         return targetUri;
 163     }
 164
 165
 166     /* (non-Javadoc)
 167      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#setTargetUri(java.lang.String)
 168      */
 169     @Override
 170     public void setTargetUri(String targetUri) {
 171         this.targetUri = targetUri;
 172     }
 173
 174
 175     /* (non-Javadoc)
 176      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#getTargetPayload()
 177      */
 178     @Override
 179     public JsonNode getTargetPayload() {
 180         return targetPayload;
 181     }
 182
 183
 184     /* (non-Javadoc)
 185      * @see org.onap.aai.datarouter.util.client
 186      * .SvcRoutingRestClient#setTargetPayload(com.fasterxml.jackson.databind.JsonNode)
 187      */
 188     @Override
 189     public void setTargetPayload(JsonNode targetPayload) {
 190         this.targetPayload = targetPayload;
 191     }
 192
 193
 194     /* (non-Javadoc)
 195      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#getRestClient()
 196      */
 197     @Override
 198     public RestClient getRestClient() {
 199         return restClient;
 200     }
 201
 202     /* (non-Javadoc)
 203      * @see org.onap.aai.datarouter.util.client.SvcRoutingRestClient#setRestClient()
 204      */
 205     @Override
 206     public void setRestClient(RestClient client) {
 207         this.restClient = client;
 208     }
 209
 210
 211     public String getOriginUrl() {
 212         return originUrl;
 213     }
 214
 215
 216     public void setOriginUrl(String originUrl) {
 217         this.originUrl = originUrl;
 218     }
 219
 220 }