catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/input/GlobalInputsMergeCommand.java

   1 package org.openecomp.sdc.be.components.merge.input;
   2
   3 import org.openecomp.sdc.be.components.impl.utils.ExceptionUtils;
   4 import org.openecomp.sdc.be.components.merge.ComponentsGlobalMergeCommand;
   5 import org.openecomp.sdc.be.components.merge.GlobalInputsFilteringBusinessLogic;
   6 import org.openecomp.sdc.be.dao.api.ActionStatus;
   7 import org.openecomp.sdc.be.datatypes.elements.PropertyDataDefinition;
   8 import org.openecomp.sdc.be.impl.ComponentsUtils;
   9 import org.openecomp.sdc.be.model.Component;
  10 import org.openecomp.sdc.be.model.InputDefinition;
  11 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  12 import org.springframework.core.annotation.Order;
  13
  14 import java.util.List;
  15 import java.util.Map;
  16 import java.util.stream.Stream;
  17
  18 import static java.util.stream.Collectors.toMap;
  19 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.LAST_COMMAND;
  20 import static org.openecomp.sdc.be.utils.PropertyDefinitionUtils.convertListOfProperties;
  21
  22 @org.springframework.stereotype.Component
  23 @Order(LAST_COMMAND)
  24 public class GlobalInputsMergeCommand extends InputsMergeCommand implements ComponentsGlobalMergeCommand {
  25
  26     private GlobalInputsFilteringBusinessLogic globalInputsFilteringBusinessLogic;
  27     private ExceptionUtils exceptionUtils;
  28
  29     public GlobalInputsMergeCommand(InputsValuesMergingBusinessLogic inputsValuesMergingBusinessLogic, DeclaredInputsResolver declaredInputsResolver, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, GlobalInputsFilteringBusinessLogic globalInputsFilteringBusinessLogic, ExceptionUtils exceptionUtils) {
  30         super(inputsValuesMergingBusinessLogic, declaredInputsResolver, toscaOperationFacade, componentsUtils);
  31         this.globalInputsFilteringBusinessLogic = globalInputsFilteringBusinessLogic;
  32         this.exceptionUtils = exceptionUtils;
  33     }
  34
  35     @Override
  36     public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
  37         return super.redeclareAndMergeInputsValues(prevComponent, currentComponent);
  38     }
  39
  40     @Override
  41     public String description() {
  42         return "merge global (non vsp) inputs";
  43     }
  44
  45     @Override
  46     List<InputDefinition> getInputsToMerge(Component component) {
  47         return globalInputsFilteringBusinessLogic.filterGlobalInputs(component).left().on(err -> exceptionUtils.rollBackAndThrow(err));
  48     }
  49
  50     @Override
  51     Map<String, List<PropertyDataDefinition>> getProperties(Component component) {
  52         return Stream.of(component.safeGetGroupsProperties(), component.safeGetPolicyProperties())
  53                 .flatMap(map -> map.entrySet().stream())
  54                 .collect(toMap(Map.Entry::getKey, entry -> convertListOfProperties(entry.getValue())));
  55     }
  56
  57 }