gerrit.onap Code Review - sdc.git/blob

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