0ad8d1458ee33cfab1c5e054c05e13bac70b19f3
[so.git] /
1 package org.onap.so.db.request.client;
2
3 import static org.mockito.ArgumentMatchers.eq;
4 import static org.mockito.ArgumentMatchers.isA;
5 import static org.mockito.Mockito.times;
6 import java.net.URI;
7 import javax.ws.rs.core.UriBuilder;
8 import org.junit.Before;
9 import org.junit.Test;
10 import org.junit.runner.RunWith;
11 import org.mockito.InjectMocks;
12 import org.mockito.Mock;
13 import org.mockito.Mockito;
14 import org.mockito.Spy;
15 import org.mockito.junit.MockitoJUnitRunner;
16 import org.onap.logging.filter.spring.SpringClientPayloadFilter;
17 import org.onap.so.db.request.beans.InfraActiveRequests;
18 import org.onap.so.db.request.beans.RequestProcessingData;
19 import org.onap.so.logging.jaxrs.filter.SOSpringClientFilter;
20 import org.springframework.beans.factory.annotation.Value;
21 import org.springframework.http.HttpEntity;
22 import org.springframework.http.HttpHeaders;
23 import org.springframework.http.HttpMethod;
24 import org.springframework.http.ResponseEntity;
25 import org.springframework.http.client.BufferingClientHttpRequestFactory;
26 import org.springframework.http.client.ClientHttpRequestFactory;
27 import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
28 import org.springframework.web.client.RestTemplate;
29 import uk.co.blackpepper.bowman.ClientFactory;
30 import uk.co.blackpepper.bowman.Configuration;
31
32
33 @RunWith(MockitoJUnitRunner.class)
34 public class RequestDbClientTest {
35     @Spy
36     @InjectMocks
37     protected RequestsDbClient requestsDbClient;
38
39     @Mock
40     protected RestTemplate restTemplate;
41
42     @Test
43     public void updateRequestProcessingDataTest() {
44         RequestProcessingData requestProcessingData = new RequestProcessingData();
45         requestProcessingData.setId(1);
46         URI uri = URI.create("/requestProcessingData/1");
47         requestsDbClient.updateRequestProcessingData(requestProcessingData);
48         Mockito.verify(restTemplate, times(1)).put(eq(uri), isA(HttpEntity.class));
49     }
50
51     @Test
52     public void updateInfraActiveRequestsTest() {
53         InfraActiveRequests request = new InfraActiveRequests();
54         request.setRequestId("1");
55         URI uri = URI.create("/infraActiveRequests/1");
56         requestsDbClient.patchInfraActiveRequests(request);
57         Mockito.verify(restTemplate, times(1)).exchange(eq(uri), eq(HttpMethod.PATCH), isA(HttpEntity.class),
58                 eq(String.class));
59     }
60
61     @Test
62     public void testGetRequestProcessingDataBySoRequestIdAndIsInternalData() {
63         Mockito.doReturn("host").when(requestsDbClient).getEndpoint();
64         requestsDbClient.getExternalRequestProcessingDataBySoRequestId("12345");
65         URI uri = URI.create(UriBuilder
66                 .fromUri("host/requestProcessingData/search/findBySoRequestIdAndIsDataInternalOrderByGroupingIdDesc")
67                 .queryParam("SO_REQUEST_ID", "12345").queryParam("IS_INTERNAL_DATA", false).build().toString());
68         Mockito.verify(restTemplate, times(1)).exchange(eq(uri), eq(HttpMethod.GET), isA(HttpEntity.class),
69                 eq(RequestProcessingData[].class));
70     }
71
72 }