package org.openecomp.sdc.be.components.impl;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anySet;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.when;
+
import fj.data.Either;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
import mockit.Deencapsulation;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.assertj.core.util.Lists;
import org.openecomp.sdc.be.model.Component;
import org.openecomp.sdc.be.model.ComponentInstance;
import org.openecomp.sdc.be.model.ComponentInstanceInput;
+import org.openecomp.sdc.be.model.ComponentInstancePropInput;
import org.openecomp.sdc.be.model.ComponentInstanceProperty;
import org.openecomp.sdc.be.model.ComponentParametersView;
import org.openecomp.sdc.be.model.DataTypeDefinition;
import org.openecomp.sdc.common.impl.FSConfigurationSource;
import org.openecomp.sdc.exception.ResponseFormat;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertSame;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.ArgumentMatchers.anySet;
-import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.Mockito.when;
-
/**
* The test suite designed for test functionality of ComponentInstanceBusinessLogic class
*/
private final static String ORIGIN_COMPONENT_ID = "originComponentId";
private final static String COMPONENT_INST_ID = "componentInstId";
private final static String TO_INSTANCE_ID = "toInstanceId";
+ private final static String TO_INSTANCE_NAME = "toInstanceName";
private final static String COMPONENT_INSTANCE_ID = "componentInstanceId";
private final static String FROM_INSTANCE_ID = "fromInstanceId";
private final static String RELATION_ID = "relationId";
private final static String PROP_NAME = "propName";
private final static String NON_EXIST_NAME = "nonExistName";
- static ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(),
- "src/test/resources/config/catalog-be");
+ static ConfigurationSource configurationSource = new FSConfigurationSource(
+ ExternalConfiguration.getChangeListener(),
+ "src/test/resources/config/catalog-be");
static ConfigurationManager configurationManager = new ConfigurationManager(configurationSource);
@InjectMocks
private static ComponentInstanceBusinessLogic componentInstanceBusinessLogic;
@Mock
+ private ComponentInstancePropInput componentInstancePropInput;
+ @Mock
ArtifactsBusinessLogic artifactsBusinessLogic;
@Mock
private ComponentsUtils componentsUtils;
private RequirementDataDefinition requirement;
private RequirementCapabilityRelDef relation;
-
@Before
public void init() {
MockitoAnnotations.initMocks(componentInstanceBusinessLogic);
assertFalse(componentInstanceBusinessLogic.isCloudSpecificArtifact(ARTIFACT_5));
}
- private void getforwardingPathOnVersionChange(){
+ private void getforwardingPathOnVersionChange() {
String containerComponentParam = "services";
String containerComponentID = "121-cont";
String componentInstanceID = "121-cont-1-comp";
//Mock for getting component
when(toscaOperationFacade.getToscaElement(eq(containerComponentID), any(ComponentParametersView.class)))
- .thenReturn(Either.left(component));
+ .thenReturn(Either.left(component));
when(toscaOperationFacade.validateComponentExists(any(String.class))).thenReturn(Either.left(Boolean.TRUE));
when(toscaOperationFacade.getToscaFullElement(eq(new_Comp_UID))).thenReturn(Either.left(component2));
Either<Set<String>, ResponseFormat> resultOp = componentInstanceBusinessLogic
- .forwardingPathOnVersionChange(containerComponentParam,
- containerComponentID, componentInstanceID,
- newComponentInstance);
+ .forwardingPathOnVersionChange(containerComponentParam,
+ containerComponentID, componentInstanceID,
+ newComponentInstance);
assertEquals(1, resultOp.left().value().size());
assertEquals("FP-ID-1", resultOp.left().value().iterator().next());
}
@Test
- public void testCreateOrUpdatePropertiesValues2(){
- String containerComponentID="containerId";
+ public void testCreateOrUpdatePropertiesValues2() {
+ String containerComponentID = "containerId";
String resourceInstanceId = "resourceId";
String componentInstanceID = "componentInstance";
List<ComponentInstanceProperty> properties = new ArrayList<>();
ComponentInstance ci = createComponentInstance("ci1");
ci.setUniqueId("resourceId");
component.setComponentInstances(Arrays.asList(ci, createComponentInstance("ci2"),
- createComponentInstance(componentInstanceID)));
+ createComponentInstance(componentInstanceID)));
HashMap<String, DataTypeDefinition> dataTypeDefinitionHashMap = new HashMap<>();
DataTypeDefinition dataTypeDefinition = new DataTypeDefinition();
dataTypeDefinition.setName("string");
dataTypeDefinitionHashMap.put("string", dataTypeDefinition);
//when(userValidations.validateUserExists(user.getUserId(), false)).thenReturn(user);
- when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll)).thenReturn(Either.left(component));
- when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll))
+ .thenReturn(Either.left(component));
+ when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
when(dataTypeCache.getAll()).thenReturn(Either.left(types));
when(propertyOperation.validateAndUpdatePropertyValue(property.getType(), "newVal", true, null, types))
- .thenReturn(Either.left("newVal"));
+ .thenReturn(Either.left("newVal"));
when(propertyOperation.validateAndUpdateRules("string", property.getRules(),
- null, types, true)).thenReturn(ImmutablePair.of("string", null));
+ null, types, true)).thenReturn(ImmutablePair.of("string", null));
when(toscaOperationFacade.updateComponentInstanceProperty(component, ci.getUniqueId(),
- origProperty)).thenReturn(StorageOperationStatus.OK);
+ origProperty)).thenReturn(StorageOperationStatus.OK);
origProperties.get(0).setValue("newVal");
- when(toscaOperationFacade.updateComponentInstanceMetadataOfTopologyTemplate(component)).thenReturn(Either.left(component));
- when (janusGraphDao.commit()).thenReturn(JanusGraphOperationStatus.OK);
- when(graphLockOperation.unlockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade.updateComponentInstanceMetadataOfTopologyTemplate(component))
+ .thenReturn(Either.left(component));
+ when(janusGraphDao.commit()).thenReturn(JanusGraphOperationStatus.OK);
+ when(graphLockOperation.unlockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
- Either<List<ComponentInstanceProperty>, ResponseFormat> responseFormatEither = componentInstanceBusinessLogic.createOrUpdatePropertiesValues(
+ Either<List<ComponentInstanceProperty>, ResponseFormat> responseFormatEither = componentInstanceBusinessLogic
+ .createOrUpdatePropertiesValues(
ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
assertThat(responseFormatEither.left().value()).isEqualTo(properties);
}
@Test
- public void testCreateOrUpdatePropertiesValuesPropertyNotExists(){
- String containerComponentID="containerId";
+ public void testCreateOrUpdatePropertiesValuesPropertyNotExists() {
+ String containerComponentID = "containerId";
String resourceInstanceId = "resourceId";
String componentInstanceID = "componentInstance";
List<ComponentInstanceProperty> properties = new ArrayList<>();
ComponentInstance ci = createComponentInstance("ci1");
ci.setUniqueId("resourceId");
component.setComponentInstances(Arrays.asList(ci, createComponentInstance("ci2"),
- createComponentInstance(componentInstanceID)));
+ createComponentInstance(componentInstanceID)));
HashMap<String, DataTypeDefinition> dataTypeDefinitionHashMap = new HashMap<>();
DataTypeDefinition dataTypeDefinition = new DataTypeDefinition();
dataTypeDefinition.setName("string");
dataTypeDefinitionHashMap.put("string", dataTypeDefinition);
//when(userValidations.validateUserExists(user.getUserId(), false)).thenReturn(user);
- when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll)).thenReturn(Either.left(component));
- when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll))
+ .thenReturn(Either.left(component));
+ when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
//when(dataTypeCache.getAll()).thenReturn(Either.left(types));
//when (janusGraphDao.commit()).thenReturn(JanusGraphOperationStatus.OK);
- when(graphLockOperation.unlockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(graphLockOperation.unlockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
try {
componentInstanceBusinessLogic.createOrUpdatePropertiesValues(
- ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
+ ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
} catch (ComponentException e) {
assertThat(e.getActionStatus()).isEqualTo(ActionStatus.PROPERTY_NOT_FOUND);
}
}
-
@Test
- public void testCreateOrUpdatePropertiesValuesValidationFailure(){
- String containerComponentID="containerId";
+ public void testCreateOrUpdatePropertiesValuesValidationFailure() {
+ String containerComponentID = "containerId";
String resourceInstanceId = "resourceId";
String componentInstanceID = "componentInstance";
List<ComponentInstanceProperty> properties = new ArrayList<>();
ComponentInstance ci = createComponentInstance("ci1");
ci.setUniqueId("resourceId");
component.setComponentInstances(Arrays.asList(ci, createComponentInstance("ci2"),
- createComponentInstance(componentInstanceID)));
+ createComponentInstance(componentInstanceID)));
HashMap<String, DataTypeDefinition> dataTypeDefinitionHashMap = new HashMap<>();
DataTypeDefinition dataTypeDefinition = new DataTypeDefinition();
dataTypeDefinition.setName("string");
dataTypeDefinitionHashMap.put("string", dataTypeDefinition);
//when(userValidations.validateUserExists(user.getUserId(), false)).thenReturn(user);
- when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll)).thenReturn(Either.left(component));
- when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll))
+ .thenReturn(Either.left(component));
+ when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
when(dataTypeCache.getAll()).thenReturn(Either.left(types));
when(propertyOperation.validateAndUpdatePropertyValue(property.getType(), "newVal", true, null, types))
- .thenReturn(Either.right(false));
- when(componentsUtils.convertFromStorageResponse(StorageOperationStatus.BAD_REQUEST)).thenReturn(ActionStatus.INVALID_CONTENT);
+ .thenReturn(Either.right(false));
+ when(componentsUtils.convertFromStorageResponse(StorageOperationStatus.BAD_REQUEST))
+ .thenReturn(ActionStatus.INVALID_CONTENT);
- try{
+ try {
componentInstanceBusinessLogic.createOrUpdatePropertiesValues(
- ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
- } catch(ComponentException e){
+ ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
+ } catch (ComponentException e) {
assertThat(e.getActionStatus()).isEqualTo(ActionStatus.INVALID_CONTENT);
return;
}
}
@Test
- public void testCreateOrUpdatePropertiesValuesMissingFieldFailure(){
- String containerComponentID="containerId";
+ public void testCreateOrUpdatePropertiesValuesMissingFieldFailure() {
+ String containerComponentID = "containerId";
String resourceInstanceId = "resourceId";
String componentInstanceID = "componentInstance";
List<ComponentInstanceProperty> properties = new ArrayList<>();
ComponentInstance ci = createComponentInstance("ci1");
ci.setUniqueId("resourceId");
component.setComponentInstances(Arrays.asList(ci, createComponentInstance("ci2"),
- createComponentInstance(componentInstanceID)));
+ createComponentInstance(componentInstanceID)));
HashMap<String, DataTypeDefinition> dataTypeDefinitionHashMap = new HashMap<>();
DataTypeDefinition dataTypeDefinition = new DataTypeDefinition();
dataTypeDefinitionHashMap.put("string", dataTypeDefinition);
//when(userValidations.validateUserExists(user.getUserId(), false)).thenReturn(user);
- when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll)).thenReturn(Either.left(component));
- when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade.getToscaElement(containerComponentID, JsonParseFlagEnum.ParseAll))
+ .thenReturn(Either.left(component));
+ when(graphLockOperation.lockComponent(containerComponentID, NodeTypeEnum.ResourceInstance))
+ .thenReturn(StorageOperationStatus.OK);
- try{
+ try {
componentInstanceBusinessLogic.createOrUpdatePropertiesValues(
- ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
- } catch(ComponentException e){
+ ComponentTypeEnum.RESOURCE_INSTANCE, containerComponentID, resourceInstanceId, properties, "userId");
+ } catch (ComponentException e) {
assertThat(e.getActionStatus()).isEqualTo(ActionStatus.MISSING_PROPERTY_NAME);
}
}
String containerComponentID = "Service-comp";
String componentInstanceID = "NodeA1";
Service component = new Service();
- component.setComponentInstances(Arrays.asList(createComponentInstance("NodeA2"), createComponentInstance("NodeB2"),
- createComponentInstance(componentInstanceID)));
+ component
+ .setComponentInstances(Arrays.asList(createComponentInstance("NodeA2"), createComponentInstance("NodeB2"),
+ createComponentInstance(componentInstanceID)));
component.addForwardingPath(createPath("path1", componentInstanceID, "NodeB1", "1"));
component.addForwardingPath(createPath("Path2", "NodeA2", "NodeB2", "2"));
when(toscaOperationFacade.getToscaElement(eq(containerComponentID), any(ComponentParametersView.class)))
- .thenReturn(Either.left(component));
+ .thenReturn(Either.left(component));
when(toscaOperationFacade.getToscaElement(eq(containerComponentID))).thenReturn(Either.left(component));
when(forwardingPathOperation.deleteForwardingPath(any(Service.class), anySet()))
- .thenReturn(Either.left(new HashSet<>()));
+ .thenReturn(Either.left(new HashSet<>()));
final ComponentInstance ci = new ComponentInstance();
ci.setName(componentInstanceID);
- ComponentInstance responseFormatEither = componentInstanceBusinessLogic.deleteForwardingPathsRelatedTobeDeletedComponentInstance(
- containerComponentID, containerComponentType, ci);
+ ComponentInstance responseFormatEither = componentInstanceBusinessLogic
+ .deleteForwardingPathsRelatedTobeDeletedComponentInstance(
+ containerComponentID, containerComponentType, ci);
assertThat(!responseFormatEither.isEmpty()).isEqualTo(true);
}
Map<String, ArtifactDefinition> artifacts = new HashMap<>();
ArtifactDefinition deploymentArtifact1 = getArtifact("deploymentArtifact1", ArtifactTypeEnum.HEAT.getType());
artifacts.put(deploymentArtifact1.getArtifactLabel(), deploymentArtifact1);
- ArtifactDefinition deploymentArtifact2 = getArtifact("deploymentArtifact2", ArtifactTypeEnum.HEAT_ENV.getType());
+ ArtifactDefinition deploymentArtifact2 = getArtifact("deploymentArtifact2",
+ ArtifactTypeEnum.HEAT_ENV.getType());
artifacts.put(deploymentArtifact2.getArtifactLabel(), deploymentArtifact2);
- ArtifactDefinition deploymentArtifact3 = getArtifact("deploymentArtifact3", ArtifactTypeEnum.HEAT_VOL.getType());
+ ArtifactDefinition deploymentArtifact3 = getArtifact("deploymentArtifact3",
+ ArtifactTypeEnum.HEAT_VOL.getType());
artifacts.put(deploymentArtifact3.getArtifactLabel(), deploymentArtifact3);
ArtifactDefinition heatEnvPlaceHolder = getArtifact("deploymentArtifact4", ArtifactTypeEnum.HEAT_ENV.getType());
- ArtifactDefinition heatEnvPlaceHolder2 = getArtifact("deploymentArtifact5", ArtifactTypeEnum.HEAT_ENV.getType());
+ ArtifactDefinition heatEnvPlaceHolder2 = getArtifact("deploymentArtifact5",
+ ArtifactTypeEnum.HEAT_ENV.getType());
- Either<Map<String, ArtifactDefinition>, StorageOperationStatus> getResourceDeploymentArtifacts = Either.left(artifacts);
+ Either<Map<String, ArtifactDefinition>, StorageOperationStatus> getResourceDeploymentArtifacts = Either
+ .left(artifacts);
Map<String, ArtifactDefinition> finalDeploymentArtifacts = new HashMap<>();
finalDeploymentArtifacts.put(deploymentArtifact1.getArtifactLabel(), deploymentArtifact1);
finalDeploymentArtifacts.put(heatEnvPlaceHolder.getArtifactLabel(), heatEnvPlaceHolder);
finalDeploymentArtifacts.put(heatEnvPlaceHolder2.getArtifactLabel(), heatEnvPlaceHolder2);
-
when(artifactsBusinessLogic.getArtifacts(componentInstance.getComponentUid(), NodeTypeEnum.Resource,
- ArtifactGroupTypeEnum.DEPLOYMENT, null)).thenReturn(getResourceDeploymentArtifacts);
+ ArtifactGroupTypeEnum.DEPLOYMENT, null)).thenReturn(getResourceDeploymentArtifacts);
when(artifactsBusinessLogic.createHeatEnvPlaceHolder(new ArrayList<>(),
- deploymentArtifact1, ArtifactsBusinessLogic.HEAT_ENV_NAME, componentInstance.getUniqueId(),
- NodeTypeEnum.ResourceInstance, componentInstance.getName(), user, containerComponent,
- null)).thenReturn(heatEnvPlaceHolder);
+ deploymentArtifact1, ArtifactsBusinessLogic.HEAT_ENV_NAME, componentInstance.getUniqueId(),
+ NodeTypeEnum.ResourceInstance, componentInstance.getName(), user, containerComponent,
+ null)).thenReturn(heatEnvPlaceHolder);
when(artifactsBusinessLogic.createHeatEnvPlaceHolder(new ArrayList<>(),
- deploymentArtifact3, ArtifactsBusinessLogic.HEAT_ENV_NAME, componentInstance.getUniqueId(),
- NodeTypeEnum.ResourceInstance, componentInstance.getName(), user, containerComponent,
- null)).thenReturn(heatEnvPlaceHolder2);
-
-
- when(toscaOperationFacade.addDeploymentArtifactsToInstance(containerComponent.getUniqueId(), componentInstance, finalDeploymentArtifacts)).thenReturn(StorageOperationStatus.OK);
- when(toscaOperationFacade.addGroupInstancesToComponentInstance(containerComponent, componentInstance, null, new HashMap<>())).thenReturn(StorageOperationStatus.OK);
- when(toscaOperationFacade.addInformationalArtifactsToInstance(containerComponent.getUniqueId(), componentInstance, null)).thenReturn(StorageOperationStatus.OK);
-
+ deploymentArtifact3, ArtifactsBusinessLogic.HEAT_ENV_NAME, componentInstance.getUniqueId(),
+ NodeTypeEnum.ResourceInstance, componentInstance.getName(), user, containerComponent,
+ null)).thenReturn(heatEnvPlaceHolder2);
+
+ when(toscaOperationFacade.addDeploymentArtifactsToInstance(containerComponent.getUniqueId(), componentInstance,
+ finalDeploymentArtifacts)).thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade
+ .addGroupInstancesToComponentInstance(containerComponent, componentInstance, null, new HashMap<>()))
+ .thenReturn(StorageOperationStatus.OK);
+ when(toscaOperationFacade
+ .addInformationalArtifactsToInstance(containerComponent.getUniqueId(), componentInstance, null))
+ .thenReturn(StorageOperationStatus.OK);
ActionStatus status = componentInstanceBusinessLogic.addComponentInstanceArtifacts(containerComponent,
- componentInstance, originComponent, user, null);
+ componentInstance, originComponent, user, null);
assertThat(status).isEqualTo(ActionStatus.OK);
private Component fillOriginComponent(Resource originComponent) {
originComponent.setUniqueId("resourceId");
originComponent.setUniqueId(ORIGIN_COMPONENT_ID);
- originComponent.setComponentInstances(Lists.newArrayList(toInstance,fromInstance));
+ originComponent.setComponentInstances(Lists.newArrayList(toInstance, fromInstance));
originComponent.setComponentType(ComponentTypeEnum.RESOURCE);
originComponent.setState(LifecycleStateEnum.CERTIFIED);
return originComponent;
forwardingPath.setDestinationPortNumber("port");
forwardingPath.setUniqueId(uniqueId);
ListDataDefinition<ForwardingPathElementDataDefinition> forwardingPathElementListDataDefinition =
- new ListDataDefinition<>();
+ new ListDataDefinition<>();
forwardingPathElementListDataDefinition
- .add(new ForwardingPathElementDataDefinition(fromNode, toNode, "nodeAcpType", "nodeBcpType",
- "nodeDcpName", "nodeBcpName"));
+ .add(new ForwardingPathElementDataDefinition(fromNode, toNode, "nodeAcpType", "nodeBcpType",
+ "nodeDcpName", "nodeBcpName"));
forwardingPath.setPathElements(forwardingPathElementListDataDefinition);
return forwardingPath;
}
-
private Map<String, ForwardingPathDataDefinition> generateForwardingPath(String componentInstanceID) {
ForwardingPathDataDefinition forwardingPath = new ForwardingPathDataDefinition("fpName");
String protocol = "protocol";
ListDataDefinition<ForwardingPathElementDataDefinition> forwardingPathElementListDataDefinition =
new ListDataDefinition<>();
forwardingPathElementListDataDefinition
- .add(new ForwardingPathElementDataDefinition(componentInstanceID, "nodeB", "nodeA_FORWARDER_CAPABILITY",
- "nodeBcpType", "nodeDcpName", "nodeBcpName"));
+ .add(new ForwardingPathElementDataDefinition(componentInstanceID, "nodeB", "nodeA_FORWARDER_CAPABILITY",
+ "nodeBcpType", "nodeDcpName", "nodeBcpName"));
forwardingPath.setPathElements(forwardingPathElementListDataDefinition);
Map<String, ForwardingPathDataDefinition> forwardingPaths = new HashMap<>();
forwardingPaths.put("1122", forwardingPath);
return forwardingPaths;
}
- @SuppressWarnings("unchecked")
- private void getServiceRelationByIdSuccess(Component component){
+ @SuppressWarnings("unchecked")
+ private void getServiceRelationByIdSuccess(Component component) {
Either<Component, StorageOperationStatus> getComponentRes = Either.left(component);
when(toscaOperationFacade.getToscaElement(eq(COMPONENT_ID), any(ComponentParametersView.class)))
- .thenReturn(getComponentRes);
+ .thenReturn(getComponentRes);
Either<RequirementCapabilityRelDef, ResponseFormat> response = componentInstanceBusinessLogic
- .getRelationById(COMPONENT_ID,
- RELATION_ID, USER_ID,
- component.getComponentType());
+ .getRelationById(COMPONENT_ID,
+ RELATION_ID, USER_ID,
+ component.getComponentType());
assertTrue(response.isLeft());
}
private void getServiceRelationByIdUserValidationFailure(Component component) {
- when(userValidations.validateUserExists(eq(USER_ID))).thenThrow(new ByActionStatusComponentException(ActionStatus.USER_NOT_FOUND));
+ when(userValidations.validateUserExists(eq(USER_ID)))
+ .thenThrow(new ByActionStatusComponentException(ActionStatus.USER_NOT_FOUND));
try {
componentInstanceBusinessLogic
- .getRelationById(COMPONENT_ID, RELATION_ID, USER_ID, component.getComponentType());
+ .getRelationById(COMPONENT_ID, RELATION_ID, USER_ID, component.getComponentType());
} catch (ByActionStatusComponentException e) {
assertSame(e.getActionStatus(), ActionStatus.USER_NOT_FOUND);
}
Either<User, ActionStatus> eitherCreator = Either.left(user);
Either<Component, StorageOperationStatus> getComponentRes = Either.right(StorageOperationStatus.NOT_FOUND);
when(toscaOperationFacade.getToscaElement(eq(COMPONENT_ID), any(ComponentParametersView.class)))
- .thenReturn(getComponentRes);
+ .thenReturn(getComponentRes);
Either<RequirementCapabilityRelDef, ResponseFormat> response = componentInstanceBusinessLogic
- .getRelationById(COMPONENT_ID,
- RELATION_ID, USER_ID,
- component.getComponentType());
+ .getRelationById(COMPONENT_ID,
+ RELATION_ID, USER_ID,
+ component.getComponentType());
assertTrue(response.isRight());
}
private void stubMethods() {
when(userValidations.validateUserExists(eq(USER_ID))).thenReturn(user);
- when(componentsUtils.convertFromStorageResponse(eq(StorageOperationStatus.GENERAL_ERROR),any(ComponentTypeEnum.class)))
- .thenReturn(ActionStatus.GENERAL_ERROR);
+ when(componentsUtils
+ .convertFromStorageResponse(eq(StorageOperationStatus.GENERAL_ERROR), any(ComponentTypeEnum.class)))
+ .thenReturn(ActionStatus.GENERAL_ERROR);
}
private void createComponents() {
resource.setState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
}
-
private void createService() {
service = new Service();
service.setUniqueId(COMPONENT_ID);
service.setState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
}
-
private void createInstances() {
toInstance = new ComponentInstance();
toInstance.setUniqueId(TO_INSTANCE_ID);
+ toInstance.setName(TO_INSTANCE_NAME);
fromInstance = new ComponentInstance();
fromInstance.setUniqueId(FROM_INSTANCE_ID);
capability.setName(CAPABILITY_NAME);
Map<String, List<CapabilityDefinition>> capabilities = new HashMap<>();
- capabilities.put(capability.getName(), Lists.newArrayList(new CapabilityDefinition(capability)));
+ final CapabilityDefinition capabilityDefinition = new CapabilityDefinition(capability);
+ final ArrayList<ComponentInstanceProperty> properties = new ArrayList<>();
+ properties.add(componentInstancePropInput);
+ capabilityDefinition.setProperties(properties);
+ capabilities.put(capability.getName(), Lists.newArrayList(capabilityDefinition));
requirement = new RequirementDataDefinition();
requirement.setOwnerId(REQUIREMENT_OWNER_ID);
requirement.setName(REQUIREMENT_NAME);
requirement.setRelationship(RELATIONSHIP_TYPE);
-
Map<String, List<RequirementDefinition>> requirements = new HashMap<>();
requirements.put(requirement.getCapability(), Lists.newArrayList(new RequirementDefinition(requirement)));
fromInstance.setRequirements(requirements);
}
-
private void createRelation() {
relation = new RequirementCapabilityRelDef();
return componentInstanceBusinessLogic;
}
-
@Test
public void testChangeServiceProxyVersion() {
ComponentInstanceBusinessLogic componentInstanceBusinessLogic;
// default test
componentInstanceBusinessLogic = createTestSubject();
result = componentInstanceBusinessLogic.changeServiceProxyVersion();
+ Assert.assertNotNull(result);
}
-
@Test
public void testCreateServiceProxy() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = testSubject.createServiceProxy();
+ Assert.assertNotNull(result);
}
-
-
-
-
@Test
public void testDeleteServiceProxy() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = testSubject.deleteServiceProxy();
+ Assert.assertNotNull(result);
}
-
@Test
public void testGetComponentInstanceInputsByInputId() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = testSubject.getComponentInstanceInputsByInputId(component, inputId);
+ Assert.assertNotNull(result);
}
-
@Test
public void testGetComponentInstancePropertiesByInputId() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = testSubject.getComponentInstancePropertiesByInputId(component, inputId);
+ Assert.assertNotNull(result);
}
-
@Test
public void testGetRelationById() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = testSubject.getRelationById(componentId, relationId, userId, componentTypeEnum);
+ Assert.assertNotNull(result);
}
- @Test
- public void testValidateParent() {
+ @Test
+ public void testValidateParent() {
ComponentInstanceBusinessLogic testSubject;
createResource();
String nodeTemplateId = "";
// default test
testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "validateParent", new Object[] {resource, nodeTemplateId});
+ result = Deencapsulation.invoke(testSubject, "validateParent", new Object[]{resource, nodeTemplateId});
+ Assert.assertNotNull(result);
}
-
@Test
public void testGetComponentType() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "getComponentType", new Object[] {ComponentTypeEnum.class});
+ result = Deencapsulation.invoke(testSubject, "getComponentType", new Object[]{ComponentTypeEnum.class});
+ Assert.assertNotNull(result);
}
-
@Test
public void testGetNewGroupName() {
ComponentInstanceBusinessLogic testSubject;
// test 1
testSubject = createTestSubject();
result = Deencapsulation.invoke(testSubject, "getNewGroupName",
- new Object[] {oldPrefix, newNormailzedPrefix, qualifiedGroupInstanceName});
+ new Object[]{oldPrefix, newNormailzedPrefix, qualifiedGroupInstanceName});
+ Assert.assertNotNull(result);
}
-
@Test
public void testUpdateComponentInstanceMetadata_3() {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = Deencapsulation
- .invoke(testSubject, "updateComponentInstanceMetadata", new Object[] {toInstance, toInstance});
+ .invoke(testSubject, "updateComponentInstanceMetadata", new Object[]{toInstance, toInstance});
+ Assert.assertNotNull(result);
}
@Test
// default test
testSubject = createTestSubject();
result = Deencapsulation.invoke(testSubject, "findRelation",
- new Object[] {relationId, requirementCapabilityRelations});
+ new Object[]{relationId, requirementCapabilityRelations});
}
-
@Test
public void testCreateOrUpdatePropertiesValues() throws Exception {
ComponentInstanceBusinessLogic testSubject;
String userId = user.getUserId();
Either<List<ComponentInstanceProperty>, ResponseFormat> result;
-
when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseAll))
- .thenReturn(Either.left(resource));
+ .thenReturn(Either.left(resource));
// test 1
testSubject = createTestSubject();
result = testSubject
- .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
- userId);
+ .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
+ userId);
+ Assert.assertNotNull(result);
componentTypeEnum = null;
result = testSubject
- .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
- userId);
+ .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
+ userId);
+ Assert.assertNotNull(result);
- // when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseAll)).thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
result = testSubject
- .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
- userId);
-
+ .createOrUpdatePropertiesValues(componentTypeEnum, componentId, resourceInstanceId, properties,
+ userId);
+ Assert.assertNotNull(result);
}
-
@Test
public void testUpdateCapabilityPropertyOnContainerComponent() throws Exception {
ComponentInstanceBusinessLogic testSubject;
// default test
testSubject = createTestSubject();
result = Deencapsulation.invoke(testSubject, "updateCapabilityPropertyOnContainerComponent",
- new Object[] {property, newValue, resource, toInstance, capabilityType, capabilityName});
+ new Object[]{property, newValue, resource, toInstance, capabilityType, capabilityName});
}
-
@Test
public void testCreateOrUpdateInstanceInputValues() throws Exception {
ComponentInstanceBusinessLogic testSubject;
Either<List<ComponentInstanceInput>, ResponseFormat> result;
when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseAll))
- .thenReturn(Either.left(resource));
+ .thenReturn(Either.left(resource));
// test 1
testSubject = createTestSubject();
result = testSubject
- .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
- userId);
+ .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
+ userId);
+ Assert.assertNotNull(result);
componentTypeEnum = null;
result = testSubject
- .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
- userId);
-
+ .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
+ userId);
+ Assert.assertNotNull(result);
- // when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseAll)).thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
result = testSubject
- .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
- userId);
-
+ .createOrUpdateInstanceInputValues(componentTypeEnum, componentId, resourceInstanceId, inputs,
+ userId);
+ Assert.assertNotNull(result);
}
-
@Test
public void testCreateOrUpdateGroupInstancePropertyValue() throws Exception {
ComponentInstanceBusinessLogic testSubject;
String userId = user.getUserId();
Either<ComponentInstanceProperty, ResponseFormat> result;
-
when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseMetadata))
- .thenReturn(Either.left(resource));
+ .thenReturn(Either.left(resource));
// test 1
testSubject = createTestSubject();
result = testSubject
- .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
- groupInstanceId, property, userId);
+ .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
+ groupInstanceId, property, userId);
+ Assert.assertNotNull(result);
componentTypeEnum = null;
result = testSubject
- .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
- groupInstanceId, property, userId);
+ .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
+ groupInstanceId, property, userId);
+ Assert.assertNotNull(result);
- // when(toscaOperationFacade.getToscaElement(componentId, JsonParseFlagEnum.ParseMetadata)).thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
result = testSubject
- .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
- groupInstanceId, property, userId);
+ .createOrUpdateGroupInstancePropertyValue(componentTypeEnum, componentId, resourceInstanceId,
+ groupInstanceId, property, userId);
+ Assert.assertNotNull(result);
}
-
@Test
public void testDeletePropertyValue() throws Exception {
ComponentInstanceBusinessLogic testSubject;
Either<ComponentInstanceProperty, ResponseFormat> result;
when(toscaOperationFacade.getToscaElement(serviceId, JsonParseFlagEnum.ParseMetadata))
- .thenReturn(Either.left(service));
+ .thenReturn(Either.left(service));
// test 1
testSubject = createTestSubject();
result = testSubject.deletePropertyValue(componentTypeEnum, serviceId, resourceInstanceId, propertyValueId,
- userId);
+ userId);
+ Assert.assertNotNull(result);
componentTypeEnum = null;
result = testSubject.deletePropertyValue(componentTypeEnum, serviceId, resourceInstanceId, propertyValueId,
- userId);
+ userId);
+ Assert.assertNotNull(result);
- // when(toscaOperationFacade.getToscaElement(serviceId, JsonParseFlagEnum.ParseMetadata)).thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
result = testSubject.deletePropertyValue(componentTypeEnum, serviceId, resourceInstanceId, propertyValueId,
- userId);
+ userId);
+ Assert.assertNotNull(result);
}
@Test
// default test
testSubject = createTestSubject();
result = Deencapsulation.invoke(testSubject, "getComponentParametersViewForForwardingPath");
+ Assert.assertNotNull(result);
}
@Test
// default test
testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "getResourceInstanceById", new Object[] {resource, instanceId});
+ result = Deencapsulation.invoke(testSubject, "getResourceInstanceById", new Object[]{resource, instanceId});
+ Assert.assertNotNull(result);
}
@Test
String userId = user.getUserId();
Either<List<ComponentInstanceProperty>, ResponseFormat> result;
-
when(toscaOperationFacade.getToscaFullElement(containerComponentId))
- .thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
+ .thenReturn(Either.right(StorageOperationStatus.BAD_REQUEST));
// test 1
testSubject = createTestSubject();
result = testSubject.updateInstanceCapabilityProperties(componentTypeEnum, containerComponentId,
- componentInstanceUniqueId, capabilityType, capabilityName, properties, userId);
+ componentInstanceUniqueId, capabilityType, capabilityName, properties, userId);
+ Assert.assertNotNull(result);
when(toscaOperationFacade.getToscaFullElement(containerComponentId)).thenReturn(Either.left(resource));
result = testSubject.updateInstanceCapabilityProperties(componentTypeEnum, containerComponentId,
- componentInstanceUniqueId, capabilityType, capabilityName, properties, userId);
+ componentInstanceUniqueId, capabilityType, capabilityName, properties, userId);
+ Assert.assertNotNull(result);
}
@Test
Either<Component, StorageOperationStatus> leftServiceOp = Either.left(service);
when(toscaOperationFacade.getToscaElement(containerComponentId)).thenReturn(leftServiceOp);
when(toscaOperationFacade.getToscaElement(eq(containerComponentId), any(ComponentParametersView.class)))
- .thenReturn(leftServiceOp);
+ .thenReturn(leftServiceOp);
when(janusGraphDao.rollback()).thenReturn(JanusGraphOperationStatus.OK);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
result = componentInstanceBusinessLogic
- .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId,
- USER_ID);
+ .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId,
+ USER_ID);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldLastUpdatedUserId);
-
assertThat(result.isRight());
}
Either<Component, StorageOperationStatus> leftServiceOp = Either.left(service);
when(toscaOperationFacade.getToscaElement(containerComponentId)).thenReturn(leftServiceOp);
when(toscaOperationFacade.getToscaElement(eq(containerComponentId), any(ComponentParametersView.class)))
- .thenReturn(leftServiceOp);
+ .thenReturn(leftServiceOp);
when(janusGraphDao.rollback()).thenReturn(JanusGraphOperationStatus.OK);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
Either<Component, StorageOperationStatus> getComponentRes = Either.left(resource);
result = componentInstanceBusinessLogic
- .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId, USER_ID);
+ .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId, USER_ID);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldServiceLastUpdatedUserId);
assertThat(result.isRight());
}
Either<Component, StorageOperationStatus> leftServiceOp = Either.left(service);
when(toscaOperationFacade.getToscaElement(containerComponentId)).thenReturn(leftServiceOp);
when(toscaOperationFacade.getToscaElement(eq(containerComponentId), any(ComponentParametersView.class)))
- .thenReturn(leftServiceOp);
+ .thenReturn(leftServiceOp);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
Either<Component, StorageOperationStatus> getComponentRes = Either.left(resource);
ImmutablePair<Component, String> pair = new ImmutablePair<>(resource, TO_INSTANCE_ID);
Either<ImmutablePair<Component, String>, StorageOperationStatus> result2 = Either.left(pair);
Either<Map<String, ArtifactDefinition>, StorageOperationStatus> getResourceDeploymentArtifacts = Either
- .left(new HashMap<String, ArtifactDefinition>());
+ .left(new HashMap<String, ArtifactDefinition>());
StorageOperationStatus artStatus = StorageOperationStatus.OK;
result = componentInstanceBusinessLogic
- .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId,
- USER_ID);
+ .copyComponentInstance(inputComponentInstance, containerComponentId, componentInstanceId,
+ USER_ID);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldServiceLastUpdatedUserId);
resource.setLifecycleState(oldResourceLifeCycle);
service.setLifecycleState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
Map<String, List<ComponentInstanceProperty>> instAttrsMap =
- new HashMap<String, List<ComponentInstanceProperty>>();
+ new HashMap<String, List<ComponentInstanceProperty>>();
List<ComponentInstanceProperty> instAttrsList = new ArrayList<ComponentInstanceProperty>();
ComponentInstanceProperty prop = new ComponentInstanceProperty();
prop.setUniqueId(attribute.getUniqueId());
Either<Component, StorageOperationStatus> serviceEitherLeft = Either.left(service);
when(toscaOperationFacade.getToscaElement(serviceComponentInstance.getUniqueId(), JsonParseFlagEnum.ParseAll))
- .thenReturn(serviceEitherLeft);
+ .thenReturn(serviceEitherLeft);
when(toscaOperationFacade.updateComponentInstanceAttribute(service, toInstance.getUniqueId(), attribute))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(toscaOperationFacade.updateComponentInstanceMetadataOfTopologyTemplate(service))
- .thenReturn(serviceEitherLeft);
+ .thenReturn(serviceEitherLeft);
Either<ComponentInstanceProperty, ResponseFormat> result = Deencapsulation
- .invoke(componentInstanceBusinessLogic,
- "createOrUpdateAttributeValueForCopyPaste",
- ComponentTypeEnum.SERVICE,
- serviceComponentInstance
- .getUniqueId(),
- toInstance.getUniqueId(), attribute,
- USER_ID);
+ .invoke(componentInstanceBusinessLogic,
+ "createOrUpdateAttributeValueForCopyPaste",
+ ComponentTypeEnum.SERVICE,
+ serviceComponentInstance
+ .getUniqueId(),
+ toInstance.getUniqueId(), attribute,
+ USER_ID);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldLastUpdatedUserId);
service.setLifecycleState(oldLifeCycleState);
when(toscaOperationFacade.getToscaElement(containerComponentId)).thenReturn(getComponent);
StorageOperationStatus status = StorageOperationStatus.OK;
when(toscaOperationFacade.updateComponentInstanceProperty(service, componentInstanceId, property))
- .thenReturn(status);
+ .thenReturn(status);
Either<Component, StorageOperationStatus> updateContainerRes = Either.left(service);
when(toscaOperationFacade.updateComponentInstanceMetadataOfTopologyTemplate(service))
- .thenReturn(updateContainerRes);
+ .thenReturn(updateContainerRes);
Either<String, ResponseFormat> result = Deencapsulation.invoke(componentInstanceBusinessLogic,
- "updateComponentInstanceProperty", containerComponentId, componentInstanceId, property);
-
+ "updateComponentInstanceProperty", containerComponentId, componentInstanceId, property);
+ Assert.assertNotNull(result);
assertTrue(result.isLeft());
}
service.setInputs(newInputs);
Either<String, ResponseFormat> result =
- Deencapsulation.invoke(componentInstanceBusinessLogic, "getInputListDefaultValue", component, inputId);
+ Deencapsulation.invoke(componentInstanceBusinessLogic, "getInputListDefaultValue", component, inputId);
service.setInputs(oldInputs);
deleteErrorIds.add(componentInstanceId);
deleteErrorMap.put("deleteFailedIds", deleteErrorIds);
Either<Component, StorageOperationStatus> cont = Either.left(service);
- when(componentsUtils.convertFromStorageResponse(eq(StorageOperationStatus.NOT_FOUND),eq(null)))
- .thenReturn(ActionStatus.GENERAL_ERROR);
+ when(componentsUtils.convertFromStorageResponse(eq(StorageOperationStatus.NOT_FOUND), eq(null)))
+ .thenReturn(ActionStatus.GENERAL_ERROR);
when(toscaOperationFacade.getToscaElement(any(String.class), any(ComponentParametersView.class)))
- .thenReturn(cont);
+ .thenReturn(cont);
- try{
- result = componentInstanceBusinessLogic
+ try {
+ result = componentInstanceBusinessLogic
.batchDeleteComponentInstance(containerComponentParam, containerComponentId, componentInstanceIdList,
- userId);
- }catch (ComponentException e){
- assertEquals(e.getActionStatus().toString(), StorageOperationStatus.GENERAL_ERROR.toString());
- }
-
-// assertEquals(deleteErrorMap, result);
+ userId);
+ Assert.assertNotNull(result);
+ assertEquals(deleteErrorMap, result);
+ } catch (ComponentException e) {
+ assertEquals(e.getActionStatus().toString(), StorageOperationStatus.GENERAL_ERROR.toString());
+ }
}
@Test
Either<Component, StorageOperationStatus> err = Either.right(StorageOperationStatus.GENERAL_ERROR);
when(toscaOperationFacade.getToscaElement(eq(containerComponentId), any(ComponentParametersView.class)))
- .thenReturn(err);
+ .thenReturn(err);
try {
result = componentInstanceBusinessLogic
- .batchDeleteComponentInstance(containerComponentParam, containerComponentId, componentInstanceIdList,
- userId);
- }catch (ComponentException e){
+ .batchDeleteComponentInstance(containerComponentParam, containerComponentId, componentInstanceIdList,
+ userId);
+ Assert.assertNotNull(result);
+ assertEquals(deleteErrorMap, result);
+ } catch (ComponentException e) {
assertEquals(e.getActionStatus().toString(), StorageOperationStatus.GENERAL_ERROR.toString());
}
-// assertEquals(deleteErrorMap, result);
}
@Test
Either<Component, StorageOperationStatus> cont = Either.left(service);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
ImmutablePair<Component, String> pair = new ImmutablePair<>(resource, TO_INSTANCE_ID);
Either<ImmutablePair<Component, String>, StorageOperationStatus> result2 = Either.left(pair);
when(toscaOperationFacade.deleteComponentInstanceFromTopologyTemplate(service, componentInstanceId))
- .thenReturn(result2);
+ .thenReturn(result2);
when(toscaOperationFacade.getToscaElement(eq(service.getUniqueId()), any(ComponentParametersView.class)))
- .thenReturn(cont);
+ .thenReturn(cont);
when(janusGraphDao.commit()).thenReturn(JanusGraphOperationStatus.OK);
result = componentInstanceBusinessLogic
- .batchDeleteComponentInstance(containerComponentParam, containerComponentId,
- componentInstanceIdList, userId);
+ .batchDeleteComponentInstance(containerComponentParam, containerComponentId,
+ componentInstanceIdList, userId);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldLastUpdatedUserId);
service.setLifecycleState(oldLifeCycleState);
Either<Component, StorageOperationStatus> cont = Either.left(service);
when(toscaOperationFacade.getToscaElement(eq(service.getUniqueId()), any(ComponentParametersView.class)))
- .thenReturn(cont);
+ .thenReturn(cont);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
Either<RequirementCapabilityRelDef, StorageOperationStatus> resultEither;
resultEither = Either.right(StorageOperationStatus.OK);
- when(componentsUtils.convertFromStorageResponseForResourceInstance(eq(StorageOperationStatus.OK),eq(true)))
- .thenReturn(ActionStatus.GENERAL_ERROR);
+ when(componentsUtils.convertFromStorageResponseForResourceInstance(eq(StorageOperationStatus.OK), eq(true)))
+ .thenReturn(ActionStatus.GENERAL_ERROR);
when(toscaOperationFacade.dissociateResourceInstances(componentId, ref)).thenReturn(resultEither);
- try{
- result = componentInstanceBusinessLogic
- .batchDissociateRIFromRI(componentId, userId, requirementDefList, componentTypeEnum);
- }catch (ComponentException e){
- assertEquals(e.getActionStatus().toString(), StorageOperationStatus.GENERAL_ERROR.toString());
- }
+ try {
+ result = componentInstanceBusinessLogic
+ .batchDissociateRIFromRI(componentId, userId, requirementDefList, componentTypeEnum);
+ Assert.assertNotNull(result);
+ assertEquals(new ArrayList<>(), result);
+ } catch (ComponentException e) {
+ assertEquals(e.getActionStatus().toString(), StorageOperationStatus.GENERAL_ERROR.toString());
+ }
service.setLastUpdaterUserId(oldLastUpdatedUserId);
service.setLifecycleState(oldLifeCycleState);
-// assertEquals(new ArrayList<>(), result);
}
@Test
Either<Component, StorageOperationStatus> cont = Either.left(service);
when(toscaOperationFacade.getToscaElement(eq(service.getUniqueId()), any(ComponentParametersView.class)))
- .thenReturn(cont);
+ .thenReturn(cont);
when(graphLockOperation.unlockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
when(graphLockOperation.lockComponent(Mockito.anyString(), eq(NodeTypeEnum.Service)))
- .thenReturn(StorageOperationStatus.OK);
+ .thenReturn(StorageOperationStatus.OK);
Either<RequirementCapabilityRelDef, StorageOperationStatus> resultEither;
resultEither = Either.left(ref);
when(toscaOperationFacade.dissociateResourceInstances(componentId, ref)).thenReturn(resultEither);
result = componentInstanceBusinessLogic
- .batchDissociateRIFromRI(componentId, userId, requirementDefList, componentTypeEnum);
+ .batchDissociateRIFromRI(componentId, userId, requirementDefList, componentTypeEnum);
+ Assert.assertNotNull(result);
service.setLastUpdaterUserId(oldLastUpdatedUserId);
service.setLifecycleState(oldLifeCycleState);
@Test
public void testGetComponentInstancePropertyByPolicyId_success() {
Optional<ComponentInstanceProperty> propertyCandidate =
- getComponentInstanceProperty(PROP_NAME);
+ getComponentInstanceProperty(PROP_NAME);
Assert.assertTrue(propertyCandidate.isPresent());
Assert.assertEquals(propertyCandidate.get().getName(), PROP_NAME);
@Test
public void testGetComponentInstancePropertyByPolicyId_failure() {
Optional<ComponentInstanceProperty> propertyCandidate =
- getComponentInstanceProperty(NON_EXIST_NAME);
+ getComponentInstanceProperty(NON_EXIST_NAME);
Assert.assertEquals(propertyCandidate, Optional.empty());
}
componentInstanceProperty.setGetPolicyValues(policyDefinition.getGetPolicyValues());
service.setComponentInstancesProperties(
- Collections.singletonMap(COMPONENT_INST_ID, Collections.singletonList(componentInstanceProperty)));
+ Collections.singletonMap(COMPONENT_INST_ID, Collections.singletonList(componentInstanceProperty)));
return componentInstanceBusinessLogic.getComponentInstancePropertyByPolicyId(service, policyDefinition);
}
Code Review / sdc.git / blobdiff