summaryrefslogtreecommitdiffstats
path: root/vid-app-common/src/test/java/org
diff options
context:
space:
mode:
authorgolabek <tomasz.golabek@nokia.com>2018-08-01 15:56:44 +0200
committerWojciech Sliwka <wojciech.sliwka@nokia.com>2018-08-23 11:02:34 +0200
commit985bc34c7519ae45adf464d68315f06972152d0e (patch)
tree368701f553976051ed2a112420f8b0582ea51151 /vid-app-common/src/test/java/org
parentdf5c2a05532cfb04dc3b08205145e38cecf0ed65 (diff)
Generic REST client for external services
Initial commit for generic REST client for requests to another components APIs Change-Id: I4af29ab1e45fd805403622e60585a351f3ef5d20 Issue-ID: VID-266 Signed-off-by: tgolabek <tomasz.golabek@nokia.com>
Diffstat (limited to 'vid-app-common/src/test/java/org')
-rw-r--r--vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpServerTest.java268
-rw-r--r--vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpsServerTest.java139
-rw-r--r--vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientModel.java56
3 files changed, 463 insertions, 0 deletions
diff --git a/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpServerTest.java b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpServerTest.java
new file mode 100644
index 000000000..d63d144e6
--- /dev/null
+++ b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpServerTest.java
@@ -0,0 +1,268 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * VID
+ * ================================================================================
+ * Copyright (C) 2018 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.vid.client;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.common.collect.ImmutableMap;
+import com.xebialabs.restito.semantics.Condition;
+import com.xebialabs.restito.server.StubServer;
+import io.joshworks.restclient.http.HttpResponse;
+import io.joshworks.restclient.http.JsonNode;
+import org.glassfish.grizzly.http.util.HttpStatus;
+import com.xebialabs.restito.semantics.Action;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.AfterMethod;
+import org.glassfish.grizzly.http.Method;
+import org.testng.annotations.Test;
+
+import java.util.Collections;
+import java.util.Map;
+
+import static com.xebialabs.restito.builder.verify.VerifyHttp.verifyHttp;
+import static com.xebialabs.restito.builder.stub.StubHttp.whenHttp;
+import static com.xebialabs.restito.semantics.Action.stringContent;
+import static com.xebialabs.restito.semantics.Action.contentType;
+import static com.xebialabs.restito.semantics.Action.status;
+import static com.xebialabs.restito.semantics.Action.ok;
+import static org.testng.Assert.assertEquals;
+
+public class SyncRestClientForHttpServerTest {
+
+ private static final SyncRestClientModel.TestModel testObject = new SyncRestClientModel.TestModel(1, "test");
+ private static final String NOT_EXISTING_OBJECT = "NOT EXISTING OBJECT";
+
+ private StubServer stubServer;
+ private ObjectMapper objectMapper = new ObjectMapper();
+ private SyncRestClient syncRestClient;
+
+ @BeforeMethod
+ public void setUp() {
+ stubServer = new StubServer();
+ stubServer.run();
+ syncRestClient = new SyncRestClient();
+ }
+
+ @AfterMethod
+ public void tearDown() {
+ stubServer.stop();
+ syncRestClient.destroy();
+ }
+
+ @Test
+ public void testJsonResponseFromGet() throws JsonProcessingException {
+ // given
+ stubGetCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient
+ .get(url, Collections.emptyMap(), Collections.emptyMap());
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.GET), Condition.url(url));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("key"), 1);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("value"), "test");
+ }
+
+ @Test
+ public void testObjectResponseFromGet() throws JsonProcessingException {
+ // given
+ stubGetCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<SyncRestClientModel.TestModel> testModelHttpResponse = syncRestClient
+ .get(url, Collections.emptyMap(), Collections.emptyMap(), SyncRestClientModel.TestModel.class);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.GET), Condition.url(url));
+ assertEquals(testModelHttpResponse.getStatus(), 200);
+ assertEquals(testModelHttpResponse.getBody().getKey(), 1);
+ assertEquals(testModelHttpResponse.getBody().getValue(), "test");
+ }
+
+ @Test
+ public void testJsonResponseFromPost() throws JsonProcessingException {
+ // given
+ stubPostCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient.post(url, Collections.emptyMap(), testObject);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.POST), Condition.url(url));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("key"), 1);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("value"), "test");
+ }
+
+ @Test
+ public void test404JsonResponseFromPost() throws JsonProcessingException {
+ // given
+ stubPostCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient
+ .post(url, Collections.emptyMap(), NOT_EXISTING_OBJECT);
+ // then
+ assertEquals(jsonNodeHttpResponse.getStatus(), 404);
+ assertEquals(jsonNodeHttpResponse.getStatusText(), "Not Found");
+ }
+
+ @Test
+ public void testHeadersWerePassedToPost() throws JsonProcessingException {
+ // given
+ stubPostCall();
+ Map headers = ImmutableMap.<String, String>builder().put("Authorization", "Basic anyHash").build();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient.post(url, headers, testObject);
+ // then
+ verifyHttp(stubServer).once(Condition.withHeader("Authorization"));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ }
+
+ @Test(expectedExceptions = {Exception.class})
+ public void testFailedJsonResponseFromPost() throws JsonProcessingException {
+ // given
+ stubPostCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ stubServer.stop();
+ syncRestClient.post(url, Collections.emptyMap(), testObject);
+ }
+
+ @Test
+ public void testObjectResponseFromPost() throws JsonProcessingException {
+ // given
+ stubPostCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<SyncRestClientModel.TestModel> objectHttpResponse = syncRestClient
+ .post(url, Collections.emptyMap(), testObject, SyncRestClientModel.TestModel.class);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.POST), Condition.url(url));
+ assertEquals(objectHttpResponse.getStatus(), 200);
+ assertEquals(objectHttpResponse.getBody().getKey(), 1);
+ assertEquals(objectHttpResponse.getBody().getValue(), "test");
+ }
+
+ @Test
+ public void testJsonResponseFromPut() throws JsonProcessingException {
+ // given
+ stubPutCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient.put(url, Collections.emptyMap(), testObject);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.PUT), Condition.url(url));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 201);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("key"), 1);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("value"), "test");
+ }
+
+ @Test
+ public void testObjectResponseFromPut() throws JsonProcessingException {
+ // given
+ stubPutCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<SyncRestClientModel.TestModel> modelHttpResponse = syncRestClient
+ .put(url, Collections.emptyMap(), testObject, SyncRestClientModel.TestModel.class);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.PUT), Condition.url(url));
+ assertEquals(modelHttpResponse.getStatus(), 201);
+ assertEquals(modelHttpResponse.getBody().getKey(), 1);
+ assertEquals(modelHttpResponse.getBody().getValue(), "test");
+ }
+
+ @Test
+ public void testJsonResponseFromDelete() throws JsonProcessingException {
+ // given
+ stubDeleteCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient.delete(url, Collections.emptyMap());
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.DELETE), Condition.url(url));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("key"), 1);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("value"), "test");
+ }
+
+ @Test
+ public void testObjectResponseFromDelete() throws JsonProcessingException {
+ // given
+ stubDeleteCall();
+ String url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<SyncRestClientModel.TestModel> modelHttpResponse = syncRestClient
+ .delete(url, Collections.emptyMap(), SyncRestClientModel.TestModel.class);
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.DELETE), Condition.url(url));
+ assertEquals(modelHttpResponse.getStatus(), 200);
+ assertEquals(modelHttpResponse.getBody().getKey(), 1);
+ assertEquals(modelHttpResponse.getBody().getValue(), "test");
+ }
+
+ @Test
+ public void testRedirectToHttp() throws JsonProcessingException {
+ // given
+ stubGetCall();
+ String secured_url = "https://0.0.0.0:" + stubServer.getPort() + "/test";
+ String available_url = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient
+ .get(secured_url, Collections.emptyMap(), Collections.emptyMap());
+ // then
+ verifyHttp(stubServer).once(Condition.method(Method.GET), Condition.url(available_url),
+ Condition.not(Condition.url(secured_url)));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ }
+
+ private void stubGetCall() throws JsonProcessingException {
+ whenHttp(stubServer)
+ .match(Condition.get("/test"))
+ .then(ok(), jsonContent(), contentType("application/json"));
+ }
+
+ private void stubDeleteCall() throws JsonProcessingException {
+ whenHttp(stubServer)
+ .match(Condition.delete("/test"))
+ .then(ok(), jsonContent(), contentType("application/json"));
+ }
+
+ private void stubPostCall() throws JsonProcessingException {
+ whenHttp(stubServer)
+ .match(Condition.post("/test"),
+ Condition.withPostBodyContaining(objectMapper.writeValueAsString(testObject)))
+ .then(ok(), jsonContent(), contentType("application/json"));
+ }
+
+ private void stubPutCall() throws JsonProcessingException {
+ whenHttp(stubServer)
+ .match(Condition.put("/test"),
+ Condition.withPostBodyContaining(objectMapper.writeValueAsString(testObject)))
+ .then(status(HttpStatus.CREATED_201), jsonContent(), contentType("application/json"));
+ }
+
+ private Action jsonContent() throws JsonProcessingException {
+ return stringContent(objectMapper.writeValueAsString(testObject));
+ }
+
+} \ No newline at end of file
diff --git a/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpsServerTest.java b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpsServerTest.java
new file mode 100644
index 000000000..ba6da4351
--- /dev/null
+++ b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientForHttpsServerTest.java
@@ -0,0 +1,139 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * VID
+ * ================================================================================
+ * Copyright (C) 2018 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.vid.client;
+
+import io.joshworks.restclient.http.HttpResponse;
+import io.joshworks.restclient.http.JsonNode;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.conn.ssl.SSLContextBuilder;
+import com.xebialabs.restito.semantics.Condition;
+import com.xebialabs.restito.server.StubServer;
+import com.xebialabs.restito.semantics.Action;
+import org.apache.http.config.RegistryBuilder;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.AfterMethod;
+import org.glassfish.grizzly.http.Method;
+import org.apache.http.client.HttpClient;
+import org.apache.http.config.Registry;
+import org.testng.annotations.Test;
+
+import java.security.GeneralSecurityException;
+import javax.net.ssl.SSLContext;
+import java.util.Collections;
+
+import static com.xebialabs.restito.builder.verify.VerifyHttp.verifyHttp;
+import static com.xebialabs.restito.builder.stub.StubHttp.whenHttp;
+import static com.xebialabs.restito.semantics.Action.stringContent;
+import static com.xebialabs.restito.semantics.Action.contentType;
+import static org.apache.http.client.config.RequestConfig.custom;
+import static com.xebialabs.restito.semantics.Action.ok;
+import static org.testng.Assert.assertEquals;
+
+public class SyncRestClientForHttpsServerTest {
+
+ private static final SyncRestClientModel.TestModel testObject = new SyncRestClientModel.TestModel(1, "test");
+ private static final String[] SUPPORTED_PROTOCOLS = {"TLSv1", "TLSv1.2"};
+ private StubServer stubServer;
+ private ObjectMapper objectMapper = new ObjectMapper();
+
+ private SyncRestClient syncRestClient;
+
+ @BeforeMethod
+ public void setUp() throws GeneralSecurityException {
+ stubServer = new StubServer();
+ stubServer.secured().run();
+ syncRestClient = new SyncRestClient(createNaiveHttpClient());
+ }
+
+ @AfterMethod
+ public void tearDown() {
+ stubServer.stop();
+ }
+
+ @Test
+ public void testJsonResponseFromGet() throws JsonProcessingException {
+ // given
+ stubGetCall();
+ String securedUrl = "https://0.0.0.0:" + stubServer.getPort() + "/test";
+ String notSecuredUrl = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<JsonNode> jsonNodeHttpResponse = syncRestClient
+ .get(securedUrl, Collections.emptyMap(), Collections.emptyMap());
+ // then
+ verifyHttp(stubServer)
+ .once(Condition.method(Method.GET), Condition.url(securedUrl), Condition.not(Condition.url(notSecuredUrl)));
+ assertEquals(jsonNodeHttpResponse.getStatus(), 200);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("key"), 1);
+ assertEquals(jsonNodeHttpResponse.getBody().getObject().get("value"), "test");
+ }
+
+ @Test
+ public void testObjectResponseFromGet() throws JsonProcessingException {
+ // given
+ stubServer.run();
+ stubGetCall();
+ String securedUrl = "https://0.0.0.0:" + stubServer.getPort() + "/test";
+ String notSecuredUrl = "http://0.0.0.0:" + stubServer.getPort() + "/test";
+ // when
+ HttpResponse<SyncRestClientModel.TestModel> testModelHttpResponse = syncRestClient
+ .get(securedUrl, Collections.emptyMap(), Collections.emptyMap(), SyncRestClientModel.TestModel.class);
+ // then
+ verifyHttp(stubServer)
+ .once(Condition.method(Method.GET), Condition.url(securedUrl), Condition.not(Condition.url(notSecuredUrl)));
+ assertEquals(testModelHttpResponse.getStatus(), 200);
+ assertEquals(testModelHttpResponse.getBody().getKey(), 1);
+ assertEquals(testModelHttpResponse.getBody().getValue(), "test");
+ }
+
+ private Action jsonContent() throws JsonProcessingException {
+ return stringContent(objectMapper.writeValueAsString(testObject));
+ }
+
+ private void stubGetCall() throws JsonProcessingException {
+ whenHttp(stubServer)
+ .match(Condition.get("/test"))
+ .then(ok(), jsonContent(), contentType("application/json"));
+ }
+
+ private CloseableHttpClient createNaiveHttpClient() throws GeneralSecurityException {
+ final SSLContext context = new SSLContextBuilder().loadTrustMaterial(null, new TrustSelfSignedStrategy())
+ .build();
+
+ final SSLConnectionSocketFactory socketFactory = new SSLConnectionSocketFactory(context, SUPPORTED_PROTOCOLS,
+ null, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
+ Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
+ .register("https", socketFactory)
+ .build();
+
+ return HttpClientBuilder.create()
+ .setDefaultRequestConfig(custom().setConnectionRequestTimeout(10000).build())
+ .setConnectionManager(new PoolingHttpClientConnectionManager(registry))
+ .setSSLSocketFactory(socketFactory).build();
+ }
+
+} \ No newline at end of file
diff --git a/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientModel.java b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientModel.java
new file mode 100644
index 000000000..b64988a23
--- /dev/null
+++ b/vid-app-common/src/test/java/org/onap/vid/client/SyncRestClientModel.java
@@ -0,0 +1,56 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * VID
+ * ================================================================================
+ * Copyright (C) 2018 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.vid.client;
+
+class SyncRestClientModel {
+
+ static class TestModel{
+
+ public TestModel() {
+ // needed by the object mappers
+ }
+
+ public TestModel(long key, String value) {
+ this.key = key;
+ this.value = value;
+ }
+
+ private long key;
+ private String value;
+
+ public void setKey(long key) {
+ this.key = key;
+ }
+
+ public void setValue(String value) {
+ this.value = value;
+ }
+
+ public long getKey() {
+ return key;
+ }
+
+ public String getValue() {
+ return value;
+ }
+ }
+
+}