2 * ============LICENSE_START=======================================================
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
12 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
23 package org.onap.aai.rest;
25 import org.apache.camel.Exchange;
26 import org.apache.camel.impl.DefaultProducer;
27 import org.eclipse.jetty.util.security.Password;
28 import org.onap.aai.event.EventBusConsumer;
29 import org.onap.aai.restclient.client.Headers;
30 import org.onap.aai.restclient.client.OperationResult;
31 import org.onap.aai.restclient.client.RestClient;
32 import org.onap.aai.restclient.rest.HttpUtil;
33 import org.onap.aai.cl.api.Logger;
34 import org.onap.aai.cl.eelf.LoggerFactory;
36 import java.util.Arrays;
37 import java.util.HashMap;
38 import java.util.List;
41 import javax.ws.rs.core.MediaType;
42 import javax.ws.rs.core.Response;
46 * The EcompRest producer.
48 public class RestClientProducer extends DefaultProducer {
50 private static enum Operation {
51 GET, PUT, POST, DELETE
54 private RestClientEndpoint endpoint;
56 /** REST client used for sending HTTP requests. */
57 private RestClient restClient;
59 private Logger logger = LoggerFactory.getInstance().getLogger(RestClientProducer.class);
62 public RestClientProducer(RestClientEndpoint endpoint) {
64 this.endpoint = endpoint;
68 public void process(Exchange exchange) {
70 // Extract the URL for our REST request from the IN message header.
71 String url = exchange.getIn().getHeader(RestClientEndpoint.IN_HEADER_URL).toString();
73 // Populate the HTTP Request header values from any values passed in via the
74 // IN message headers.
75 Map<String, List<String>> headers = populateRestHeaders(exchange);
77 if (logger.isDebugEnabled()) {
78 StringBuilder sb = new StringBuilder();
79 sb.append("Process REST request - operation=").append(getOperation(exchange));
80 sb.append(" headers=[");
81 for (String key : headers.keySet()) {
82 sb.append("{").append(key).append("->").append(headers.get(key)).append("} ");
85 sb.append(" content: ").append(exchange.getIn().getBody());
86 logger.debug(sb.toString());
89 // Now, invoke the REST client to perform the operation.
90 OperationResult result = null;
91 switch (getOperation(exchange)) {
94 result = getRestClient().get(url, headers, MediaType.APPLICATION_JSON_TYPE);
98 result = getRestClient().put(url, exchange.getIn().getBody().toString(), headers,
99 MediaType.APPLICATION_JSON_TYPE, null);
103 result = getRestClient().post(url, exchange.getIn().getBody().toString(), headers,
104 MediaType.APPLICATION_JSON_TYPE, MediaType.APPLICATION_JSON_TYPE);
108 result = getRestClient().delete(url, headers, MediaType.APPLICATION_JSON_TYPE);
112 // The supplied operation is not supported.
113 result = new OperationResult();
114 result.setResultCode(Response.Status.BAD_REQUEST.getStatusCode());
115 result.setFailureCause("Unsupported HTTP Operation: " + getOperation(exchange));
120 // Populate the OUT message with our result.
121 exchange.getOut().setHeader(RestClientEndpoint.OUT_HEADER_RESPONSE_CODE,
122 result.getResultCode());
123 if (HttpUtil.isHttpResponseClassSuccess(result.getResultCode())) {
124 exchange.getOut().setHeader(RestClientEndpoint.OUT_HEADER_RESPONSE_MSG,
125 responseStatusStringFromResult(result));
126 exchange.getOut().setBody(result.getResult());
128 exchange.getOut().setHeader(RestClientEndpoint.OUT_HEADER_RESPONSE_MSG,
129 result.getFailureCause());
136 * Extracts the requested REST operation from the exchange message.
138 * @param exchange - The Camel exchange to pull the operation from.
140 * @return - The REST operation being requested.
142 private Operation getOperation(Exchange exchange) {
144 String toEndpoint = ((String) exchange.getProperty(Exchange.TO_ENDPOINT));
146 String operation = toEndpoint.substring((toEndpoint.lastIndexOf("://") + 3));
148 int position = operation.indexOf('?');
150 operation = operation.substring(0, position);
153 return Operation.valueOf(operation.toUpperCase());
159 * This method extracts values from the IN message which are intended to be used to populate the
160 * HTTP Header entries for our REST request.
162 * @param exchange - The Camel exchange to extract the HTTP header parameters from.
164 * @return - A map of HTTP header names and values.
166 private Map<String, List<String>> populateRestHeaders(Exchange exchange) {
168 Map<String, List<String>> headers = new HashMap<>();
170 if (exchange.getIn().getHeader(Headers.FROM_APP_ID) != null) {
171 headers.put(Headers.FROM_APP_ID,
172 Arrays.asList(exchange.getIn().getHeader(Headers.FROM_APP_ID).toString()));
174 if (exchange.getIn().getHeader(Headers.TRANSACTION_ID) != null) {
175 headers.put(Headers.TRANSACTION_ID,
176 Arrays.asList(exchange.getIn().getHeader(Headers.TRANSACTION_ID).toString()));
178 if (exchange.getIn().getHeader(Headers.RESOURCE_VERSION) != null) {
179 headers.put(Headers.RESOURCE_VERSION,
180 Arrays.asList(exchange.getIn().getHeader(Headers.RESOURCE_VERSION).toString()));
182 if (exchange.getIn().getHeader(Headers.ETAG) != null) {
183 headers.put(Headers.ETAG, Arrays.asList(exchange.getIn().getHeader(Headers.ETAG).toString()));
185 if (exchange.getIn().getHeader(Headers.IF_MATCH) != null) {
186 headers.put(Headers.IF_MATCH,
187 Arrays.asList(exchange.getIn().getHeader(Headers.IF_MATCH).toString()));
189 if (exchange.getIn().getHeader(Headers.IF_NONE_MATCH) != null) {
190 headers.put(Headers.IF_NONE_MATCH,
191 Arrays.asList(exchange.getIn().getHeader(Headers.IF_NONE_MATCH).toString()));
193 if (exchange.getIn().getHeader(Headers.ACCEPT) != null) {
194 headers.put(Headers.ACCEPT,
195 Arrays.asList(exchange.getIn().getHeader(Headers.ACCEPT).toString()));
197 if (exchange.getIn().getHeader("Content-Type") != null) {
198 headers.put("Content-Type",
199 Arrays.asList(exchange.getIn().getHeader("Content-Type").toString()));
207 * This helper method converts an HTTP response code into the associated string.
209 * @param result - A result object to get the response code from.
211 * @return - The string message associated with the supplied response code.
213 private String responseStatusStringFromResult(OperationResult result) {
215 // Not every valid response code is actually represented by the Response.Status
216 // object, so we need to guard against missing codes, otherwise we throw null
217 // pointer exceptions when we try to generate our metrics logs...
218 Response.Status responseStatus = Response.Status.fromStatusCode(result.getResultCode());
219 String responseStatusCodeString = "";
220 if (responseStatus != null) {
221 responseStatusCodeString = responseStatus.toString();
224 return responseStatusCodeString;
228 * Instantiate the REST client that will be used for sending our HTTP requests.
230 * @return - An instance of the REST client.
232 private RestClient getRestClient() {
234 if (restClient == null) {
236 String keystoreFilename = endpoint.getEcompKeystore();
237 String keystorePassword = endpoint.getEcompKeystorePassword();
238 String clientCertFilename = endpoint.getEcompClientCert();
240 if (logger.isDebugEnabled()) {
241 logger.debug("Instantiating REST Client with client_cert=" + clientCertFilename
242 + " keystore=" + keystoreFilename + " keystorePassword=" + keystorePassword);
245 // Create REST client for search service
246 restClient = new RestClient().validateServerHostname(false).validateServerCertChain(true)
247 .clientCertFile(clientCertFilename)
248 .clientCertPassword(Password.deobfuscate(keystorePassword)).trustStore(keystoreFilename);