Springboot 2.0 upgrade
[so.git] / bpmn / so-bpmn-tasks / src / test / java / org / onap / so / client / adapter / vnf / VnfVolumeAdapterClientIT.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP - SO
4  * ================================================================================
5  * Copyright (C) 2017 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.client.adapter.vnf;
22
23 import static org.junit.Assert.assertEquals;
24 import static org.mockito.Mockito.doReturn;
25 import static org.mockito.Mockito.mock;
26 import static org.mockito.Mockito.spy;
27 import static org.mockito.Mockito.when;
28
29 import javax.ws.rs.InternalServerErrorException;
30 import javax.ws.rs.core.UriBuilder;
31
32 import org.junit.Test;
33 import org.junit.runner.RunWith;
34 import org.mockito.MockitoAnnotations;
35 import org.mockito.junit.MockitoJUnitRunner;
36 import org.onap.so.adapters.vnfrest.CreateVolumeGroupRequest;
37 import org.onap.so.adapters.vnfrest.CreateVolumeGroupResponse;
38 import org.onap.so.adapters.vnfrest.DeleteVolumeGroupRequest;
39 import org.onap.so.adapters.vnfrest.DeleteVolumeGroupResponse;
40 import org.onap.so.adapters.vnfrest.RollbackVolumeGroupRequest;
41 import org.onap.so.adapters.vnfrest.RollbackVolumeGroupResponse;
42 import org.onap.so.adapters.vnfrest.UpdateVolumeGroupRequest;
43 import org.onap.so.adapters.vnfrest.UpdateVolumeGroupResponse;
44 import org.onap.so.client.adapter.rest.AdapterRestClient;
45 import org.onap.so.BaseIntegrationTest;
46
47
48 @RunWith(MockitoJUnitRunner.Silent.class)
49 public class VnfVolumeAdapterClientIT extends BaseIntegrationTest{
50
51         private static final String TESTING_ID = "___TESTING___";
52         private static final String AAI_VOLUME_GROUP_ID = "test";
53         private static final String CLOUD_SITE_ID = "test";
54         private static final String TENANT_ID = "test";
55         private static final String VOLUME_GROUP_STACK_ID = "test";
56         private static final boolean SKIP_AAI = true;
57         private static final String REQUEST_ID = "test";
58         private static final String SERVICE_INSTANCE_ID = "test";
59
60         @Test
61         public void createVolumeGroupTest() throws VnfAdapterClientException {
62                 CreateVolumeGroupRequest request = new CreateVolumeGroupRequest();
63                 request.setCloudSiteId(TESTING_ID);
64
65                 CreateVolumeGroupResponse mockResponse = new CreateVolumeGroupResponse();
66                 mockResponse.setVolumeGroupCreated(true);
67
68                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
69                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
70
71                 doReturn(mockClient).when(client).getAdapterRestClient("");
72                 when(mockClient.post(request, CreateVolumeGroupResponse.class)).thenReturn(mockResponse);
73
74                 CreateVolumeGroupResponse response = client.createVNFVolumes(request);
75                 assertEquals("Testing CreateVolumeGroup response", mockResponse.getVolumeGroupCreated(),
76                                 response.getVolumeGroupCreated());
77         }
78
79         @Test(expected = VnfAdapterClientException.class)
80         public void createVolumeGroupTestThrowException() throws VnfAdapterClientException {
81                 CreateVolumeGroupRequest request = new CreateVolumeGroupRequest();
82                 request.setCloudSiteId(TESTING_ID);
83
84                 CreateVolumeGroupResponse mockResponse = new CreateVolumeGroupResponse();
85                 mockResponse.setVolumeGroupCreated(true);
86
87                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
88                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
89
90                 doReturn(mockClient).when(client).getAdapterRestClient("");
91                 when(mockClient.post(request, CreateVolumeGroupResponse.class)).thenThrow(new InternalServerErrorException("Error in create volume group"));
92
93                 client.createVNFVolumes(request);
94         }
95
96         @Test
97         public void deleteVolumeGroupTest() throws VnfAdapterClientException {
98                 DeleteVolumeGroupRequest request = new DeleteVolumeGroupRequest();
99                 request.setCloudSiteId(TESTING_ID);
100
101                 DeleteVolumeGroupResponse mockResponse = new DeleteVolumeGroupResponse();
102                 mockResponse.setVolumeGroupDeleted(true);
103
104                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
105                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
106                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID);
107                 when(mockClient.delete(request, DeleteVolumeGroupResponse.class)).thenReturn(mockResponse);
108                 MockitoAnnotations.initMocks(this);
109
110                 DeleteVolumeGroupResponse response = client.deleteVNFVolumes(AAI_VOLUME_GROUP_ID, request);
111                 assertEquals("Testing DeleteVolumeGroup response", mockResponse.getVolumeGroupDeleted(),
112                                 response.getVolumeGroupDeleted());
113         }
114
115         @Test(expected = VnfAdapterClientException.class)
116         public void deleteVolumeGroupTestThrowException() throws VnfAdapterClientException {
117                 DeleteVolumeGroupRequest request = new DeleteVolumeGroupRequest();
118                 request.setCloudSiteId(TESTING_ID);
119
120                 DeleteVolumeGroupResponse mockResponse = new DeleteVolumeGroupResponse();
121                 mockResponse.setVolumeGroupDeleted(true);
122
123                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
124                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
125                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID);
126                 when(mockClient.delete(request, DeleteVolumeGroupResponse.class))
127                                 .thenThrow(new InternalServerErrorException("Error in delete volume group"));
128                 MockitoAnnotations.initMocks(this);
129
130                 client.deleteVNFVolumes(AAI_VOLUME_GROUP_ID, request);
131         }
132
133         @Test
134         public void rollbackVolumeGroupTest() throws VnfAdapterClientException {
135                 RollbackVolumeGroupRequest request = new RollbackVolumeGroupRequest();
136
137                 RollbackVolumeGroupResponse mockResponse = new RollbackVolumeGroupResponse();
138                 mockResponse.setVolumeGroupRolledBack(true);
139
140                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
141                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
142                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID + "/rollback");
143                 when(mockClient.delete(request, RollbackVolumeGroupResponse.class)).thenReturn(mockResponse);
144                 MockitoAnnotations.initMocks(this);
145
146                 RollbackVolumeGroupResponse response = client.rollbackVNFVolumes(AAI_VOLUME_GROUP_ID, request);
147                 assertEquals("Testing RollbackVolumeGroup response", mockResponse.getVolumeGroupRolledBack(),
148                                 response.getVolumeGroupRolledBack());
149         }
150
151         @Test(expected = VnfAdapterClientException.class)
152         public void rollbackVolumeGroupTestThrowException() throws VnfAdapterClientException {
153                 RollbackVolumeGroupRequest request = new RollbackVolumeGroupRequest();
154
155                 RollbackVolumeGroupResponse mockResponse = new RollbackVolumeGroupResponse();
156                 mockResponse.setVolumeGroupRolledBack(true);
157
158                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
159                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
160                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID + "/rollback");
161                 when(mockClient.delete(request, RollbackVolumeGroupResponse.class))
162                                 .thenThrow(new InternalServerErrorException("Error in rollback volume group"));
163                 MockitoAnnotations.initMocks(this);
164
165                 client.rollbackVNFVolumes(AAI_VOLUME_GROUP_ID, request);
166         }
167
168         @Test
169         public void updateVolumeGroupTest() throws VnfAdapterClientException {
170                 UpdateVolumeGroupRequest request = new UpdateVolumeGroupRequest();
171
172                 UpdateVolumeGroupResponse mockResponse = new UpdateVolumeGroupResponse();
173                 mockResponse.setVolumeGroupId(AAI_VOLUME_GROUP_ID);
174
175                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
176                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
177                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID);
178                 when(mockClient.put(request, UpdateVolumeGroupResponse.class)).thenReturn(mockResponse);
179                 MockitoAnnotations.initMocks(this);
180
181                 UpdateVolumeGroupResponse response = client.updateVNFVolumes(AAI_VOLUME_GROUP_ID, request);
182                 assertEquals("Testing DeleteVfModule response", mockResponse.getVolumeGroupId(), response.getVolumeGroupId());
183         }
184
185         @Test(expected = VnfAdapterClientException.class)
186         public void updateVolumeGroupTestThrowException() throws VnfAdapterClientException {
187                 UpdateVolumeGroupRequest request = new UpdateVolumeGroupRequest();
188
189                 UpdateVolumeGroupResponse mockResponse = new UpdateVolumeGroupResponse();
190                 mockResponse.setVolumeGroupId(AAI_VOLUME_GROUP_ID);
191
192                 VnfVolumeAdapterClientImpl client = spy(VnfVolumeAdapterClientImpl.class);
193                 AdapterRestClient mockClient = mock(AdapterRestClient.class);
194                 doReturn(mockClient).when(client).getAdapterRestClient("/" + AAI_VOLUME_GROUP_ID);
195                 when(mockClient.put(request, UpdateVolumeGroupResponse.class))
196                                 .thenThrow(new InternalServerErrorException("Error in update volume group"));
197                 MockitoAnnotations.initMocks(this);
198
199                 client.updateVNFVolumes(AAI_VOLUME_GROUP_ID, request);
200         }
201
202         public void buildQueryPathTest() {
203                 String expectedOutput = "/" + AAI_VOLUME_GROUP_ID + "?cloudSiteId=" + CLOUD_SITE_ID + "&tenantId=" + TENANT_ID
204                                 + "&volumeGroupStackId=" + VOLUME_GROUP_STACK_ID + "&skipAAI=" + SKIP_AAI + "&msoRequest.requestId="
205                                 + REQUEST_ID + "&msoRequest.serviceInstanceId=" + SERVICE_INSTANCE_ID;
206                 VnfVolumeAdapterClientImpl client = new VnfVolumeAdapterClientImpl();
207                 assertEquals("Test build query path", expectedOutput, client.buildQueryPath(AAI_VOLUME_GROUP_ID, CLOUD_SITE_ID,
208                                 TENANT_ID, VOLUME_GROUP_STACK_ID, SKIP_AAI, REQUEST_ID, SERVICE_INSTANCE_ID));
209         }
210
211         protected UriBuilder getUri(String path) {
212                 return UriBuilder.fromPath(path);
213         }
214 }