1 package org.openecomp.sdc.be.components.merge.instance;
4 import org.openecomp.sdc.be.components.merge.VspComponentsMergeCommand;
5 import org.openecomp.sdc.be.components.merge.property.DataDefinitionsValuesMergingBusinessLogic;
6 import org.openecomp.sdc.be.dao.api.ActionStatus;
7 import org.openecomp.sdc.be.impl.ComponentsUtils;
8 import org.openecomp.sdc.be.model.Component;
9 import org.openecomp.sdc.be.model.ComponentInstance;
10 import org.openecomp.sdc.be.model.ComponentInstanceProperty;
11 import org.openecomp.sdc.be.model.InputDefinition;
12 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
13 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
14 import org.springframework.core.annotation.Order;
16 import java.util.Collections;
17 import java.util.List;
19 import java.util.function.Function;
20 import java.util.stream.Collectors;
22 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;
24 @org.springframework.stereotype.Component
25 @Order(ANY_ORDER_COMMAND)
26 public class ComponentInstancePropertiesMergeBL implements VspComponentsMergeCommand {
28 private final ToscaOperationFacade toscaOperationFacade;
29 private final ComponentsUtils componentsUtils;
30 private final DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic;
32 public ComponentInstancePropertiesMergeBL(ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic) {
33 this.toscaOperationFacade = toscaOperationFacade;
34 this.componentsUtils = componentsUtils;
35 this.propertyValuesMergingBusinessLogic = propertyValuesMergingBusinessLogic;
39 public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
40 Map<String, List<ComponentInstanceProperty>> newInstProps = currentComponent.getComponentInstancesProperties();
41 if (newInstProps == null) {
42 return ActionStatus.OK;
44 Map<String, String> currComponentNames = getComponentNameByUniqueId(currentComponent);
45 Map<String, String> prevComponentUniqueIds = getComponentUniqueIdByName(prevComponent);
47 newInstProps.forEach((instanceId, newProps) -> {
48 String instanceName = currComponentNames.get(instanceId);
49 String oldInstanceId = prevComponentUniqueIds.get(instanceName);
51 mergeOldInstancePropertiesValues(prevComponent, currentComponent, oldInstanceId, newProps);
53 return updateComponentInstancesProperties(currentComponent, newInstProps);
57 public String description() {
58 return "merge component instance properties";
62 public ActionStatus mergeComponentInstanceProperties(List<ComponentInstanceProperty> oldInstProps, List<InputDefinition> oldInputs, Component newComponent, String instanceId) {
63 List<ComponentInstanceProperty> newInstProps = newComponent.safeGetComponentInstanceProperties(instanceId);
64 if (newInstProps == null) {
65 return ActionStatus.OK;
67 propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstProps, oldInputs, newInstProps, newComponent.getInputs());
68 return updateComponentInstanceProperties(newComponent, instanceId, newInstProps);
71 private static Map<String, String> getComponentNameByUniqueId(Component component) {
72 return asMap(component, ComponentInstance::getUniqueId, ComponentInstance::getName);
75 private static Map<String, String> getComponentUniqueIdByName(Component component) {
76 return asMap(component, ComponentInstance::getName, ComponentInstance::getUniqueId);
79 private static Map<String, String> asMap(Component component, Function<? super ComponentInstance, ? extends String> keyMapper, Function<? super ComponentInstance, ? extends String> valueMapper) {
80 return component.safeGetComponentInstances().stream().
81 collect(Collectors.toMap(keyMapper, valueMapper));
84 private void mergeOldInstancePropertiesValues(Component oldComponent, Component newComponent, String instanceId, List<ComponentInstanceProperty> newProps) {
85 List<ComponentInstanceProperty> oldInstProperties = oldComponent == null ? Collections.emptyList() : oldComponent.safeGetComponentInstanceProperties(instanceId);
86 List<InputDefinition> oldInputs = oldComponent == null ? Collections.emptyList() : oldComponent.getInputs();
87 propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstProperties, oldInputs, newProps, newComponent.getInputs());
90 private ActionStatus updateComponentInstancesProperties(Component newComponent, Map<String, List<ComponentInstanceProperty>> newInstProps) {
91 Either<Map<String, List<ComponentInstanceProperty>>, StorageOperationStatus> mapStorageOperationStatusEither = toscaOperationFacade.updateComponentInstancePropsToComponent(newInstProps, newComponent.getUniqueId());
92 if (mapStorageOperationStatusEither.isRight()) {
93 return componentsUtils.convertFromStorageResponse(mapStorageOperationStatusEither.right().value());
95 return ActionStatus.OK;
98 private ActionStatus updateComponentInstanceProperties(Component component, String instanceId, List<ComponentInstanceProperty> newInstProps) {
99 StorageOperationStatus storageOperationStatus = toscaOperationFacade.updateComponentInstanceProperties(component, instanceId, newInstProps);
100 if (storageOperationStatus != StorageOperationStatus.OK) {
101 return componentsUtils.convertFromStorageResponse(storageOperationStatus);
103 return ActionStatus.OK;