import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
-import org.openecomp.core.model.dao.ServiceModelDao;
-import org.openecomp.core.model.types.ServiceElement;
import org.openecomp.core.utilities.file.FileUtils;
import org.openecomp.core.utilities.orchestration.OnboardingTypesEnum;
-import org.openecomp.sdc.datatypes.error.ErrorLevel;
-import org.openecomp.sdc.healing.api.HealingManager;
-import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
-import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductDao;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDao;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDependencyModelDao;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.OrchestrationTemplateDao;
import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductInfoDao;
-import org.openecomp.sdc.vendorsoftwareproduct.dao.type.OrchestrationTemplateCandidateDataEntity;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentDependencyModelEntity;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentEntity;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.type.OrchestrationTemplateCandidateData;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
-import org.openecomp.sdc.vendorsoftwareproduct.services.composition.CompositionDataExtractor;
-import org.openecomp.sdc.vendorsoftwareproduct.services.composition.CompositionEntityDataManager;
+import org.openecomp.sdc.vendorsoftwareproduct.impl.orchestration.OrchestrationUtil;
import org.openecomp.sdc.vendorsoftwareproduct.services.filedatastructuremodule.CandidateService;
import org.openecomp.sdc.vendorsoftwareproduct.types.OrchestrationTemplateActionResponse;
-import org.openecomp.sdc.vendorsoftwareproduct.types.UploadFileResponse;
-import org.openecomp.sdc.vendorsoftwareproduct.types.UploadFileStatus;
+import org.openecomp.sdc.vendorsoftwareproduct.types.composition.ComponentData;
import org.openecomp.sdc.vendorsoftwareproduct.utils.ZipFileUtils;
import org.openecomp.sdc.versioning.dao.types.Version;
import org.testng.Assert;
+import org.testng.annotations.AfterMethod;
import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
-import java.io.IOException;
import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
import java.util.Optional;
import static org.mockito.Matchers.anyObject;
+import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.doReturn;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertNotNull;
-/**
- * @author Avrahamg
- * @since November 08, 2016
- */
public class OrchestrationTemplateCandidateManagerImplTest {
- private static final String USER1 = "vspTestUser1";
private static final String VSP_ID = "vspId";
- private static final Version VERSION01 = new Version(0, 1);
+ private static final Version VERSION01 = new Version("versionId");
+
+ private static final String COMPONENT_ORIG_ID_1 = "Component_Pd_Server_Id_Orig";
+ private static final String COMPONENT_ORIG_ID_2 = "Component_Sm_Server_Id_Orig";
+ private static final String COMPONENT_ORIG_ID_3 = "Component_Oam_Server_Id_Orig";
+ private static final String COMPONENT_ORIG_ID_4 = "Component_Ps_Server_Id_Orig";
+
+ private static final String COMPONENT_NEW_ID_1 = "Component_Pd_Server_Id_New";
+ private static final String COMPONENT_NEW_ID_2 = "Component_Sm_Server_Id_New";
+ private static final String COMPONENT_NEW_ID_3 = "Component_Oam_Server_Id_New";
+ private static final String COMPONENT_NEW_ID_4 = "Component_Ps_Server_Id_New";
+
+ private static final String COMPONENT_NAME_1 = "pd_server";
+ private static final String COMPONENT_NAME_2 = "sm_server";
+ private static final String COMPONENT_NAME_3 = "oam_server";
+ private static final String COMPONENT_NAME_4 = "ps_server";
- @Mock
- private VendorSoftwareProductDao vendorSoftwareProductDaoMock;
@Mock
private VendorSoftwareProductInfoDao vspInfoDaoMock;
@Mock
private CandidateService candidateServiceMock;
@Mock
- private HealingManager healingManagerMock;
- @Mock
- private CompositionDataExtractor compositionDataExtractorMock;
+ private OrchestrationTemplateDao orchestrationTemplateDaoMock;
@Mock
- private ServiceModelDao<ToscaServiceModel, ServiceElement> serviceModelDaoMock;
+ private ComponentDependencyModelDao componentDependencyModelDaoMock;
@Mock
- private CompositionEntityDataManager compositionEntityDataManagerMock;
+ private ComponentDao componentDaoMock;
+
@InjectMocks
private OrchestrationTemplateCandidateManagerImpl candidateManager;
+ @InjectMocks
+ private OrchestrationUtil orchestrationUtil;
+
@BeforeMethod
public void setUp() throws Exception {
MockitoAnnotations.initMocks(this);
}
- // TODO: 3/15/2017 fix and enable
- //@Test
- public void testProcessEmptyUpload() throws IOException {
-/* testLegalUpload(VSP_ID, activeVersion002,
- new ZipFileUtils().getZipInputStream("/vspmanager/zips/emptyComposition.zip"), USER1);*/
+ @AfterMethod
+ public void tearDown() {
+ candidateManager = null;
+ orchestrationUtil = null;
+ }
- OrchestrationTemplateCandidateDataEntity orchTemplate =
- new OrchestrationTemplateCandidateDataEntity(VSP_ID, VERSION01);
+ @Test
+ public void testProcessEmptyUpload() {
+ OrchestrationTemplateCandidateData orchTemplate =
+ new OrchestrationTemplateCandidateData();
orchTemplate
.setContentData(ByteBuffer.wrap(FileUtils.toByteArray(new ZipFileUtils().getZipInputStream
("/vspmanager/zips/emptyComposition.zip"))));
" ]\n" +
"}");
doReturn(orchTemplate)
- .when(candidateServiceMock).getOrchestrationTemplateCandidate(VSP_ID, VERSION01);
+ .when(candidateServiceMock).getOrchestrationTemplateCandidate(anyObject(), anyObject());
doReturn(new VspDetails(VSP_ID, VERSION01))
.when(vspInfoDaoMock).get(anyObject());
+ doReturn(null)
+ .when(orchestrationTemplateDaoMock).getInfo(anyObject(), anyObject());
doReturn("{}").when(candidateServiceMock).createManifest(anyObject(), anyObject());
doReturn(Optional.empty()).when(candidateServiceMock)
- .fetchZipFileByteArrayInputStream(anyObject(), anyObject(), anyObject(), OnboardingTypesEnum.ZIP, anyObject());
+ .fetchZipFileByteArrayInputStream(anyObject(), anyObject(), anyObject(),
+ eq(OnboardingTypesEnum.ZIP), anyObject());
OrchestrationTemplateActionResponse response =
- candidateManager.process(VSP_ID, VERSION01, USER1);
+ candidateManager.process(VSP_ID, VERSION01);
- Assert.assertNotNull(response);
+ assertNotNull(response);
}
- /*
- @Test(dependsOnMethods = {"testUploadFile"})
- public void testUploadNotExistingFile() throws IOException {
- URL url = this.getClass().getResource("notExist.zip");
- testLegalUpload(VSP_ID, activeVersion002, url == null ? null : url.openStream(), USER1);
+
+ @Test
+ public void testUpdateVspComponentDependenciesHeatReuploadMoreComponents() {
+ doReturn(getExistingComponentDependencies())
+ .when(componentDependencyModelDaoMock).list(anyObject());
+ doReturn(getComponentListWithMoreComponentsInHeat())
+ .when(componentDaoMock).list(anyObject());
+
+ orchestrationUtil
+ .updateVspComponentDependencies(VSP_ID, VERSION01, getVspInitComponentIdNameInfo());
+
+ verify(componentDependencyModelDaoMock, times(2)).update(anyObject());
+ verify(componentDependencyModelDaoMock, never()).delete(anyObject());
}
- private void testLegalUpload(String vspId, Version version, InputStream upload, String user) {
- candidateManager.upload(vspId, VERSION01, upload, USER1);
- candidateManager.process(vspId, VERSION01, user);
+ @Test
+ public void testUpdateVspComponentDependenciesHeatReuploadLessComponents() {
+ doReturn(getExistingComponentDependencies())
+ .when(componentDependencyModelDaoMock).list(anyObject());
+ doReturn(getComponentListWithLessComponentsInHeat()).when(componentDaoMock).list(anyObject());
- UploadDataEntity
- uploadData =
- vendorSoftwareProductDaoMock.getUploadData(new UploadDataEntity(vspId, version));
- Assert.assertNotNull(uploadData);
- }*/
+ orchestrationUtil.updateVspComponentDependencies(VSP_ID, VERSION01,
+ getVspInitComponentIdNameInfo());
- // TODO: 3/15/2017 fix and enable
- //@Test
- public void testUploadWith2VolsIn1HeatInManifest() {
- doReturn(Optional.empty()).when(candidateServiceMock).validateNonEmptyFileToUpload(anyObject());
- doReturn(Optional.empty()).when(candidateServiceMock).validateRawZipData(anyObject());
+ verify(componentDependencyModelDaoMock).update(anyObject());
+ verify(componentDependencyModelDaoMock).delete(anyObject());
+ }
+
+ @Test
+ public void testUpdateVspComponentDependenciesHeatReuploadSameComponents() {
+ doReturn(getExistingComponentDependencies())
+ .when(componentDependencyModelDaoMock).list(anyObject());
+ doReturn(getComponentListWithSameComponentsInHeat()).when(componentDaoMock).list(anyObject());
+
+ orchestrationUtil
+ .updateVspComponentDependencies(VSP_ID, VERSION01, getVspInitComponentIdNameInfo());
- UploadFileResponse uploadFileResponse = candidateManager
- .upload(VSP_ID, VERSION01, new ZipFileUtils().getZipInputStream("/legalUploadWithWarning"),
- USER1, "zip", "legalUploadWithWarning");
- Assert.assertTrue(uploadFileResponse.getStatus() == UploadFileStatus.Success);
- Assert.assertTrue(
- uploadFileResponse.getErrors().get("uploadFile").get(0).getLevel() == ErrorLevel.WARNING);
- Assert.assertTrue(uploadFileResponse.getErrors().get("uploadFile").get(0).getMessage()
- .equals("heat contains more then one vol. selecting only first vol"));
+ verify(componentDependencyModelDaoMock, times(2)).update(anyObject());
+ verify(componentDependencyModelDaoMock, never()).delete(anyObject());
}
- // TODO: 3/15/2017 fix and enable
- //@Test
- public void testUploadWithManifest() {
- UploadFileResponse uploadFileResponse = candidateManager
- .upload(VSP_ID, VERSION01, new ZipFileUtils().getZipInputStream("/legalUploadWithWarning"),
- USER1, "zip", "legalUploadWithWarning");
- Assert.assertTrue(uploadFileResponse.getStatus() == UploadFileStatus.Success);
- Assert.assertTrue(
- uploadFileResponse.getErrors().get("uploadFile").get(0).getLevel() == ErrorLevel.WARNING);
- Assert.assertTrue(uploadFileResponse.getErrors().get("uploadFile").get(0).getMessage()
- .equals("heat contains more then one vol. selecting only first vol"));
+ @Test
+ public void testUpdateVspComponentDependenciesHeatReuploadNoComponents() {
+ doReturn(getExistingComponentDependencies())
+ .when(componentDependencyModelDaoMock).list(anyObject());
+ doReturn(new ArrayList<>()).when(componentDaoMock).list(anyObject());
+
+ orchestrationUtil
+ .updateVspComponentDependencies(VSP_ID, VERSION01, getVspInitComponentIdNameInfo());
+
+ verify(componentDependencyModelDaoMock, never()).update(anyObject());
+ verify(componentDependencyModelDaoMock, never()).delete(anyObject());
}
+ @Test
+ public void testVspComponentIdNameInfoNoComponents() {
+ Map<String, String> vspComponentIdNameInfo =
+ orchestrationUtil.getVspComponentIdNameInfo(VSP_ID, VERSION01);
+
+ assertEquals(vspComponentIdNameInfo.size(), 0);
+ }
+
+ @Test
+ public void testVspComponentIdNameInfo() {
+ doReturn(getInitialVspComponents()).when(componentDaoMock).list(anyObject());
+
+ Map<String, String> vspComponentIdNameInfo =
+ orchestrationUtil.getVspComponentIdNameInfo(VSP_ID, VERSION01);
+
+ assertEquals(vspComponentIdNameInfo.size(), 3);
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_1));
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_2));
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_3));
+ }
+ @Test
+ public void testVspComponentIdNameInfoEmptyCompositionData() {
+ Collection<ComponentEntity> initialVspComponents = getInitialVspComponents();
+ ComponentEntity componentEntity = new ComponentEntity();
+ componentEntity.setId(COMPONENT_ORIG_ID_4);
+ initialVspComponents.add(componentEntity);
+
+ doReturn(initialVspComponents).when(componentDaoMock).list(anyObject());
+
+ Map<String, String> vspComponentIdNameInfo =
+ orchestrationUtil.getVspComponentIdNameInfo(VSP_ID, VERSION01);
+
+ assertEquals(vspComponentIdNameInfo.size(), 3);
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_1));
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_2));
+ assertNotNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_3));
+ Assert.assertNull(vspComponentIdNameInfo.get(COMPONENT_ORIG_ID_4));
+ }
+
+ private Map<String, String> getVspInitComponentIdNameInfo() {
+ Map<String, String> componentIdNameInfoBeforeProcess = new HashMap<>();
+ componentIdNameInfoBeforeProcess.put(COMPONENT_ORIG_ID_1, COMPONENT_NAME_1);
+ componentIdNameInfoBeforeProcess.put(COMPONENT_ORIG_ID_2, COMPONENT_NAME_2);
+ componentIdNameInfoBeforeProcess.put(COMPONENT_ORIG_ID_3, COMPONENT_NAME_3);
+ return componentIdNameInfoBeforeProcess;
+ }
+
+ private Collection<ComponentEntity> getInitialVspComponents() {
+ Collection<ComponentEntity> vspComponents = new ArrayList<>();
+ ComponentEntity component1 = createComponentEntity(COMPONENT_ORIG_ID_1, COMPONENT_NAME_1);
+ ComponentEntity component2 = createComponentEntity(COMPONENT_ORIG_ID_2, COMPONENT_NAME_2);
+ ComponentEntity component3 = createComponentEntity(COMPONENT_ORIG_ID_3, COMPONENT_NAME_3);
+ vspComponents.add(component1);
+ vspComponents.add(component2);
+ vspComponents.add(component3);
+ return vspComponents;
+ }
+
+ private Collection<ComponentEntity> getComponentListWithMoreComponentsInHeat() {
+ Collection<ComponentEntity> vspComponents = getInitialVspComponents();
+ createInitialComponentDependencies(vspComponents);
+ ComponentEntity newComponent = createComponentEntity(COMPONENT_NEW_ID_4, COMPONENT_NAME_4);
+ vspComponents.add(newComponent);
+ return vspComponents;
+ }
+
+ private Collection<ComponentEntity> getComponentListWithLessComponentsInHeat() {
+ Collection<ComponentEntity> vspComponents = getInitialVspComponents();
+ for (Iterator<ComponentEntity> iterator = vspComponents.iterator(); iterator.hasNext(); ) {
+ ComponentEntity componentEntity = iterator.next();
+ switch (componentEntity.getComponentCompositionData().getName()) {
+ case COMPONENT_NAME_1:
+ iterator.remove();
+ break;
+ case COMPONENT_NAME_2:
+ componentEntity.setId(COMPONENT_NEW_ID_2);
+ break;
+ case COMPONENT_NAME_3:
+ componentEntity.setId(COMPONENT_NEW_ID_3);
+ break;
+ }
+ }
+ return vspComponents;
+ }
+
+ private Collection<ComponentEntity> getComponentListWithSameComponentsInHeat() {
+ Collection<ComponentEntity> vspComponents = getInitialVspComponents();
+ createInitialComponentDependencies(vspComponents);
+ return vspComponents;
+ }
+
+ private Collection<ComponentDependencyModelEntity> getExistingComponentDependencies() {
+ Collection<ComponentDependencyModelEntity> newComponents = new ArrayList<>();
+ ComponentDependencyModelEntity entity =
+ createComponentDependencyEntity(COMPONENT_ORIG_ID_1, COMPONENT_ORIG_ID_2);
+ ComponentDependencyModelEntity entity2 =
+ createComponentDependencyEntity(COMPONENT_ORIG_ID_2, COMPONENT_ORIG_ID_3);
+ newComponents.add(entity);
+ newComponents.add(entity2);
+ return newComponents;
+ }
+
+ private ComponentEntity createComponentEntity(String componentId, String componentName) {
+ ComponentEntity componentEntity = new ComponentEntity();
+ componentEntity.setId(componentId);
+ ComponentData data = new ComponentData();
+ data.setName(componentName);
+ componentEntity.setComponentCompositionData(data);
+ return componentEntity;
+ }
+
+ private ComponentDependencyModelEntity createComponentDependencyEntity(String sourceComponentId,
+ String targetComponentId) {
+ ComponentDependencyModelEntity componentDependency = new ComponentDependencyModelEntity();
+ componentDependency.setSourceComponentId(sourceComponentId);
+ componentDependency.setTargetComponentId(targetComponentId);
+ return componentDependency;
+ }
+
+ private void createInitialComponentDependencies(Collection<ComponentEntity> vspComponents) {
+ for (ComponentEntity componentEntity : vspComponents) {
+ switch (componentEntity.getComponentCompositionData().getName()) {
+ case COMPONENT_NAME_1:
+ componentEntity.setId(COMPONENT_NEW_ID_1);
+ break;
+ case COMPONENT_NAME_2:
+ componentEntity.setId(COMPONENT_NEW_ID_2);
+ break;
+ case COMPONENT_NAME_3:
+ componentEntity.setId(COMPONENT_NEW_ID_3);
+ break;
+ }
+ }
+ }
}
\ No newline at end of file
Code Review / sdc.git / blobdiff