2  * ============LICENSE_START=======================================================
 
   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
 
  11  *      http://www.apache.org/licenses/LICENSE-2.0
 
  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=========================================================
 
  21 package org.onap.so.client.orchestration;
 
  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.bpmn.servicedecomposition.bbobjects.CloudRegion;
 
  38 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
 
  39 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
 
  40 import org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule;
 
  41 import org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup;
 
  42 import org.onap.so.bpmn.servicedecomposition.generalobjects.OrchestrationContext;
 
  43 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext;
 
  44 import org.onap.so.client.adapter.vnf.VnfVolumeAdapterClientImpl;
 
  45 import org.onap.so.client.adapter.vnf.mapper.VnfAdapterObjectMapper;
 
  46 import org.onap.so.db.catalog.beans.OrchestrationStatus;
 
  47 import com.shazam.shazamcrest.matcher.Matchers;
 
  49 @RunWith(MockitoJUnitRunner.Silent.class)
 
  50 public class VnfAdapterVolumeGroupResourcesTest extends TestDataSetup {
 
  52     private VnfAdapterVolumeGroupResources vnfAdapterVolumeGroupResources;
 
  55     protected VnfAdapterObjectMapper MOCK_vnfAdapterObjectMapper;
 
  58     protected VnfVolumeAdapterClientImpl MOCK_vnfVolumeAdapterClient;
 
  60     private RequestContext requestContext;
 
  61     private ServiceInstance serviceInstance;
 
  62     private GenericVnf genericVnf;
 
  63     private VfModule vfModule;
 
  64     private VolumeGroup volumeGroup;
 
  65     private CloudRegion cloudRegion;
 
  66     private OrchestrationContext orchestrationContext;
 
  69     public void before() {
 
  70         requestContext = buildRequestContext();
 
  71         serviceInstance = buildServiceInstance();
 
  72         genericVnf = buildGenericVnf();
 
  73         serviceInstance.getVnfs().add(genericVnf);
 
  74         vfModule = buildVfModule();
 
  75         genericVnf.getVfModules().add(vfModule);
 
  76         volumeGroup = buildVolumeGroup();
 
  77         serviceInstance.getVnfs().get(0).getVolumeGroups().add(volumeGroup);
 
  78         cloudRegion = buildCloudRegion();
 
  79         orchestrationContext = buildOrchestrationContext();
 
  80         orchestrationContext.setIsRollbackEnabled(true);
 
  84     public void test_createVolumeGroup() throws Exception {
 
  85         volumeGroup.setOrchestrationStatus(OrchestrationStatus.ASSIGNED);
 
  87         CreateVolumeGroupRequest createVolumeGroupRequest = new CreateVolumeGroupRequest();
 
  88         createVolumeGroupRequest.setCloudSiteId("cloudSiteId");
 
  90         CreateVolumeGroupResponse expectedCreateVolumeGroupResponse = new CreateVolumeGroupResponse();
 
  91         expectedCreateVolumeGroupResponse.setVolumeGroupStackId("volumeGroupStackId");
 
  92         expectedCreateVolumeGroupResponse.setVolumeGroupCreated(true);
 
  94         String sdncVfModuleQueryResponse = "sdncVfModuleQueryResponse";
 
  96         doReturn(createVolumeGroupRequest).when(MOCK_vnfAdapterObjectMapper).createVolumeGroupRequestMapper(
 
  97                 requestContext, cloudRegion, orchestrationContext, serviceInstance, genericVnf, volumeGroup,
 
  98                 sdncVfModuleQueryResponse);
 
 100         CreateVolumeGroupRequest actualCreateVolumeGroupResponse =
 
 101                 vnfAdapterVolumeGroupResources.createVolumeGroupRequest(requestContext, cloudRegion,
 
 102                         orchestrationContext, serviceInstance, genericVnf, volumeGroup, sdncVfModuleQueryResponse);
 
 104         verify(MOCK_vnfAdapterObjectMapper, times(1)).createVolumeGroupRequestMapper(requestContext, cloudRegion,
 
 105                 orchestrationContext, serviceInstance, genericVnf, volumeGroup, sdncVfModuleQueryResponse);
 
 107         assertThat(createVolumeGroupRequest, Matchers.sameBeanAs(actualCreateVolumeGroupResponse));
 
 111     public void test_deleteVolumeGroup() throws Exception {
 
 112         DeleteVolumeGroupRequest deleteVolumeGroupRequest = new DeleteVolumeGroupRequest();
 
 113         doReturn(deleteVolumeGroupRequest).when(MOCK_vnfAdapterObjectMapper)
 
 114                 .deleteVolumeGroupRequestMapper(requestContext, cloudRegion, serviceInstance, volumeGroup);
 
 116         DeleteVolumeGroupRequest expectedDeleteVolumeGroupRequest = new DeleteVolumeGroupRequest();
 
 117         DeleteVolumeGroupRequest actualDeleteVolumeGroupRequest = vnfAdapterVolumeGroupResources
 
 118                 .deleteVolumeGroupRequest(requestContext, cloudRegion, serviceInstance, volumeGroup);
 
 120         verify(MOCK_vnfAdapterObjectMapper, times(1)).deleteVolumeGroupRequestMapper(requestContext, cloudRegion,
 
 121                 serviceInstance, volumeGroup);
 
 122         assertThat(expectedDeleteVolumeGroupRequest, Matchers.sameBeanAs(actualDeleteVolumeGroupRequest));