catalog-be/src/main/java/org/openecomp/sdc/be/components/merge/instance/ComponentInstanceInputsRedeclareHandler.java

   1 package org.openecomp.sdc.be.components.merge.instance;
   2
   3 import org.openecomp.sdc.be.components.merge.input.DeclaredInputsResolver;
   4 import org.openecomp.sdc.be.components.merge.input.InputsValuesMergingBusinessLogic;
   5 import org.openecomp.sdc.be.dao.api.ActionStatus;
   6 import org.openecomp.sdc.be.dao.utils.MapUtil;
   7 import org.openecomp.sdc.be.datatypes.elements.Annotation;
   8 import org.openecomp.sdc.be.datatypes.elements.PropertyDataDefinition;
   9 import org.openecomp.sdc.be.impl.ComponentsUtils;
  10 import org.openecomp.sdc.be.model.Component;
  11 import org.openecomp.sdc.be.model.InputDefinition;
  12 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  13 import org.openecomp.sdc.be.model.utils.ComponentUtilities;
  14 import org.openecomp.sdc.common.log.wrappers.Logger;
  15
  16 import java.util.Collection;
  17 import java.util.List;
  18 import java.util.Map;
  19 import java.util.stream.Stream;
  20
  21 import static java.util.Collections.singletonMap;
  22 import static java.util.stream.Collectors.toList;
  23 import static org.apache.commons.collections.CollectionUtils.isEmpty;
  24 import static org.openecomp.sdc.be.dao.utils.MapUtil.toMap;
  25
  26 @org.springframework.stereotype.Component
  27 public class ComponentInstanceInputsRedeclareHandler {
  28
  29     private static final Logger log = Logger.getLogger(ComponentInstanceInputsRedeclareHandler.class);
  30     private final DeclaredInputsResolver declaredInputsResolver;
  31     private final ToscaOperationFacade toscaOperationFacade;
  32     private final ComponentsUtils componentsUtils;
  33     private final InputsValuesMergingBusinessLogic inputsValuesMergingBusinessLogic;
  34
  35     public ComponentInstanceInputsRedeclareHandler(DeclaredInputsResolver declaredInputsResolver, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, InputsValuesMergingBusinessLogic inputsValuesMergingBusinessLogic) {
  36         this.declaredInputsResolver = declaredInputsResolver;
  37         this.toscaOperationFacade = toscaOperationFacade;
  38         this.componentsUtils = componentsUtils;
  39         this.inputsValuesMergingBusinessLogic = inputsValuesMergingBusinessLogic;
  40     }
  41
  42     ActionStatus redeclareComponentInputsForInstance(Component container, String newInstanceId, Component newInstanceOriginType, List<InputDefinition> oldInputs) {
  43         log.debug("#redeclareComponentInputsForInstance - getting inputs that were previously declared from instance {} and setting on current component {}", newInstanceId, container.getUniqueId());
  44         Map<String, List<PropertyDataDefinition>> allPropertiesForInstance = getAllGetPropertiesForInstance(container, newInstanceId);
  45         List<InputDefinition> previouslyDeclaredInputs = declaredInputsResolver.getPreviouslyDeclaredInputsToMerge(oldInputs, container, allPropertiesForInstance);
  46         inputsValuesMergingBusinessLogic.mergeComponentInputs(oldInputs, previouslyDeclaredInputs);
  47         updateInputsAnnotations(allPropertiesForInstance.get(newInstanceId), newInstanceOriginType, previouslyDeclaredInputs);
  48
  49         return updateInputs(container.getUniqueId(), previouslyDeclaredInputs);
  50     }
  51
  52     private void updateInputsAnnotations(List<PropertyDataDefinition> instanceProps, Component newInstanceOriginType, List<InputDefinition> previouslyDeclaredInputs) {
  53         Map<String, PropertyDataDefinition> instancePropsById = toMap(instanceProps, PropertyDataDefinition::getUniqueId);
  54         for (InputDefinition input : previouslyDeclaredInputs) {
  55             List<Annotation> originPropInputAnnotations = getAnnotationsFromOriginType(newInstanceOriginType, input.getPropertyId(), instancePropsById);
  56             if(!isEmpty(originPropInputAnnotations)){
  57                 input.setAnnotations(originPropInputAnnotations);
  58             }
  59         }
  60     }
  61
  62     private List<Annotation> getAnnotationsFromOriginType(Component originType, String propertyId, Map<String, PropertyDataDefinition> instancePropsById) {
  63         PropertyDataDefinition instanceProp = instancePropsById.get(propertyId);
  64         String originPropInputName = instanceProp.getName();
  65         return ComponentUtilities.getInputAnnotations(originType, originPropInputName);
  66     }
  67
  68     private Map<String, List<PropertyDataDefinition>> getAllGetPropertiesForInstance(Component newComponent, String instanceId) {
  69         List<PropertyDataDefinition> allInstanceProps = Stream.of(newComponent.safeGetComponentInstanceProperties(instanceId),
  70                 newComponent.safeGetComponentInstanceInput(instanceId))
  71                 .flatMap(Collection::stream)
  72                 .map(PropertyDataDefinition::new)
  73                 .collect(toList());
  74         return singletonMap(instanceId, allInstanceProps);
  75     }
  76
  77     private ActionStatus updateInputs(String containerId, List<InputDefinition> inputsToUpdate) {
  78         log.debug("#updateInputs - updating inputs for container {}", containerId);
  79         return toscaOperationFacade.updateInputsToComponent(inputsToUpdate, containerId)
  80                 .either(updatedInputs -> ActionStatus.OK,
  81                         componentsUtils::convertFromStorageResponse);
  82     }
  83
  84 }