1 package org.onap.so.db.request.client;
3 import static org.mockito.ArgumentMatchers.eq;
4 import static org.mockito.ArgumentMatchers.isA;
5 import static org.mockito.Mockito.times;
7 import javax.ws.rs.core.UriBuilder;
8 import org.junit.Before;
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;
33 @RunWith(MockitoJUnitRunner.class)
34 public class RequestDbClientTest {
37 protected RequestsDbClient requestsDbClient;
40 protected RestTemplate restTemplate;
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));
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),
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));