diff options
author | Bogumil Zebek <bogumil.zebek@nokia.com> | 2020-11-24 12:56:32 +0100 |
---|---|---|
committer | Zebek Bogumil <bogumil.zebek@nokia.com> | 2020-12-02 13:20:29 +0100 |
commit | f9ff1605045ad31e52fffac2da25f7195d5c7455 (patch) | |
tree | 5b47ef4e46165fefdcb38cff3ac62902df8beadb /sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java | |
parent | d2b10d0697934a82868878c6027962e5cb5d1882 (diff) |
Improve code quality
- fix sonars
- remove potential NullPointerException when HttpClient cannot be created for SSL
- extract code to separate classes
Issue-ID: SDC-3388
Signed-off-by: Zebek Bogumil <bogumil.zebek@nokia.com>
Change-Id: Ic42bc638fddf83a4f3e1944bedf3cc2b92012e5e
Diffstat (limited to 'sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java')
-rw-r--r-- | sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java | 179 |
1 files changed, 179 insertions, 0 deletions
diff --git a/sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java b/sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java new file mode 100644 index 0000000..4e74080 --- /dev/null +++ b/sdc-distribution-client/src/test/java/org/onap/sdc/http/HttpAsdcClientTest.java @@ -0,0 +1,179 @@ +/*- + * ============LICENSE_START======================================================= + * sdc-distribution-client + * ================================================================================ + * Copyright (C) 2020 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.sdc.http; + +import org.apache.http.Header; +import org.apache.http.HttpEntity; +import org.apache.http.StatusLine; +import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.message.BasicHeader; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; +import org.onap.sdc.utils.Pair; +import org.onap.sdc.utils.TestConfiguration; + +import java.io.IOException; +import java.util.HashMap; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; + +@RunWith(MockitoJUnitRunner.class) +public class HttpAsdcClientTest { + + private static final String URL = "http://127.0.0.1:8080/target"; + private static final int HTTP_OK = 200; + private static final String K_1 = "k1"; + private static final String V_1 = "v1"; + private static final String K_2 = "k2"; + private static final String V_2 = "v2"; + private static final Header[] HEADERS = new Header[]{new BasicHeader(K_1, V_1), new BasicHeader(K_2, V_2)}; + private static final HashMap<String, String> HEADERS_MAP = new HashMap<String, String>() {{ + put("key1", "key2"); + }}; + + @Mock + private CloseableHttpClient httpClient; + @Mock + private HttpEntity httpEntity; + + @Test + public void shouldCreateInitializedHttpClient() { + // given + TestConfiguration configuration = new TestConfiguration(); + configuration.setUseHttpsWithSDC(false); + + // when + final HttpRequestFactory httpRequestFactory = new HttpRequestFactory( + configuration.getUser(), + configuration.getPassword()); + final HttpAsdcClient httpAsdcClient = new HttpAsdcClient( + configuration.getAsdcAddress(), + new HttpClientFactory(configuration), + httpRequestFactory); + + // then + assertNotNull(httpAsdcClient); + assertEquals(HttpClientFactory.HTTP, httpAsdcClient.getHttpSchema()); + } + + @Test + public void shouldCreateInitializedHttpsClient() { + // given + TestConfiguration configuration = new TestConfiguration(); + configuration.setUseHttpsWithSDC(true); + + // when + final HttpRequestFactory httpRequestFactory = new HttpRequestFactory( + configuration.getUser(), + configuration.getPassword()); + final HttpAsdcClient httpAsdcClient = new HttpAsdcClient( + configuration.getAsdcAddress(), + new HttpClientFactory(configuration), + httpRequestFactory); + + // then + assertNotNull(httpAsdcClient); + assertEquals(HttpClientFactory.HTTPS, httpAsdcClient.getHttpSchema()); + } + + @Test + public void shouldSendGetRequestWithoutAnyError() throws IOException { + // given + TestConfiguration configuration = givenHttpConfiguration(); + final HttpAsdcClient httpAsdcClient = createTestObj(HttpClientFactory.HTTP, configuration, httpClient); + CloseableHttpResponse httpResponse = givenHttpResponse(); + + // when + final HttpAsdcResponse response = httpAsdcClient.getRequest(URL, HEADERS_MAP); + + // then + assertThat(response).isNotNull(); + assertThat(response.getStatus()).isEqualTo(HTTP_OK); + assertThat(response.getHeadersMap()).containsAllEntriesOf(new HashMap<String, String>() {{ + put(K_1, V_1); + put(K_2, V_2); + }}); + assertThat(response.getMessage()).isEqualTo(httpEntity); + verify(httpResponse).close(); + + } + + @Test + public void shouldSendPostRequestWithoutAnyError() throws IOException { + // given + TestConfiguration configuration = givenHttpConfiguration(); + final HttpAsdcClient httpAsdcClient = createTestObj(HttpClientFactory.HTTP, configuration, httpClient); + CloseableHttpResponse httpResponse = givenHttpResponse(); + + // when + final HttpAsdcResponse response = httpAsdcClient.postRequest(URL,httpEntity, HEADERS_MAP); + + // then + assertThat(response).isNotNull(); + assertThat(response.getStatus()).isEqualTo(HTTP_OK); + assertThat(response.getMessage()).isEqualTo(httpEntity); + verify(httpResponse).close(); + + } + + private HttpAsdcClient createTestObj(String httpProtocol, TestConfiguration configuration, CloseableHttpClient httpClient) { + final HttpRequestFactory httpRequestFactory = new HttpRequestFactory( + configuration.getUser(), + configuration.getPassword()); + HttpClientFactory httpClientFactory = mock(HttpClientFactory.class); + when(httpClientFactory.createInstance()).thenReturn(new Pair<>(httpProtocol, httpClient)); + final HttpAsdcClient httpAsdcClient = new HttpAsdcClient( + configuration.getAsdcAddress(), + httpClientFactory, + httpRequestFactory); + return httpAsdcClient; + } + + private CloseableHttpResponse givenHttpResponse(HttpEntity httpEntity, Header[] headers) { + CloseableHttpResponse httpResponse = mock(CloseableHttpResponse.class); + StatusLine statusLine = mock(StatusLine.class); + when(statusLine.getStatusCode()).thenReturn(HTTP_OK); + when(httpResponse.getStatusLine()).thenReturn(statusLine); + when(httpResponse.getAllHeaders()).thenReturn(headers); + when(httpResponse.getEntity()).thenReturn(httpEntity); + return httpResponse; + } + + private TestConfiguration givenHttpConfiguration() { + TestConfiguration configuration = new TestConfiguration(); + configuration.setUseHttpsWithSDC(false); + return configuration; + } + + private CloseableHttpResponse givenHttpResponse() throws IOException { + CloseableHttpResponse httpResponse = givenHttpResponse(httpEntity, HEADERS); + when(httpClient.execute(any())).thenReturn(httpResponse); + return httpResponse; + } +} |