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.ComponentInstanceInput;
11 import org.openecomp.sdc.be.model.InputDefinition;
12 import org.openecomp.sdc.be.model.jsonjanusgraph.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.stream.Collectors;
21 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;
23 @org.springframework.stereotype.Component
24 @Order(ANY_ORDER_COMMAND)
25 public class ComponentInstanceInputsMergeBL implements VspComponentsMergeCommand {
27 private final ToscaOperationFacade toscaOperationFacade;
28 private final ComponentsUtils componentsUtils;
29 private final DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic;
31 public ComponentInstanceInputsMergeBL(ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic) {
32 this.toscaOperationFacade = toscaOperationFacade;
33 this.componentsUtils = componentsUtils;
34 this.propertyValuesMergingBusinessLogic = propertyValuesMergingBusinessLogic;
38 public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
39 Map<String, List<ComponentInstanceInput>> componentInstancesInputs = currentComponent.getComponentInstancesInputs();
40 if (componentInstancesInputs == null) {
41 return ActionStatus.OK;
43 componentInstancesInputs.forEach((instanceId, instInputs) -> mergeOldInstanceInputsValues(prevComponent, currentComponent, instanceId, instInputs));
44 return updateComponentInstancesInputs(currentComponent, componentInstancesInputs);
48 public String description() {
49 return "merge component instance inputs";
52 public ActionStatus mergeComponentInstanceInputs(List<ComponentInstanceInput> oldInstProps, List<InputDefinition> oldInputs, Component newComponent, String instanceId) {
53 List<ComponentInstanceInput> newInstInputs = newComponent.safeGetComponentInstanceInput(instanceId);
54 if (newInstInputs == null) {
55 return ActionStatus.OK;
58 List<ComponentInstanceInput> oldRedeclaredInputs = findComponentInputs(oldInstProps);
59 oldRedeclaredInputs.forEach(oldInput -> newInstInputs.stream()
60 .filter(newInstInput -> oldInput.getName().equals(newInstInput.getName()))
61 .forEach(this::switchValues));
63 propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstProps, oldInputs, newInstInputs, newComponent.getInputs());
64 return updateComponentInstanceInputs(newComponent, instanceId, newInstInputs);
67 private void switchValues(ComponentInstanceInput input) {
68 String tempDefaultValue = input.getDefaultValue();
69 input.setDefaultValue(input.getValue());
70 input.setValue(tempDefaultValue);
73 private List<ComponentInstanceInput> findComponentInputs(List<ComponentInstanceInput> oldInstProps) {
74 return oldInstProps.stream()
75 .filter(ComponentInstanceInput::isGetInputProperty)
76 .collect(Collectors.toList());
79 private ActionStatus updateComponentInstanceInputs(Component newComponent, String instanceId, List<ComponentInstanceInput> newInstInput) {
80 StorageOperationStatus storageOperationStatus = toscaOperationFacade.updateComponentInstanceInputs(newComponent, instanceId, newInstInput);
81 if (storageOperationStatus != StorageOperationStatus.OK) {
82 return componentsUtils.convertFromStorageResponse(storageOperationStatus);
84 return ActionStatus.OK;
87 private ActionStatus updateComponentInstancesInputs(Component component, Map<String, List<ComponentInstanceInput>> componentInstancesInputs) {
88 Either<Map<String, List<ComponentInstanceInput>>, StorageOperationStatus> mapStorageOperationStatusEither = toscaOperationFacade.updateComponentInstanceInputsToComponent(componentInstancesInputs, component.getUniqueId());
89 if (mapStorageOperationStatusEither.isRight()) {
90 return componentsUtils.convertFromStorageResponse(mapStorageOperationStatusEither.right().value());
92 return ActionStatus.OK;
95 private void mergeOldInstanceInputsValues(Component oldComponent, Component newComponent, String instanceId, List<ComponentInstanceInput> instInputs) {
96 ComponentInstance currentCompInstance = newComponent.getComponentInstanceById(instanceId).get();
97 List<ComponentInstanceInput> oldInstInputs = oldComponent == null ? Collections.emptyList() : oldComponent.safeGetComponentInstanceInputsByName(currentCompInstance.getName());
98 List<InputDefinition> oldInputs = oldComponent == null ? Collections.emptyList() : oldComponent.getInputs();
99 propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstInputs, oldInputs, instInputs, newComponent.getInputs());