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