8c17237830cbc6a82a2f7041fe6a667e2d944243
[so.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2017 - 2019 AT&T 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
21 package org.onap.so.apihandlerinfra.infra.rest.handler;
22
23 import static com.shazam.shazamcrest.MatcherAssert.assertThat;
24 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
25 import static org.junit.Assert.assertEquals;
26 import static org.mockito.ArgumentMatchers.eq;
27 import java.util.HashMap;
28 import java.util.Map;
29 import javax.ws.rs.container.ContainerRequestContext;
30 import org.junit.Rule;
31 import org.junit.Test;
32 import org.junit.rules.ExpectedException;
33 import org.junit.runner.RunWith;
34 import org.mockito.ArgumentCaptor;
35 import org.mockito.InjectMocks;
36 import org.mockito.Mock;
37 import org.mockito.Mockito;
38 import org.mockito.junit.MockitoJUnitRunner;
39 import org.onap.so.apihandler.common.RequestClientParameter;
40 import org.onap.so.apihandlerinfra.Action;
41 import org.onap.so.apihandlerinfra.Constants;
42 import org.onap.so.constants.Status;
43 import org.onap.so.db.catalog.client.CatalogDbClient;
44 import org.onap.so.db.request.beans.InfraActiveRequests;
45 import org.onap.so.db.request.client.RequestsDbClient;
46 import org.onap.so.serviceinstancebeans.ModelType;
47 import org.onap.so.serviceinstancebeans.RequestDetails;
48 import org.onap.so.serviceinstancebeans.RequestInfo;
49 import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
50 import com.fasterxml.jackson.databind.ObjectMapper;
51
52 @RunWith(MockitoJUnitRunner.class)
53 public class NetworkRestHandlerTest {
54
55     @Rule
56     public ExpectedException exceptionRule = ExpectedException.none();
57
58     @InjectMocks
59     NetworkRestHandler restHandler;
60
61     @Mock
62     ContainerRequestContext mockRequestContext;
63
64     @Mock
65     private CatalogDbClient catalogDbClient;
66
67     @Mock
68     private RequestsDbClient infraActiveRequestsClient;
69
70     private ObjectMapper mapper = new ObjectMapper();
71
72     @Test
73     public void test_checkDuplicateRequest() {
74         ArgumentCaptor<HashMap> instanceIdCaptor = ArgumentCaptor.forClass(HashMap.class);
75         restHandler.checkDuplicateRequest("serviceInstanceId", "networkId", "instanceName", "requestId");
76         Mockito.verify(infraActiveRequestsClient, Mockito.times(1)).checkInstanceNameDuplicate(
77                 instanceIdCaptor.capture(), eq("instanceName"), eq(ModelType.network.toString()));
78         Map actualMap = instanceIdCaptor.getValue();
79         assertEquals("ServiceInstanceID should exist in map", "serviceInstanceId", actualMap.get("serviceInstanceId"));
80         assertEquals("NetworkId should exit in map", "networkId", actualMap.get("networkInstanceId"));
81     }
82
83     @Test
84     public void test_saveInstanceName() {
85         ServiceInstancesRequest request = createTestRequest();
86         InfraActiveRequests dbRequest = createDatabaseRecord();
87         restHandler.saveInstanceName(request, dbRequest);
88         Mockito.verify(infraActiveRequestsClient, Mockito.times(1)).updateInfraActiveRequests(dbRequest);
89         assertEquals("InstanceName Should Be Equal", "instanceName", dbRequest.getNetworkName());
90     }
91
92     @Test
93     public void test_buildRequestParams() throws Exception {
94         RequestClientParameter expected = new RequestClientParameter.Builder().setRequestId("requestId")
95                 .setServiceInstanceId("serviceInstanceId").setNetworkId("networkId").setALaCarte(true)
96                 .setRequestDetails(mapper.writeValueAsString(createTestRequest()))
97                 .setRequestAction(Action.deleteInstance.toString())
98                 .setRequestUri("http://localhost:8080/serviceInstances").setApiVersion("v8").build();
99         RequestClientParameter actual = restHandler.buildRequestParams(createTestRequest(),
100                 "http://localhost:8080/serviceInstances", "requestId", "serviceInstanceId", "networkId");
101         assertThat(actual, sameBeanAs(expected));
102     }
103
104     @Test
105     public void test_createInfraActiveRequestForDelete() {
106         InfraActiveRequests expected = new InfraActiveRequests();
107         expected.setRequestAction(Action.deleteInstance.toString());
108         expected.setServiceInstanceId("serviceInstanceId");
109         expected.setNetworkId("networkId");
110         expected.setRequestId("requestId");
111         expected.setRequestorId("userId");
112         expected.setSource("VID");
113         expected.setRequestStatus(Status.IN_PROGRESS.toString());
114         expected.setLastModifiedBy(Constants.MODIFIED_BY_APIHANDLER);
115         expected.setRequestScope(ModelType.network.toString());
116         expected.setRequestUrl("http://localhost:9090");
117         InfraActiveRequests actual = restHandler.createInfraActiveRequestForDelete("requestId", "serviceInstanceId",
118                 "networkId", "userId", "VID", "http://localhost:9090");
119         assertThat(actual, sameBeanAs(expected).ignoring("startTime"));
120         Mockito.verify(infraActiveRequestsClient, Mockito.times(1)).save(actual);
121     }
122
123     private ServiceInstancesRequest createTestRequest() {
124         ServiceInstancesRequest request = new ServiceInstancesRequest();
125         RequestDetails requestDetails = new RequestDetails();
126         RequestInfo requestInfo = new RequestInfo();
127         requestInfo.setInstanceName("instanceName");
128         requestDetails.setRequestInfo(requestInfo);
129         request.setRequestDetails(requestDetails);
130         return request;
131     }
132
133     private InfraActiveRequests createDatabaseRecord() {
134         InfraActiveRequests request = new InfraActiveRequests();
135         request.setRequestId("requestId");
136         return request;
137     }
138
139 }