gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.sdc.be.components.merge.instance;
   2
   3 import fj.data.Either;
   4 import org.openecomp.sdc.be.components.merge.property.DataDefinitionsValuesMergingBusinessLogic;
   5 import org.openecomp.sdc.be.dao.api.ActionStatus;
   6 import org.openecomp.sdc.be.impl.ComponentsUtils;
   7 import org.openecomp.sdc.be.model.Component;
   8 import org.openecomp.sdc.be.model.ComponentInstance;
   9 import org.openecomp.sdc.be.model.ComponentInstanceInput;
  10 import org.openecomp.sdc.be.model.InputDefinition;
  11 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  12 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  13
  14 import java.util.Collections;
  15 import java.util.List;
  16 import java.util.Map;
  17
  18 @org.springframework.stereotype.Component
  19 public class ComponentInstanceInputsMergeBL implements ComponentsMergeCommand {
  20
  21     @javax.annotation.Resource
  22     private ToscaOperationFacade toscaOperationFacade;
  23
  24     @javax.annotation.Resource
  25     private ComponentsUtils componentsUtils;
  26
  27     @javax.annotation.Resource
  28     private DataDefinitionsValuesMergingBusinessLogic propertyValuesMergingBusinessLogic;
  29
  30     @Override
  31     public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
  32         Map<String, List<ComponentInstanceInput>> componentInstancesInputs = currentComponent.getComponentInstancesInputs();
  33         if (componentInstancesInputs == null) {
  34             return ActionStatus.OK;
  35         }
  36         componentInstancesInputs.forEach((instanceId, instInputs) -> mergeOldInstanceInputsValues(prevComponent, currentComponent, instanceId, instInputs));
  37         return updateComponentInstancesInputs(currentComponent, componentInstancesInputs);
  38     }
  39
  40     @Override
  41     public String description() {
  42         return "merge component instance inputs";
  43     }
  44
  45     public ActionStatus mergeComponentInstanceInputs(List<ComponentInstanceInput> oldInstProps, List<InputDefinition> oldInputs, Component newComponent, String instanceId) {
  46         List<ComponentInstanceInput> newInstInput = newComponent.safeGetComponentInstanceInput(instanceId);
  47         if (newInstInput == null) {
  48             return ActionStatus.OK;
  49         }
  50         propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstProps, oldInputs, newInstInput, newComponent.getInputs());
  51         return updateComponentInstanceInputs(newComponent, instanceId, newInstInput);
  52     }
  53
  54     private ActionStatus updateComponentInstanceInputs(Component newComponent, String instanceId, List<ComponentInstanceInput> newInstInput) {
  55         StorageOperationStatus storageOperationStatus = toscaOperationFacade.updateComponentInstanceInputs(newComponent, instanceId, newInstInput);
  56         if (storageOperationStatus != StorageOperationStatus.OK) {
  57             return componentsUtils.convertFromStorageResponse(storageOperationStatus);
  58         }
  59         return ActionStatus.OK;
  60     }
  61
  62     private ActionStatus updateComponentInstancesInputs(Component component, Map<String, List<ComponentInstanceInput>> componentInstancesInputs) {
  63         Either<Map<String, List<ComponentInstanceInput>>, StorageOperationStatus> mapStorageOperationStatusEither = toscaOperationFacade.updateComponentInstanceInputsToComponent(componentInstancesInputs, component.getUniqueId());
  64         if (mapStorageOperationStatusEither.isRight()) {
  65             return componentsUtils.convertFromStorageResponse(mapStorageOperationStatusEither.right().value());
  66         }
  67         return ActionStatus.OK;
  68     }
  69
  70     private void mergeOldInstanceInputsValues(Component oldComponent, Component newComponent, String instanceId, List<ComponentInstanceInput> instInputs) {
  71         ComponentInstance currentCompInstance = newComponent.getComponentInstanceById(instanceId).get();
  72         List<ComponentInstanceInput> oldInstInputs = oldComponent == null ? Collections.emptyList() : oldComponent.safeGetComponentInstanceInputsByName(currentCompInstance.getName());
  73         List<InputDefinition> oldInputs = oldComponent == null ? Collections.emptyList() : oldComponent.getInputs();
  74         propertyValuesMergingBusinessLogic.mergeInstanceDataDefinitions(oldInstInputs, oldInputs, instInputs, newComponent.getInputs());
  75     }
  76
  77 }