7ce47a008031c2a5412938b5c995c096b208a61b
[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.anyMap;
24 import static org.mockito.ArgumentMatchers.anyString;
25 import static org.mockito.ArgumentMatchers.eq;
26 import static org.mockito.BDDMockito.given;
27 import static org.mockito.Mockito.verify;
28 import static org.onap.dcaegen2.services.sdk.rest.services.aai.client.AaiClientConfigurations.secureConfiguration;
29
30 import java.util.HashMap;
31 import java.util.Map;
32 import org.junit.jupiter.api.Test;
33 import org.onap.dcaegen2.services.sdk.rest.services.aai.client.service.http.AbstractHttpClientTest;
34 import org.onap.dcaegen2.services.sdk.rest.services.model.AaiModel;
35 import org.onap.dcaegen2.services.sdk.rest.services.model.JsonBodyBuilder;
36 import org.onap.dcaegen2.services.sdk.rest.services.model.logging.RequestDiagnosticContext;
37 import reactor.core.publisher.Mono;
38 import reactor.test.StepVerifier;
39
40 class AaiHttpPutClientTest extends AbstractHttpClientTest {
41
42     @Test
43     void getAaiResponse_shouldCallPutMethod_withGivenAaiHeaders() {
44         Map<String, String> headers = new HashMap<>();
45         AaiHttpPutClient cut = new AaiHttpPutClient(secureConfiguration(headers), bodyBuilder, "", httpClient);
46
47         given(httpClient.put(
48                 anyString(),
49                 any(RequestDiagnosticContext.class),
50                 anyMap(),
51                 any(JsonBodyBuilder.class),
52                 any(AaiModel.class)
53         )).willReturn(Mono.just(response));
54
55         StepVerifier
56                 .create(cut.getAaiResponse(aaiModel))
57                 .expectNext(response)
58                 .verifyComplete();
59
60         verify(httpClient).put(
61                 anyString(),
62                 any(RequestDiagnosticContext.class),
63                 eq(headers),
64                 eq(bodyBuilder),
65                 eq(aaiModel)
66         );
67     }
68
69     @Test
70     void getAaiResponse_shouldCallPutMethod_withProperUri() {
71         String uri = "test-uri";
72         AaiHttpPutClient cut = new AaiHttpPutClient(secureConfiguration(), bodyBuilder, uri, httpClient);
73
74         given(httpClient.put(
75                 anyString(),
76                 any(RequestDiagnosticContext.class),
77                 anyMap(),
78                 any(JsonBodyBuilder.class),
79                 any(AaiModel.class)
80         )).willReturn(Mono.just(response));
81
82         StepVerifier
83                 .create(cut.getAaiResponse(aaiModel))
84                 .expectNext(response)
85                 .verifyComplete();
86
87         verify(httpClient).put(
88                 eq(uri),
89                 any(RequestDiagnosticContext.class),
90                 anyMap(),
91                 eq(bodyBuilder),
92                 eq(aaiModel)
93         );
94     }
95 }