d14eca18935e8820bd4663a6b96b97e3f1694a6e
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * DCAEGEN2-SERVICES-SDK
4  * ================================================================================
5  * Copyright (C) 2019 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
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 package org.onap.dcaegen2.services.sdk.rest.services.aai.client.service.http.put;
21
22 import static org.mockito.ArgumentMatchers.any;
23 import static org.mockito.ArgumentMatchers.argThat;
24 import static org.mockito.ArgumentMatchers.eq;
25 import static org.mockito.BDDMockito.given;
26 import static org.mockito.Mockito.verify;
27 import static org.onap.dcaegen2.services.sdk.rest.services.aai.client.AaiClientConfigurations.secureConfiguration;
28
29 import io.vavr.collection.HashMap;
30 import io.vavr.collection.Map;
31 import org.junit.jupiter.api.Test;
32 import org.onap.dcaegen2.services.sdk.rest.services.aai.client.service.http.AbstractHttpClientTest;
33 import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.HttpRequest;
34 import reactor.core.publisher.Mono;
35 import reactor.test.StepVerifier;
36
37 class AaiHttpPutClientTest extends AbstractHttpClientTest {
38
39     @Test
40     void getAaiResponse_shouldCallPutMethod_withGivenAaiHeaders() {
41         Map<String, String> headers = HashMap.of("sample-key", "sample-value");
42         AaiHttpPutClient cut = new AaiHttpPutClient(secureConfiguration(headers.toJavaMap()), bodyBuilder, "",
43                 httpClient);
44
45         given(bodyBuilder.createJsonBody(eq(aaiModel)))
46                 .willReturn("test-body");
47
48         given(httpClient.call(any(HttpRequest.class)))
49                 .willReturn(Mono.just(response));
50
51         StepVerifier
52                 .create(cut.getAaiResponse(aaiModel))
53                 .expectNext(response)
54                 .verifyComplete();
55
56         verify(httpClient)
57                 .call(argThat(httpRequest -> httpRequest.customHeaders().equals(headers)));
58     }
59
60     @Test
61     void getAaiResponse_shouldCallPutMethod_withProperUri() {
62         String uri = "test-uri";
63         AaiHttpPutClient cut = new AaiHttpPutClient(secureConfiguration(), bodyBuilder, uri, httpClient);
64
65         given(bodyBuilder.createJsonBody(eq(aaiModel)))
66                 .willReturn("test-body");
67
68         given(httpClient.call(any(HttpRequest.class)))
69                 .willReturn(Mono.just(response));
70
71         StepVerifier
72                 .create(cut.getAaiResponse(aaiModel))
73                 .expectNext(response)
74                 .verifyComplete();
75
76         verify(httpClient)
77                 .call(argThat(httpRequest -> httpRequest.url().equals(uri)));
78
79     }
80 }