1 files changed, 71 insertions, 0 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/input/InputsMergeCommand.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/input/InputsMergeCommand.java
new file mode 100644
index 0000000000..3cf4c0df65
--- /dev/null
+++ b/catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/input/InputsMergeCommand.java
@@ -0,0 +1,71 @@
+package org.openecomp.sdc.be.components.merge.input;
+
+import org.openecomp.sdc.be.dao.api.ActionStatus;
+import org.openecomp.sdc.be.datatypes.elements.PropertyDataDefinition;
+import org.openecomp.sdc.be.impl.ComponentsUtils;
+import org.openecomp.sdc.be.model.Component;
+import org.openecomp.sdc.be.model.InputDefinition;
+import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
+import org.openecomp.sdc.common.log.wrappers.Logger;
+
+import java.util.List;
+import java.util.Map;
+
+import static java.util.Collections.emptyList;
+import static org.apache.commons.collections.CollectionUtils.isEmpty;
+
+public abstract class InputsMergeCommand {
+
+    private static final Logger log = Logger.getLogger(InputsMergeCommand.class);
+
+    private InputsValuesMergingBusinessLogic inputsValuesMergingBusinessLogic;
+    private DeclaredInputsResolver declaredInputsResolver;
+    private ToscaOperationFacade toscaOperationFacade;
+    private ComponentsUtils componentsUtils;
+
+    public InputsMergeCommand(InputsValuesMergingBusinessLogic inputsValuesMergingBusinessLogic, DeclaredInputsResolver declaredInputsResolver, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils) {
+        this.inputsValuesMergingBusinessLogic = inputsValuesMergingBusinessLogic;
+        this.declaredInputsResolver = declaredInputsResolver;
+        this.toscaOperationFacade = toscaOperationFacade;
+        this.componentsUtils = componentsUtils;
+    }
+
+    abstract List<InputDefinition> getInputsToMerge(Component component);
+
+    abstract Map<String, List<PropertyDataDefinition>> getProperties(Component component);
+
+    ActionStatus redeclareAndMergeInputsValues(Component prevComponent, Component currComponent) {
+        if (prevComponent == null || isEmpty(prevComponent.getInputs())) {
+            return ActionStatus.OK;
+        }
+        List<InputDefinition> mergedInputs = mergeInputsValues(prevComponent, currComponent);
+        List<InputDefinition> previouslyDeclaredInputsToMerge = getPreviouslyDeclaredInputsToMerge(prevComponent, currComponent);
+        mergedInputs.addAll(previouslyDeclaredInputsToMerge);
+        return updateInputs(currComponent.getUniqueId(), mergedInputs);
+    }
+
+    private List<InputDefinition> mergeInputsValues(Component prevComponent, Component currComponent) {
+        log.debug("#mergeInputsValues - merge inputs values from previous component {} to current component {}", prevComponent.getUniqueId(), currComponent.getUniqueId());
+        List<InputDefinition> inputsToMerge = getInputsToMerge(currComponent);
+        List<InputDefinition> prevInputs = prevComponent.safeGetInputs();
+        inputsValuesMergingBusinessLogic.mergeComponentInputs(prevInputs, inputsToMerge);
+        return inputsToMerge;
+    }
+
+    private List<InputDefinition> getPreviouslyDeclaredInputsToMerge(Component prevComponent, Component currComponent) {
+        log.debug("#getPreviouslyDeclaredInputsToMerge - getting inputs that were previously declared from previous component {} and setting on current component {}", prevComponent.getUniqueId(), currComponent.getUniqueId());
+        if (isEmpty(prevComponent.getInputs())) {
+            return emptyList();
+        }
+        Map<String, List<PropertyDataDefinition>> props = getProperties(currComponent);
+        return declaredInputsResolver.getPreviouslyDeclaredInputsToMerge(prevComponent, currComponent, props);
+    }
+
+    private ActionStatus updateInputs(String containerId, List<InputDefinition> inputsToUpdate) {
+        log.debug("#updateInputs - updating inputs for container {}", containerId);
+        return toscaOperationFacade.updateInputsToComponent(inputsToUpdate, containerId)
+                .either(updatedInputs -> ActionStatus.OK,
+                        componentsUtils::convertFromStorageResponse);
+    }
+
+}