diff options
Diffstat (limited to 'catalog-be')
| -rw-r--r-- | catalog-be/src/test/java/org/openecomp/sdc/be/tosca/CapabilityRequirementConverterTest.java | 454 |
1 files changed, 294 insertions, 160 deletions
diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/tosca/CapabilityRequirementConverterTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/tosca/CapabilityRequirementConverterTest.java index 5254c08dab..49920c3c45 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/tosca/CapabilityRequirementConverterTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/tosca/CapabilityRequirementConverterTest.java @@ -13,190 +13,324 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.openecomp.sdc.be.tosca; - +import com.google.common.collect.ImmutableList; +import fj.data.Either; import org.junit.Before; import org.junit.Test; +import org.junit.runner.RunWith; import org.mockito.InjectMocks; import org.mockito.Mock; import org.mockito.Mockito; -import org.mockito.MockitoAnnotations; +import org.mockito.Spy; +import org.mockito.junit.MockitoJUnitRunner; + +import org.openecomp.sdc.be.datatypes.elements.RequirementDataDefinition; import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum; import org.openecomp.sdc.be.model.CapabilityDefinition; import org.openecomp.sdc.be.model.Component; import org.openecomp.sdc.be.model.ComponentInstance; import org.openecomp.sdc.be.model.ComponentInstanceProperty; +import org.openecomp.sdc.be.model.ComponentParametersView; +import org.openecomp.sdc.be.model.GroupDefinition; +import org.openecomp.sdc.be.model.RequirementDefinition; import org.openecomp.sdc.be.model.Resource; +import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade; +import org.openecomp.sdc.be.tosca.model.ToscaNodeTemplate; +import org.openecomp.sdc.be.tosca.model.ToscaTemplateCapability; import java.util.ArrayList; -import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; -import org.openecomp.sdc.be.model.jsonjanusgraph.operations.ToscaOperationFacade; -import static java.util.Arrays.asList; import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.Mockito.doReturn; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertTrue; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.when; +@RunWith(MockitoJUnitRunner.class) public class CapabilityRequirementConverterTest { - @InjectMocks - CapabilityRequirementConverter testSubject; - - @Mock - ToscaOperationFacade toscaOperationFacade; - @Mock - private PropertyConvertor propertyConvertorMock; - - CapabilityRequirementConverter capabiltyRequirementConvertor = Mockito.spy(new CapabilityRequirementConverter()); - ComponentInstance instanceProxy = Mockito.spy( new ComponentInstance() ); - ComponentInstance vfInstance = Mockito.spy( new ComponentInstance() ); - Component vfComponent = Mockito.spy( new Resource() ); - ComponentInstance vfcInstance = Mockito.spy( new ComponentInstance() ); - Component vfcComponent = Mockito.spy( new Resource() ); - - @Before - public void setUpMock() throws Exception { - MockitoAnnotations.initMocks(this); - } - - @Test - public void testGetInstance() { - CapabilityRequirementConverter.getInstance(); - } - - @Test - public void testGetReducedPathByOwner() throws Exception { - List<String> pathList = new ArrayList<>(); - String uniqueId = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_2"; - - String exerpt = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"; - String duplicate = "a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"; - pathList.add(exerpt); - pathList.add(duplicate); - pathList.add(duplicate); - pathList.add(uniqueId); - - pathList.add("5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"); - pathList.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); - - List<String> reducedMap = new CapabilityRequirementConverter().getReducedPathByOwner( pathList , uniqueId ); - - assertThat(reducedMap).isNotNull().doesNotContain(exerpt).containsOnlyOnce(duplicate).hasSize(4); - - List<String> path = new ArrayList<String>(); - - capabiltyRequirementConvertor.getReducedPathByOwner(path, uniqueId); - - path.add(""); - capabiltyRequirementConvertor.getReducedPathByOwner(path, uniqueId); - capabiltyRequirementConvertor.getReducedPathByOwner(path, ""); - } - - // generate stub capability - private Map<String, List<CapabilityDefinition>> newCapabilities(String capabilityName) { - Map<String, List<CapabilityDefinition>> capabilities = new HashMap<>(); - List<CapabilityDefinition> list = new ArrayList<>(); - CapabilityDefinition capabilityDefinition = new CapabilityDefinition(); - capabilityDefinition.setName(capabilityName); - capabilityDefinition.setType("att.Node"); - List<ComponentInstanceProperty> properties = new ArrayList<>(); - ComponentInstanceProperty prop = new ComponentInstanceProperty(); - prop.setValue("value"); - properties.add(prop); - capabilityDefinition.setProperties(properties); - List<String> pathList = new ArrayList<>(); - - capabilityDefinition.setOwnerId("41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693"); - pathList.add("41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"); - // pathList.add("a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"); - pathList.add("5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"); - pathList.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); - - capabilityDefinition.setPath(pathList); - list.add(capabilityDefinition); - capabilities.put(capabilityDefinition.getType(), list); - - return capabilities; - } - - @Test - public void testBuildName() { - doReturn("1").when(instanceProxy).getActualComponentUid(); - doReturn("2").when(vfInstance).getActualComponentUid(); - doReturn("3").when(vfcInstance).getActualComponentUid(); - // region proxy - Component proxyOrigin = new Resource(); - - proxyOrigin.setName("vepdgtp4837svc_proxy0"); - proxyOrigin.setComponentType(ComponentTypeEnum.RESOURCE); - proxyOrigin.setComponentInstances(asList(vfInstance)); - - // endregion - // region vf+vfc - vfInstance.setName("vepdgtp4837vf0"); - vfInstance.setNormalizedName("vepdgtp4837vf0"); - vfInstance.setUniqueId( - "5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"); - vfComponent.setName("vepdgtp4837vf0"); // origin - vfComponent.setComponentInstances(Arrays.asList(vfcInstance)); - vfcInstance.setUniqueId("41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"); - vfcInstance.setName("lb_1"); - vfcInstance.setNormalizedName("lb_1"); - vfcInstance.setName("41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"); - vfcComponent.setName("lb_1"); - // endregion - Map<String, List<CapabilityDefinition>> capabilities = newCapabilities("port"); - vfcComponent.setCapabilities(capabilities); - Map<Component, ComponentInstance> map = Collections - .unmodifiableMap(new HashMap<Component, ComponentInstance>() { - { - put(proxyOrigin, null); - put(vfComponent, vfInstance); - put(vfcComponent, vfcInstance); - } - }); - Map<String, Component> cache = Collections.unmodifiableMap(new HashMap<String, Component>() { - { - put("1", proxyOrigin); - put("2", vfComponent); - put("3", vfcComponent); - } - }); - instanceProxy.setCapabilities(capabilities); - proxyOrigin.setCapabilities(capabilities); - List<CapabilityDefinition> flatList = capabilities.values().stream().flatMap(List::stream) - .collect(Collectors.toList()); - flatList.stream().forEach((CapabilityDefinition capabilityDefinition) -> { - String name = capabiltyRequirementConvertor.buildCapabilityNameForComponentInstance(cache, instanceProxy, - capabilityDefinition); - System.out.println("built name -> " + name); - assertThat(name).isEqualTo("vepdgtp4837vf0.lb_1." + capabilityDefinition.getName()); - }); - } - @Test - public void getReducedPathByOwner() throws Exception { - List<String> pathList = new ArrayList<>(); - String uniqueId = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_2"; - - String exerpt = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"; - String duplicate = "a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"; - pathList.add(exerpt); - pathList.add(duplicate); - pathList.add(duplicate); - pathList.add(uniqueId); - - pathList.add("5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"); - pathList.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); - - List<String> reducedMap = new CapabilityRequirementConverter().getReducedPathByOwner( pathList , uniqueId ); - - assertThat( reducedMap ).isNotNull().doesNotContain(exerpt).containsOnlyOnce(duplicate).hasSize(4); - } + @Mock + private ToscaOperationFacade toscaOperationFacade; + @Mock + private PropertyConvertor propertyConvertor; + + @InjectMocks + private CapabilityRequirementConverter capabilityRequirementConverter; + + @Spy + private ComponentInstance instanceProxy = new ComponentInstance(); + @Spy + private ComponentInstance vfInstance = new ComponentInstance(); + @Spy + private Component vfComponent = new Resource(); + @Spy + private ComponentInstance vfcInstance = new ComponentInstance(); + @Spy + private Component vfcComponent = new Resource(); + + private static final String VF_INSTANCE_NAME = "vepdgtp4837vf0"; + private static final String VF_INSTANCE_NORMALIZED_NAME = "vepdgtp4837vf0"; + private static final String VF_INSTANCE_UNIQUE_ID = "5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"; + private static final String VF_COMPONENT_NAME = "vepdgtp4837vf0"; + + private static final String VFC_INSTANCE_UNIQUE_ID = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"; + private static final String VFC_INSTANCE_NAME = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_1"; + private static final String VFC_INSTANCE_NORMALIZED_NAME = "lb_1"; + private static final String VFC_COMPONENT_NAME = "clb_1"; + + private static final String ORIGIN_NAME = "vepdgtp4837svc_proxy0"; + + private static final String OWNER_ID = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693"; + private static final String DATA_DEFINITION_NAME = "name"; + + private static final String GROUP_NAME = "groupName"; + + private static final String PROPERTY_VALUE = "propValue"; + private static final String PROPERTY_NAME = "propName"; + + @Before + public void clean() { + instanceProxy = Mockito.spy(new ComponentInstance()); + vfInstance = Mockito.spy(new ComponentInstance()); + vfcInstance = Mockito.spy(new ComponentInstance()); + vfComponent = Mockito.spy(new Resource()); + vfcComponent = Mockito.spy(new Resource()); + } + + @Test + public void testGetInstance() { + assertNotNull(CapabilityRequirementConverter.getInstance()); + } + + @Test + public void testGetReducedPathByOwner() { + List<String> pathList = new ArrayList<>(); + String uniqueId = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_2"; + + String duplicate = "a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"; + pathList.add(VFC_INSTANCE_UNIQUE_ID); + pathList.add(duplicate); + pathList.add(duplicate); + pathList.add(uniqueId); + + pathList.add(VF_INSTANCE_UNIQUE_ID); + pathList.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); + + List<String> reducedMap = new CapabilityRequirementConverter().getReducedPathByOwner(pathList, uniqueId); + + assertThat(reducedMap).isNotNull().doesNotContain(VFC_INSTANCE_UNIQUE_ID) + .containsOnlyOnce(duplicate).hasSize(4); + + List<String> path = new ArrayList<>(); + capabilityRequirementConverter.getReducedPathByOwner(path, uniqueId); + + path.add(""); + capabilityRequirementConverter.getReducedPathByOwner(path, uniqueId); + capabilityRequirementConverter.getReducedPathByOwner(path, ""); + } + + @Test + public void testBuildName() { + // endregion + Map<String, List<CapabilityDefinition>> capabilities = newCapabilities("port"); + Component origin = getOrigin(vfInstance); + Map<String, Component> cache = populateInstanceAndGetCache(origin, capabilities); + + List<CapabilityDefinition> flatList = capabilities.values().stream().flatMap(List::stream) + .collect(Collectors.toList()); + flatList.forEach((CapabilityDefinition capabilityDefinition) -> { + String name = capabilityRequirementConverter.buildCapabilityNameForComponentInstance(cache, instanceProxy, + capabilityDefinition); + assertThat(name).isEqualTo(VF_INSTANCE_NAME + "." + + VFC_INSTANCE_NORMALIZED_NAME + "." + capabilityDefinition.getName()); + }); + } + + @Test + public void getReducedPathByOwner() { + List<String> pathList = new ArrayList<>(); + String uniqueId = "41d3a665-1313-4b5e-9bf0-e901ecf4b806.a77df84e-83eb-4edc-9823-d1f9f6549693.lb_2"; + + String duplicate = "a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"; + pathList.add(VFC_INSTANCE_UNIQUE_ID); + pathList.add(duplicate); + pathList.add(duplicate); + pathList.add(uniqueId); + + pathList.add(VF_INSTANCE_UNIQUE_ID); + pathList.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); + + List<String> reducedMap = new CapabilityRequirementConverter().getReducedPathByOwner(pathList, uniqueId); + + assertThat(reducedMap).isNotNull().doesNotContain(VFC_INSTANCE_UNIQUE_ID) + .containsOnlyOnce(duplicate).hasSize(4); + } + + @Test + public void testConvertSubstitutionMappingCapabilities() { + String capabilityName = "port"; + // endregion + Map<String, List<CapabilityDefinition>> capabilities = newCapabilities(capabilityName); + Component origin = getOrigin(vfcInstance); + Map<String, Component> cache = populateInstanceAndGetCache(origin, capabilities); + Either<Map<String, String[]>, ToscaError> res = capabilityRequirementConverter + .convertSubstitutionMappingCapabilities(cache, origin); + + assertFalse(res.isRight()); + assertTrue(res.isLeft()); + Map<String, String[]> map = res.left().value(); + String[] substitution = map.get(VFC_INSTANCE_NORMALIZED_NAME + "." + capabilityName); + assertEquals(VFC_INSTANCE_UNIQUE_ID, substitution[0]); + assertEquals(capabilityName, substitution[1]); + } + + @Test + public void buildRequirementNameForComponentInstanceTest() { + String capabilityName = "port"; + // endregion + Map<String, List<CapabilityDefinition>> capabilities = newCapabilities(capabilityName); + Component origin = getOrigin(vfcInstance); + Map<String, Component> cache = populateInstanceAndGetCache(origin, capabilities); + + RequirementDefinition def = getRequirementDefinition(); + + String resp = capabilityRequirementConverter.buildRequirementNameForComponentInstance(cache, vfcInstance, def); + assertEquals(DATA_DEFINITION_NAME, resp); + } + + @Test + public void convertComponentInstanceCapabilitiesTest() { + vfcInstance.setUniqueId(VFC_INSTANCE_UNIQUE_ID); + vfcInstance.setName(VFC_INSTANCE_NAME); + vfcInstance.setNormalizedName(VFC_INSTANCE_NORMALIZED_NAME); + + Component origin = getOrigin(vfcInstance); + GroupDefinition group = new GroupDefinition(); + group.setUniqueId("5f172af9-1588-443e-8897-1432b19aad8c.2cb7514a-1e50-4280-8457-baacb97b50bf.vepdgtp4837vf0"); + group.setName(GROUP_NAME); + origin.setGroups(ImmutableList.of(group)); + + when(toscaOperationFacade.getToscaElement(any(), any(ComponentParametersView.class))) + .thenReturn(Either.left(origin)); + + when(propertyConvertor.convertToToscaObject(any(ComponentInstanceProperty.class), + eq(PROPERTY_VALUE), any(), eq(false))).thenReturn(PROPERTY_VALUE); + + String capabilityName = "port"; + // endregion + Map<String, List<CapabilityDefinition>> capabilities = newCapabilities(capabilityName); + vfcInstance.setCapabilities(capabilities); + + ToscaNodeTemplate nodeTemplate = new ToscaNodeTemplate(); + + Either<ToscaNodeTemplate, ToscaError> resp = capabilityRequirementConverter.convertComponentInstanceCapabilities(vfcInstance, + new HashMap<>(), nodeTemplate); + + assertTrue(resp.isLeft()); + assertFalse(resp.isRight()); + + Map<String, ToscaTemplateCapability> convertCapabilities = resp.left().value().getCapabilities(); + assertNotNull(convertCapabilities.get(GROUP_NAME + "." + capabilityName)); + + ToscaTemplateCapability templateCapability = convertCapabilities.get("groupName.port"); + assertEquals(PROPERTY_VALUE, templateCapability.getProperties().get(PROPERTY_NAME)); + } + + private Component getOrigin(ComponentInstance instance) { + // region proxy + Component proxyOrigin = new Resource(); + + proxyOrigin.setName(ORIGIN_NAME); + proxyOrigin.setComponentType(ComponentTypeEnum.RESOURCE); + proxyOrigin.setComponentInstances(Collections.singletonList(instance)); + return proxyOrigin; + } + + private Map<String, Component> populateInstanceAndGetCache(Component proxyOrigin, + Map<String, List<CapabilityDefinition>> capabilities) { + when(instanceProxy.getActualComponentUid()).thenReturn("1"); + when(vfInstance.getActualComponentUid()).thenReturn("2"); + when(vfcInstance.getActualComponentUid()).thenReturn("3"); + + // endregion + // region vf+vfc + vfInstance.setName(VF_INSTANCE_NAME); + vfInstance.setNormalizedName(VF_INSTANCE_NORMALIZED_NAME); + vfInstance.setUniqueId(VF_INSTANCE_UNIQUE_ID); + + vfComponent.setName(VF_COMPONENT_NAME); // origin + vfComponent.setComponentInstances(Collections.singletonList(vfcInstance)); + + vfcInstance.setUniqueId(VFC_INSTANCE_UNIQUE_ID); + vfcInstance.setName(VFC_INSTANCE_NAME); + vfcInstance.setNormalizedName(VFC_INSTANCE_NORMALIZED_NAME); + + vfcComponent.setName(VFC_COMPONENT_NAME); + + vfcComponent.setCapabilities(capabilities); + instanceProxy.setCapabilities(capabilities); + proxyOrigin.setCapabilities(capabilities); + + return Collections.unmodifiableMap(new HashMap<String, Component>() { + { + put("1", proxyOrigin); + put("2", vfComponent); + put("3", vfcComponent); + } + }); + } + + private RequirementDefinition getRequirementDefinition() { + RequirementDataDefinition dataDefinition = new RequirementDataDefinition(); + dataDefinition.setName(DATA_DEFINITION_NAME); + dataDefinition.setPreviousName("previousName"); + dataDefinition.setOwnerId(OWNER_ID); + dataDefinition.setPath(getPath()); + + return new RequirementDefinition(dataDefinition); + } + + // generate stub capability + private Map<String, List<CapabilityDefinition>> newCapabilities(String capabilityName) { + Map<String, List<CapabilityDefinition>> capabilities = new HashMap<>(); + List<CapabilityDefinition> list = new ArrayList<>(); + CapabilityDefinition capabilityDefinition = new CapabilityDefinition(); + capabilityDefinition.setName(capabilityName); + capabilityDefinition.setType("att.Node"); + List<ComponentInstanceProperty> properties = new ArrayList<>(); + ComponentInstanceProperty prop = new ComponentInstanceProperty(); + prop.setName(PROPERTY_NAME); + prop.setValue(PROPERTY_VALUE); + properties.add(prop); + capabilityDefinition.setProperties(properties); + capabilityDefinition.setOwnerId(OWNER_ID); + + List<String> pathList = getPath(); + capabilityDefinition.setPath(pathList); + list.add(capabilityDefinition); + capabilities.put(capabilityDefinition.getType(), list); + + return capabilities; + } + + private List<String> getPath() { + List<String> path = new ArrayList<>(); + path.add(VFC_INSTANCE_UNIQUE_ID); + // pathList.add("a77df84e-83eb-4edc-9823-d1f9f6549693.c79e9a4a-b172-4323-a2e2-1c48d6603241.lb_swu_direct_4_rvmi"); + path.add(VF_INSTANCE_UNIQUE_ID); + path.add("86ae128e-3d0a-41f7-a957-db1df9fe598c.9cc8f8ac-6869-4dd6-a6e1-74ecb9570dc4.vepdgtp4837svc_proxy0"); + + return path; + } } |