catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/instance/ComponentInstanceInputsMergeBL.java

   1 package org.openecomp.sdc.be.components.merge.instance;
   2
   3 import fj.data.Either;
   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.jsontitan.operations.ToscaOperationFacade;
  13 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  14 import org.springframework.core.annotation.Order;
  15
  16 import java.util.Collections;
  17 import java.util.List;
  18 import java.util.Map;
  19 import java.util.stream.Collectors;
  20
  21 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;
  22
  23 @org.springframework.stereotype.Component
  24 @Order(ANY_ORDER_COMMAND)
  25 public class ComponentInstanceInputsMergeBL implements VspComponentsMergeCommand {
  26
  27     private final ToscaOperationFacade toscaOperationFacade;
  28     private final ComponentsUtils componentsUtils;
  29     private final DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic;
  30
  31     public ComponentInstanceInputsMergeBL(ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic) {
  32         this.toscaOperationFacade = toscaOperationFacade;
  33         this.componentsUtils = componentsUtils;
  34         this.propertyValuesMergingBusinessLogic = propertyValuesMergingBusinessLogic;
  35     }
  36
  37     @Override
  38     public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
  39         Map<String, List<ComponentInstanceInput>> componentInstancesInputs = currentComponent.getComponentInstancesInputs();
  40         if (componentInstancesInputs == null) {
  41             return ActionStatus.OK;
  42         }
  43         componentInstancesInputs.forEach((instanceId, instInputs) -> mergeOldInstanceInputsValues(prevComponent, currentComponent, instanceId, instInputs));
  44         return updateComponentInstancesInputs(currentComponent, componentInstancesInputs);
  45     }
  46
  47     @Override
  48     public String description() {
  49         return "merge component instance inputs";
  50     }
  51
  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;
  56         }
  57
  58         List<ComponentInstanceInput> oldRedeclaredInputs = findComponentInputs(oldInstProps);
  59         oldRedeclaredInputs.forEach(oldInput -> newInstInputs.stream()
  60                                                               .filter(newInstInput -> oldInput.getName().equals(newInstInput.getName()))
  61                                                               .forEach(this::switchValues));
  62
  63         propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstProps, oldInputs, newInstInputs, newComponent.getInputs());
  64         return updateComponentInstanceInputs(newComponent, instanceId, newInstInputs);
  65     }
  66
  67     private void switchValues(ComponentInstanceInput input) {
  68         String tempDefaultValue = input.getDefaultValue();
  69         input.setDefaultValue(input.getValue());
  70         input.setValue(tempDefaultValue);
  71     }
  72
  73     private List<ComponentInstanceInput> findComponentInputs(List<ComponentInstanceInput> oldInstProps) {
  74         return oldInstProps.stream()
  75                            .filter(ComponentInstanceInput::isGetInputProperty)
  76                            .collect(Collectors.toList());
  77     }
  78
  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);
  83         }
  84         return ActionStatus.OK;
  85     }
  86
  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());
  91         }
  92         return ActionStatus.OK;
  93     }
  94
  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());
 100     }
 101
 102 }