b23c5bca873c6dea7f359f3f3d47e3a344bb8bfa
[so.git] /
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.orchestration;
22
23 import static org.junit.Assert.assertThat;
24 import static org.mockito.Mockito.doReturn;
25 import static org.mockito.Mockito.times;
26 import static org.mockito.Mockito.verify;
27 import org.junit.Before;
28 import org.junit.Test;
29 import org.junit.runner.RunWith;
30 import org.mockito.InjectMocks;
31 import org.mockito.Mock;
32 import org.mockito.junit.MockitoJUnitRunner;
33 import org.onap.so.bpmn.common.data.TestDataSetup;
34 import org.onap.so.adapters.vnfrest.CreateVolumeGroupRequest;
35 import org.onap.so.adapters.vnfrest.CreateVolumeGroupResponse;
36 import org.onap.so.adapters.vnfrest.DeleteVolumeGroupRequest;
37 import org.onap.so.adapters.vnfrest.DeleteVolumeGroupResponse;
38 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
39 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
40 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
41 import org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule;
42 import org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup;
43 import org.onap.so.bpmn.servicedecomposition.generalobjects.OrchestrationContext;
44 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext;
45 import org.onap.so.client.adapter.vnf.VnfVolumeAdapterClientImpl;
46 import org.onap.so.client.adapter.vnf.mapper.VnfAdapterObjectMapper;
47 import org.onap.so.db.catalog.beans.OrchestrationStatus;
48 import com.shazam.shazamcrest.matcher.Matchers;
49
50 @RunWith(MockitoJUnitRunner.Silent.class)
51 public class VnfAdapterVolumeGroupResourcesTest extends TestDataSetup {
52     @InjectMocks
53     private VnfAdapterVolumeGroupResources vnfAdapterVolumeGroupResources;
54
55     @Mock
56     protected VnfAdapterObjectMapper MOCK_vnfAdapterObjectMapper;
57
58     @Mock
59     protected VnfVolumeAdapterClientImpl MOCK_vnfVolumeAdapterClient;
60
61     private RequestContext requestContext;
62     private ServiceInstance serviceInstance;
63     private GenericVnf genericVnf;
64     private VfModule vfModule;
65     private VolumeGroup volumeGroup;
66     private CloudRegion cloudRegion;
67     private OrchestrationContext orchestrationContext;
68
69     @Before
70     public void before() {
71         requestContext = buildRequestContext();
72         serviceInstance = buildServiceInstance();
73         genericVnf = buildGenericVnf();
74         serviceInstance.getVnfs().add(genericVnf);
75         vfModule = buildVfModule();
76         genericVnf.getVfModules().add(vfModule);
77         volumeGroup = buildVolumeGroup();
78         serviceInstance.getVnfs().get(0).getVolumeGroups().add(volumeGroup);
79         cloudRegion = buildCloudRegion();
80         orchestrationContext = buildOrchestrationContext();
81         orchestrationContext.setIsRollbackEnabled(true);
82     }
83
84     @Test
85     public void test_createVolumeGroup() throws Exception {
86         volumeGroup.setOrchestrationStatus(OrchestrationStatus.ASSIGNED);
87
88         CreateVolumeGroupRequest createVolumeGroupRequest = new CreateVolumeGroupRequest();
89         createVolumeGroupRequest.setCloudSiteId("cloudSiteId");
90
91         CreateVolumeGroupResponse expectedCreateVolumeGroupResponse = new CreateVolumeGroupResponse();
92         expectedCreateVolumeGroupResponse.setVolumeGroupStackId("volumeGroupStackId");
93         expectedCreateVolumeGroupResponse.setVolumeGroupCreated(true);
94
95         String sdncVfModuleQueryResponse = "sdncVfModuleQueryResponse";
96
97         doReturn(createVolumeGroupRequest).when(MOCK_vnfAdapterObjectMapper).createVolumeGroupRequestMapper(
98                 requestContext, cloudRegion, orchestrationContext, serviceInstance, genericVnf, volumeGroup,
99                 sdncVfModuleQueryResponse);
100
101         CreateVolumeGroupRequest actualCreateVolumeGroupResponse =
102                 vnfAdapterVolumeGroupResources.createVolumeGroupRequest(requestContext, cloudRegion,
103                         orchestrationContext, serviceInstance, genericVnf, volumeGroup, sdncVfModuleQueryResponse);
104
105         verify(MOCK_vnfAdapterObjectMapper, times(1)).createVolumeGroupRequestMapper(requestContext, cloudRegion,
106                 orchestrationContext, serviceInstance, genericVnf, volumeGroup, sdncVfModuleQueryResponse);
107
108         assertThat(createVolumeGroupRequest, Matchers.sameBeanAs(actualCreateVolumeGroupResponse));
109     }
110
111     @Test
112     public void test_deleteVolumeGroup() throws Exception {
113         DeleteVolumeGroupRequest deleteVolumeGroupRequest = new DeleteVolumeGroupRequest();
114         doReturn(deleteVolumeGroupRequest).when(MOCK_vnfAdapterObjectMapper)
115                 .deleteVolumeGroupRequestMapper(requestContext, cloudRegion, serviceInstance, volumeGroup);
116
117         DeleteVolumeGroupRequest expectedDeleteVolumeGroupRequest = new DeleteVolumeGroupRequest();
118         DeleteVolumeGroupRequest actualDeleteVolumeGroupRequest = vnfAdapterVolumeGroupResources
119                 .deleteVolumeGroupRequest(requestContext, cloudRegion, serviceInstance, volumeGroup);
120
121         verify(MOCK_vnfAdapterObjectMapper, times(1)).deleteVolumeGroupRequestMapper(requestContext, cloudRegion,
122                 serviceInstance, volumeGroup);
123         assertThat(expectedDeleteVolumeGroupRequest, Matchers.sameBeanAs(actualDeleteVolumeGroupRequest));
124     }
125 }