1 package org.onap.so.adapters.requestsdb.client;
3 import org.junit.Before;
5 import org.junit.runner.RunWith;
6 import org.onap.so.adapters.requestsdb.application.MSORequestDBApplication;
7 import org.onap.so.db.request.beans.InfraActiveRequests;
8 import org.onap.so.db.request.beans.OperationStatus;
9 import org.springframework.beans.factory.annotation.Autowired;
10 import org.springframework.boot.context.embedded.LocalServerPort;
11 import org.springframework.boot.test.context.SpringBootTest;
12 import org.springframework.test.context.ActiveProfiles;
13 import org.springframework.test.context.junit4.SpringRunner;
14 import java.util.List;
15 import java.util.UUID;
17 import java.util.HashMap;
18 import java.util.ArrayList;
20 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
21 import static org.junit.Assert.assertEquals;
22 import static org.junit.Assert.assertNull;
23 import static org.junit.Assert.assertThat;
25 @RunWith(SpringRunner.class)
26 @SpringBootTest(classes = MSORequestDBApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
27 @ActiveProfiles("test")
28 public class RequestsDbClientTest {
31 private RequestDbClientPortChanger requestsDbClient;
33 private InfraActiveRequests infraActiveRequests;
40 requestsDbClient.setPort(port);
42 infraActiveRequests = new InfraActiveRequests();
43 infraActiveRequests.setRequestId(UUID.randomUUID().toString());
44 infraActiveRequests.setOperationalEnvId(UUID.randomUUID().toString());
45 infraActiveRequests.setServiceInstanceId(UUID.randomUUID().toString());
46 infraActiveRequests.setServiceInstanceName("serviceInstanceNameTest");
47 infraActiveRequests.setVnfId(UUID.randomUUID().toString());
48 infraActiveRequests.setVnfName("vnfInstanceNameTest");
49 infraActiveRequests.setVfModuleId(UUID.randomUUID().toString());
50 infraActiveRequests.setVfModuleName("vfModuleInstanceNameTest");
51 infraActiveRequests.setVolumeGroupId(UUID.randomUUID().toString());
52 infraActiveRequests.setVolumeGroupName("volumeGroupInstanceNameTest");
53 infraActiveRequests.setNetworkId(UUID.randomUUID().toString());
54 infraActiveRequests.setNetworkName("networkInstanceNameTest");
55 infraActiveRequests.setConfigurationId(UUID.randomUUID().toString());
56 infraActiveRequests.setConfigurationName("configurationInstanceNameTest");
57 infraActiveRequests.setAicCloudRegion("1");
58 infraActiveRequests.setTenantId(UUID.randomUUID().toString());
59 infraActiveRequests.setRequestScope("operationalEnvironment");
60 infraActiveRequests.setRequestorId(UUID.randomUUID().toString());
61 infraActiveRequests.setSource("sourceTest");
62 infraActiveRequests.setOperationalEnvName(UUID.randomUUID().toString());
63 infraActiveRequests.setRequestStatus("IN_PROGRESS");
64 infraActiveRequests.setAction("create");
65 infraActiveRequests.setRequestAction("someaction");
66 requestsDbClient.save(infraActiveRequests);
69 private void verifyOperationStatus(OperationStatus request,OperationStatus response){
70 assertThat(request, sameBeanAs(response).ignoring("operateAt").ignoring("finishedAt"));
73 private void verifyInfraActiveRequests(InfraActiveRequests infraActiveRequestsResponse) {
74 assertThat(infraActiveRequestsResponse, sameBeanAs(infraActiveRequests).ignoring("modifyTime").ignoring("log"));
78 public void getCloudOrchestrationFiltersFromInfraActiveTest() {
79 Map<String, String> requestMap = new HashMap<>();
80 requestMap.put("operationalEnvironmentId", infraActiveRequests.getOperationalEnvId());
81 requestMap.put("operationalEnvironmentName", infraActiveRequests.getOperationalEnvName());
82 requestMap.put("resourceType", "operationalEnvironment");
84 List<InfraActiveRequests> iarr = requestsDbClient.getCloudOrchestrationFiltersFromInfraActive(requestMap);
86 assertEquals(1, iarr.size());
87 InfraActiveRequests infraActiveRequestsResponse = iarr.get(0);
88 verifyInfraActiveRequests(infraActiveRequestsResponse);
93 public void checkVnfIdStatusTest() {
94 InfraActiveRequests infraActiveRequestsResponse = requestsDbClient.checkVnfIdStatus(infraActiveRequests.getOperationalEnvId());
95 verifyInfraActiveRequests(infraActiveRequestsResponse);
96 assertNull(requestsDbClient.checkVnfIdStatus(UUID.randomUUID().toString()));
100 public void checkInstanceNameDuplicateTest() {
101 InfraActiveRequests infraActiveRequestsResponse = requestsDbClient.checkInstanceNameDuplicate(null,infraActiveRequests.getOperationalEnvName(),infraActiveRequests.getRequestScope());
103 verifyInfraActiveRequests(infraActiveRequestsResponse);
107 public void checkInstanceNameDuplicateViaTest() {
108 Map<String, String> requestMap = new HashMap<>();
109 requestMap.put("operationalEnvironmentId", infraActiveRequests.getOperationalEnvId());
111 InfraActiveRequests infraActiveRequestsResponse = requestsDbClient.checkInstanceNameDuplicate((HashMap<String, String>)requestMap,null,infraActiveRequests.getRequestScope());
113 verifyInfraActiveRequests(infraActiveRequestsResponse);
117 public void getOrchestrationFiltersFromInfraActiveTest() {
118 Map<String, List<String>> requestMap = new HashMap<>();
119 List<String> values = new ArrayList<>();
120 values.add("EQUALS");
121 values.add(infraActiveRequests.getServiceInstanceId());
122 requestMap.put("serviceInstanceId", values);
124 values = new ArrayList<>();
125 values.add("EQUALS");
126 values.add(infraActiveRequests.getServiceInstanceName());
127 requestMap.put("serviceInstanceName", values);
129 List<InfraActiveRequests> iaar = requestsDbClient.getOrchestrationFiltersFromInfraActive(requestMap);
131 assertEquals(1, iaar.size());
132 InfraActiveRequests infraActiveRequestsResponse = iaar.get(0);
134 verifyInfraActiveRequests(infraActiveRequestsResponse);
135 values = new ArrayList<>();
136 values.add("EQUALS");
137 values.add(UUID.randomUUID().toString());
138 requestMap.put("serviceInstanceName", values);
139 requestsDbClient.getOrchestrationFiltersFromInfraActive(requestMap);
143 public void getInfraActiveRequestbyRequestIdTest(){
144 InfraActiveRequests infraActiveRequestsResponse = requestsDbClient.getInfraActiveRequestbyRequestId(infraActiveRequests.getRequestId());
145 verifyInfraActiveRequests(infraActiveRequestsResponse);
146 assertNull(requestsDbClient.getInfraActiveRequestbyRequestId(UUID.randomUUID().toString()));
150 public void getOneByServiceIdAndOperationIdTest(){
151 OperationStatus operationStatus = new OperationStatus();
152 operationStatus.setProgress("IN_PROGRESS");
153 operationStatus.setResult("FAILED");
154 operationStatus.setServiceId(UUID.randomUUID().toString());
155 operationStatus.setOperationContent("operation-content");
156 operationStatus.setOperation("operation");
157 operationStatus.setOperationId(UUID.randomUUID().toString());
158 operationStatus.setReason("reason-test");
159 operationStatus.setUserId(UUID.randomUUID().toString());
160 operationStatus.setServiceName("test-service");
161 requestsDbClient.save(operationStatus);
163 OperationStatus operationStatusResponse = requestsDbClient.getOneByServiceIdAndOperationId(operationStatus.getServiceId(),operationStatus.getOperationId());
165 verifyOperationStatus(operationStatus,operationStatusResponse);
167 assertNull(requestsDbClient.getOneByServiceIdAndOperationId(UUID.randomUUID().toString(),operationStatus.getOperationId()));