vid-app-common/src/test/java/org/onap/vid/mso/MsoBusinessLogicImplTest.java

   1 package org.onap.vid.mso;
   2
   3 import com.fasterxml.jackson.core.type.TypeReference;
   4 import com.fasterxml.jackson.databind.ObjectMapper;
   5 import org.mockito.ArgumentCaptor;
   6 import org.mockito.InjectMocks;
   7 import org.mockito.Mock;
   8 import org.mockito.Mockito;
   9 import org.mockito.MockitoAnnotations;
  10 import org.onap.portalsdk.core.util.SystemProperties;
  11 import org.onap.vid.changeManagement.RequestDetailsWrapper;
  12 import org.onap.vid.controllers.MsoController;
  13 import org.onap.vid.mso.rest.RequestDetails;
  14 import org.onap.vid.properties.Features;
  15 import org.springframework.test.context.ContextConfiguration;
  16 import org.springframework.test.context.testng.AbstractTestNGSpringContextTests;
  17 import org.springframework.test.context.web.WebAppConfiguration;
  18 import org.testng.Assert;
  19 import org.testng.annotations.BeforeTest;
  20 import org.testng.annotations.DataProvider;
  21 import org.testng.annotations.Test;
  22 import org.togglz.core.manager.FeatureManager;
  23
  24 import java.io.IOException;
  25 import java.nio.file.Path;
  26 import java.nio.file.Paths;
  27
  28 import static org.assertj.core.api.Assertions.assertThat;
  29 import static org.mockito.Matchers.eq;
  30 import static org.mockito.Mockito.verify;
  31 import static org.mockito.Mockito.when;
  32 import static org.onap.vid.controllers.MsoController.SVC_INSTANCE_ID;
  33 import static org.onap.vid.mso.MsoBusinessLogicImpl.validateEndpointPath;
  34
  35 @ContextConfiguration(classes = {SystemProperties.class})
  36 @WebAppConfiguration
  37 public class MsoBusinessLogicImplTest extends AbstractTestNGSpringContextTests {
  38
  39     private static final String SERVICE_INSTANCE_ID = "1";
  40     private static final String VNF_INSTANCE_ID = "1";
  41     private static final String EXPECTED_SCALE_OUT_PATH = "/serviceInstantiation/v7/serviceInstances/1/vnfs/1/vfModules/scaleOut";
  42     private static final Path PATH_TO_NOT_PROCESSED_SCALE_OUT_REQUEST = Paths.get("src", "test", "resources", "payload_jsons", "scaleOutVfModulePayload.json");
  43     private static final Path PATH_TO_FINAL_SCALE_OUT_REQUEST = Paths.get("src", "test", "resources", "payload_jsons", "scaleOutVfModulePayloadToMso.json");
  44     private static final ObjectMapper OBJECT_MAPPER=new ObjectMapper();
  45
  46     @InjectMocks
  47     private MsoBusinessLogicImpl msoBusinessLogic;
  48
  49     @Mock
  50     private FeatureManager featureManagerMock;
  51
  52     @Mock
  53     private MsoInterface msoInterfaceMock;
  54
  55
  56     @BeforeTest
  57     public void initMocks() {
  58         MockitoAnnotations.initMocks(this);
  59     }
  60
  61     @Test
  62     public void validateEndpointPath_endPointIsNotEmptyAndVaild_returnProperty() {
  63         System.setProperty("TestEnv", "123");
  64         String foundEndPoint = validateEndpointPath("TestEnv");
  65         Assert.assertEquals("123", foundEndPoint);
  66     }
  67
  68     @Test(expectedExceptions = RuntimeException.class)
  69     public void validateEndpointPath_endPointIsNull_throwRuntimeException() {
  70         validateEndpointPath("NotExists");
  71     }
  72
  73     @Test(expectedExceptions = RuntimeException.class)
  74     public void validateEndpointPath_endPointIsNotEmptyButDoesntExists_throwRuntimeException() {
  75         System.setProperty("EmptyEndPoint", "");
  76         validateEndpointPath("EmptyEndPoint");
  77     }
  78
  79
  80     //@Test(dataProvider = "unAssignOrDeleteParams")
  81     public void deleteSvcInstance_verifyEndPointPathConstructing_unAssignFeatureOffOrUnAssignFlagIsFalse(boolean isAssignFlag, String status) {
  82         Mockito.reset(msoInterfaceMock);
  83         String endpoint = validateEndpointPath(isAssignFlag ? MsoProperties.MSO_DELETE_OR_UNASSIGN_REST_API_SVC_INSTANCE : MsoProperties.MSO_REST_API_SVC_INSTANCE);
  84         RequestDetails requestDetails = new RequestDetails();
  85
  86         when(featureManagerMock.isActive(Features.FLAG_UNASSIGN_SERVICE)).thenReturn(isAssignFlag);
  87
  88         msoBusinessLogic.deleteSvcInstance(requestDetails, "tempId", status);
  89
  90         verify(msoInterfaceMock).deleteSvcInstance(requestDetails, endpoint + "/tempId");
  91     }
  92
  93     @DataProvider
  94     public Object[][] unAssignOrDeleteParams() {
  95         return new Object[][]{
  96                 {Boolean.FALSE, "active"},
  97                 {Boolean.FALSE, "created"},
  98                 {Boolean.TRUE, "Active"},
  99                 {Boolean.TRUE, "unexpected-status"},
 100         };
 101     }
 102
 103     //@Test(dataProvider = "unAssignStatus")
 104     public void deleteSvcInstance_verifyEndPointPathConstructing_unAssignFeatureOnAndUnAssignFlagIsTrue(String status) {
 105         Mockito.reset(msoInterfaceMock);
 106         // in the test Features.FLAG_UNASSIGN_SERVICE is active so the endpoint should be MsoProperties.MSO_DELETE_OR_UNASSIGN_REST_API_SVC_INSTANCE
 107         String endpoint = validateEndpointPath(MsoProperties.MSO_DELETE_OR_UNASSIGN_REST_API_SVC_INSTANCE);
 108         RequestDetails requestDetails = new RequestDetails();
 109
 110         when(featureManagerMock.isActive(Features.FLAG_UNASSIGN_SERVICE)).thenReturn(true);
 111
 112         msoBusinessLogic.deleteSvcInstance(requestDetails, "tempId", status);
 113
 114         verify(msoInterfaceMock).unassignSvcInstance(requestDetails, endpoint + "/tempId/unassign");
 115     }
 116
 117     @DataProvider
 118     public Object[][] unAssignStatus() {
 119         return new Object[][]{
 120                 {"Created"},
 121                 {"Pendingdelete"},
 122                 {"pending-Delete"},
 123                 {"Assigned"}
 124         };
 125     }
 126
 127     @Test
 128     public void deleteVnf_verifyEndPointPathConstructing() {
 129         String endpoint = validateEndpointPath(MsoProperties.MSO_REST_API_VNF_INSTANCE);
 130         RequestDetails requestDetails = new RequestDetails();
 131
 132         String vnf_endpoint = endpoint.replaceFirst(SVC_INSTANCE_ID, "serviceInstanceTempId");
 133
 134         msoBusinessLogic.deleteVnf(requestDetails, "serviceInstanceTempId", "vnfInstanceTempId");
 135         verify(msoInterfaceMock).deleteVnf(requestDetails, vnf_endpoint + "/vnfInstanceTempId");
 136     }
 137
 138     @Test
 139     public void deleteVfModule_verifyEndPointPathConstructing() {
 140         String endpoint = validateEndpointPath(MsoProperties.MSO_REST_API_VF_MODULE_INSTANCE);
 141         RequestDetails requestDetails = new RequestDetails();
 142
 143         String vf__modules_endpoint = endpoint.replaceFirst(SVC_INSTANCE_ID, "serviceInstanceTempId").replaceFirst(MsoController.VNF_INSTANCE_ID, "vnfInstanceTempId");
 144
 145         msoBusinessLogic.deleteVfModule(requestDetails, "serviceInstanceTempId", "vnfInstanceTempId", "vfModuleTempId");
 146         verify(msoInterfaceMock).deleteVfModule(requestDetails, vf__modules_endpoint + "/vfModuleTempId");
 147     }
 148
 149
 150     @Test
 151     public void shouldSendProperScaleOutRequest() throws IOException {
 152         ArgumentCaptor<RequestDetailsWrapper> requestDetailsWrapperArgumentCaptor = ArgumentCaptor.forClass(RequestDetailsWrapper.class);
 153         org.onap.vid.changeManagement.RequestDetails requestDetails = getScaleOutRequest();
 154         RequestDetailsWrapper expectedRequestWrapper = getExpectedRequestWrapper();
 155
 156         msoBusinessLogic.scaleOutVfModuleInstance(requestDetails, SERVICE_INSTANCE_ID, VNF_INSTANCE_ID);
 157
 158         verify(msoInterfaceMock).scaleOutVFModuleInstance(requestDetailsWrapperArgumentCaptor.capture(), eq(EXPECTED_SCALE_OUT_PATH));
 159         RequestDetailsWrapper actual = requestDetailsWrapperArgumentCaptor.getAllValues().get(0);
 160
 161         assertThat(expectedRequestWrapper.requestDetails).isEqualTo(actual.requestDetails);
 162     }
 163
 164     private org.onap.vid.changeManagement.RequestDetails getScaleOutRequest() throws IOException {
 165         return OBJECT_MAPPER.readValue(PATH_TO_NOT_PROCESSED_SCALE_OUT_REQUEST.toFile(), org.onap.vid.changeManagement.RequestDetails.class);
 166     }
 167
 168     private RequestDetailsWrapper getExpectedRequestWrapper() throws IOException {
 169         return OBJECT_MAPPER.readValue(PATH_TO_FINAL_SCALE_OUT_REQUEST.toFile(), new TypeReference<RequestDetailsWrapper<org.onap.vid.changeManagement.RequestDetails>>() {
 170         });
 171     }
 172 }
 173