78b79f9d005ef727ed9352d6c4d5d917c4fc2437
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START====================================
3  * DCAEGEN2-SERVICES-SDK
4  * =========================================================
5  * Copyright (C) 2019 Nokia. 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
10  *
11  *       http://www.apache.org/licenses/LICENSE-2.0
12  *
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=====================================
19  */
20
21 package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl;
22
23 import static org.assertj.core.api.Assertions.assertThat;
24 import static org.mockito.ArgumentMatchers.any;
25 import static org.mockito.BDDMockito.given;
26 import static org.mockito.Mockito.mock;
27 import static org.mockito.Mockito.verify;
28
29 import com.google.gson.JsonObject;
30 import java.net.InetSocketAddress;
31 import org.junit.jupiter.api.Test;
32 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpMethod;
33 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpRequest;
34 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpResponse;
35 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.ImmutableHttpRequest;
36 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.ImmutableHttpResponse;
37 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.RxHttpClient;
38 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.CbsClient;
39 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.CbsRequests;
40 import org.onap.dcaegen2.services.sdk.rest.services.model.logging.RequestDiagnosticContext;
41 import reactor.core.publisher.Mono;
42
43 /**
44  * @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
45  * @since February 2019
46  */
47 class CbsClientImplTest {
48     private final RxHttpClient httpClient = mock(RxHttpClient.class);
49
50     @Test
51     void shouldFetchUsingProperUrl() {
52         // given
53         InetSocketAddress cbsAddress = InetSocketAddress.createUnresolved("cbshost", 6969);
54         String serviceName = "dcaegen2-ves-collector";
55         final CbsClient cut = new CbsClientImpl(httpClient, serviceName, cbsAddress);
56         final HttpResponse httpResponse = ImmutableHttpResponse.builder()
57                 .url("http://xxx")
58                 .statusCode(200)
59                 .rawBody("{}".getBytes())
60                 .build();
61         given(httpClient.call(any(HttpRequest.class))).willReturn(Mono.just(httpResponse));
62         RequestDiagnosticContext diagnosticContext = RequestDiagnosticContext.create();
63
64         // when
65         final JsonObject result = cut.get(CbsRequests.getConfiguration(diagnosticContext)).block();
66
67         // then
68         final String expectedUrl = "http://cbshost:6969/service_component/dcaegen2-ves-collector";
69         verify(httpClient).call(ImmutableHttpRequest.builder()
70                 .method(HttpMethod.GET)
71                 .url(expectedUrl)
72                 .diagnosticContext(diagnosticContext)
73                 .build());
74         assertThat(result.toString()).isEqualTo(httpResponse.bodyAsString());
75     }
76 }