2 // * ============LICENSE_START=======================================================
3 // * PNF-REGISTRATION-HANDLER
4 // * ================================================================================
5 // * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved.
6 // * ================================================================================
7 // * Licensed under the Apache License, Version 2.0 (the "License");
8 // * you may not use this file except in compliance with the License.
9 // * You may obtain a copy of the License at
11 // * http://www.apache.org/licenses/LICENSE-2.0
13 // * Unless required by applicable law or agreed to in writing, software
14 // * distributed under the License is distributed on an "AS IS" BASIS,
15 // * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 // * See the License for the specific language governing permissions and
17 // * limitations under the License.
18 // * ============LICENSE_END=========================================================
21 //package org.onap.dcaegen2.services.prh.service.consumer;
23 //import org.apache.http.client.ResponseHandler;
24 //import org.apache.http.client.methods.HttpGet;
25 //import org.apache.http.impl.client.CloseableHttpClient;
26 //import org.junit.jupiter.api.Assertions;
27 //import org.junit.jupiter.api.BeforeAll;
28 //import org.junit.jupiter.api.Test;
29 //import org.onap.dcaegen2.services.prh.config.DmaapConsumerConfiguration;
31 //import java.io.IOException;
32 //import java.lang.reflect.Field;
33 //import java.util.Optional;
35 //import static org.mockito.ArgumentMatchers.any;
36 //import static org.mockito.Mockito.mock;
37 //import static org.mockito.Mockito.when;
40 //public class ExtendedDmaapConsumerHttpClientImplTest {
42 // private static ExtendedDmaapConsumerHttpClientImpl objectUnderTest;
44 // private static DmaapConsumerConfiguration configurationMock = mock(DmaapConsumerConfiguration.class);
45 // private static CloseableHttpClient closeableHttpClientMock = mock(CloseableHttpClient.class);
47 // private static final String JSON_MESSAGE = "{ \"responseFromDmaap\": \"Success\" }";
49 // private static Optional<String> expectedResult = Optional.empty();
52 // public static void init() throws NoSuchFieldException, IllegalAccessException {
54 // when(configurationMock.dmaapHostName()).thenReturn("54.45.33.2");
55 // when(configurationMock.dmaapProtocol()).thenReturn("https");
56 // when(configurationMock.dmaapPortNumber()).thenReturn(1234);
57 // when(configurationMock.dmaapUserName()).thenReturn("PRH");
58 // when(configurationMock.dmaapUserPassword()).thenReturn("PRH");
59 // when(configurationMock.dmaapContentType()).thenReturn("application/json");
60 // when(configurationMock.dmaapTopicName()).thenReturn("unauthenticated.SEC_OTHER_OUTPUT");
61 // when(configurationMock.consumerGroup()).thenReturn("OpenDCAE-c12");
62 // when(configurationMock.consumerId()).thenReturn("c12");
64 // objectUnderTest = new ExtendedDmaapConsumerHttpClientImpl(configurationMock);
71 // public void getHttpResponseGet_success() throws IOException {
72 // expectedResult = Optional.of(JSON_MESSAGE);
74 // when(closeableHttpClientMock.execute(any(HttpGet.class), any(ResponseHandler.class)))
75 // .thenReturn(expectedResult);
77 // Optional<String> actualResult = objectUnderTest.getHttpConsumerResponse();
79 // Assertions.assertEquals(expectedResult.get(), actualResult.get());
83 // public void getExtendedDetails_returnsNull() throws IOException {
84 // when(closeableHttpClientMock.execute(any(HttpGet.class), any(ResponseHandler.class))).
85 // thenReturn(Optional.empty());
86 // Optional<String> actualResult = objectUnderTest.getHttpConsumerResponse();
87 // Assertions.assertEquals(Optional.empty(),actualResult);
91 // private static void setField() throws NoSuchFieldException, IllegalAccessException {
92 // Field field = objectUnderTest.getClass().getDeclaredField("closeableHttpClient");
93 // field.setAccessible(true);
94 // field.set(objectUnderTest, closeableHttpClientMock);