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));