2 * ============LICENSE_START=======================================================
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
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 package org.onap.aai.rest;
23 import static org.junit.Assert.assertTrue;
25 import java.io.PrintWriter;
26 import java.io.StringWriter;
27 import java.lang.reflect.Method;
28 import java.util.List;
31 import org.apache.camel.Exchange;
32 import org.apache.camel.ExtendedCamelContext;
33 import org.apache.camel.support.DefaultMessage;
34 import org.junit.Before;
35 import org.junit.Test;
36 import org.junit.runner.RunWith;
37 import org.mockito.Mock;
38 import org.mockito.runners.MockitoJUnitRunner;
39 import org.onap.aai.logging.RouterCoreMsgs;
40 import org.onap.aai.restclient.client.Headers;
42 @RunWith(MockitoJUnitRunner.class)
43 public class RestClientTest {
47 public ExtendedCamelContext context;
50 * Test case initialization
52 * @throws Exception the exception
55 public void init() throws Exception {
59 public void validate() throws Exception {
62 RestClientComponent rc = new RestClientComponent(context);
63 RestClientEndpoint endpoint = new RestClientEndpoint("http://host.com:8443/endpoint", rc);
65 endpoint.setEcompClientCert("client-cert");
66 endpoint.setEcompKeystore("keystore");
67 endpoint.setEcompKeystorePassword("OBF:1y0q1uvc1uum1uvg1pil1pjl1uuq1uvk1uuu1y10");
68 endpoint.setOp("GET");
71 assertTrue(endpoint.getEcompClientCert().compareTo("client-cert") == 0);
72 assertTrue(endpoint.getEcompKeystore().compareTo("keystore") == 0);
73 assertTrue(endpoint.getEcompKeystorePassword().compareTo("OBF:1y0q1uvc1uum1uvg1pil1pjl1uuq1uvk1uuu1y10") == 0);
74 assertTrue(endpoint.getOp().compareTo("GET") == 0);
75 assertTrue(endpoint.isSingleton());
77 RestClientProducer producer = (RestClientProducer)endpoint.createProducer();
78 assertTrue(producer != null);
80 Method method = RestClientProducer.class.getDeclaredMethod("populateRestHeaders", Exchange.class);
81 method.setAccessible(true);
83 Exchange exchange = endpoint.createExchange();
84 exchange.setProperty(Exchange.TO_ENDPOINT, "mock://get");
85 DefaultMessage in = (DefaultMessage)exchange.getIn();
87 in.setHeader(RestClientEndpoint.IN_HEADER_URL, "svc/endpoint");
88 in.setHeader(Headers.FROM_APP_ID, "val1");
89 in.setHeader(Headers.TRANSACTION_ID, "val2");
90 in.setHeader(Headers.RESOURCE_VERSION, "val2");
91 in.setHeader(Headers.ETAG, "val2");
92 in.setHeader(Headers.IF_MATCH, "val2");
93 in.setHeader(Headers.IF_NONE_MATCH, "val2");
94 in.setHeader(Headers.ACCEPT, "val2");
95 in.setHeader("Content-Type", "val2");
97 Map<String, List<String>> headers = (Map<String, List<String>>)method.invoke(producer, exchange);
98 assertTrue(headers.size() == 8);
100 producer.process(exchange);
102 System.out.println(RouterCoreMsgs.EVENT_CONSUMER_CREATION_EXCEPTION);
104 catch (Exception ex) {
105 StringWriter writer = new StringWriter();
106 PrintWriter printWriter = new PrintWriter( writer );
107 ex.printStackTrace( printWriter );
109 System.out.println(writer.toString());