1 package org.openecomp.sdc.be.components.merge.input;
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.jsonjanusgraph.operations.ToscaOperationFacade;
12 import org.springframework.core.annotation.Order;
14 import java.util.List;
16 import java.util.stream.Stream;
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;
22 @org.springframework.stereotype.Component
24 public class GlobalInputsMergeCommand extends InputsMergeCommand implements ComponentsGlobalMergeCommand {
26 private GlobalInputsFilteringBusinessLogic globalInputsFilteringBusinessLogic;
27 private ExceptionUtils exceptionUtils;
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;
36 public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
37 return super.redeclareAndMergeInputsValues(prevComponent, currentComponent);
41 public String description() {
42 return "merge global (non vsp) inputs";
46 List<InputDefinition> getInputsToMerge(Component component) {
47 return globalInputsFilteringBusinessLogic.filterGlobalInputs(component).left().on(err -> exceptionUtils.rollBackAndThrow(err));
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())));