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

   1 package org.openecomp.sdc.be.components.merge.instance;
   2
   3 import fj.data.Either;
   4 import org.apache.commons.collections.CollectionUtils;
   5 import org.openecomp.sdc.be.components.merge.VspComponentsMergeCommand;
   6 import org.openecomp.sdc.be.components.merge.capability.CapabilityResolver;
   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.dao.utils.MapUtil;
  10 import org.openecomp.sdc.be.impl.ComponentsUtils;
  11 import org.openecomp.sdc.be.model.CapabilityDefinition;
  12 import org.openecomp.sdc.be.model.Component;
  13 import org.openecomp.sdc.be.model.ComponentInstance;
  14 import org.openecomp.sdc.be.model.ComponentParametersView;
  15 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
  16 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  17 import org.openecomp.sdc.common.log.wrappers.Logger;
  18 import org.springframework.core.annotation.Order;
  19
  20 import java.util.List;
  21 import java.util.Map;
  22
  23 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;
  24
  25 @org.springframework.stereotype.Component
  26 @Order(ANY_ORDER_COMMAND)
  27 public class ComponentCapabilitiesPropertiesMergeBL implements VspComponentsMergeCommand {
  28
  29     private static final Logger log = Logger.getLogger(ComponentCapabilitiesPropertiesMergeBL.class);
  30
  31     private final DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic;
  32     private final ToscaOperationFacade toscaOperationFacade;
  33     private final ComponentsUtils componentsUtils;
  34     private final CapabilityResolver capabilityResolver;
  35
  36     public ComponentCapabilitiesPropertiesMergeBL(DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, CapabilityResolver capabilityResolver) {
  37         this.dataDefinitionsValuesMergingBusinessLogic = dataDefinitionsValuesMergingBusinessLogic;
  38         this.toscaOperationFacade = toscaOperationFacade;
  39         this.componentsUtils = componentsUtils;
  40         this.capabilityResolver = capabilityResolver;
  41     }
  42
  43     @Override
  44     public String description() {
  45         return "merge component instances capabilities properties";
  46     }
  47
  48     @Override
  49     public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
  50         StorageOperationStatus mergeStatus = getCmptWithCapabilitiesProps(currentComponent.getUniqueId())
  51                 .either(currCmptWithCap -> mergeCmptCalculatedCapabilitiesProperties(prevComponent, currCmptWithCap),
  52                         err -> err);
  53         return componentsUtils.convertFromStorageResponse(mergeStatus);
  54     }
  55
  56     public ActionStatus mergeComponentInstanceCapabilities(Component currentComponent, Component origInstanceCmpt, String instanceId, List<CapabilityDefinition> prevInstanceCapabilities) {
  57         if (CollectionUtils.isEmpty(prevInstanceCapabilities)) {
  58             return ActionStatus.OK;
  59         }
  60         Map<CapabilityDefinition, CapabilityDefinition> oldToNewCap = capabilityResolver.resolvePrevCapToNewCapability(currentComponent, origInstanceCmpt, instanceId, prevInstanceCapabilities);
  61         oldToNewCap.forEach(this::mergeCapabilityProperties);
  62         StorageOperationStatus updateStatus = updateInstanceCapabilitiesProperties(currentComponent, instanceId);
  63         return componentsUtils.convertFromStorageResponse(updateStatus);
  64     }
  65
  66     private StorageOperationStatus mergeCmptCalculatedCapabilitiesProperties(Component prevComponent, Component currentComponent) {
  67         List<ComponentInstance> prevInstances = prevComponent.getComponentInstances();
  68         if (prevInstances == null) {
  69             return StorageOperationStatus.OK;
  70         }
  71         prevInstances.forEach(prevInstance -> mergeInstanceCapabilities(prevInstance, currentComponent));
  72         return updateComponentCapabilitiesProperties(currentComponent);
  73     }
  74
  75     private void mergeInstanceCapabilities(ComponentInstance prevInstance, Component currComponent) {
  76         ComponentInstance currInstance = MapUtil.toMap(currComponent.getComponentInstances(), ComponentInstance::getName).get(prevInstance.getName());
  77         Map<CapabilityDefinition, CapabilityDefinition> oldToNewCapabilities = capabilityResolver.resolvePrevCapIdToNewCapability(prevInstance, currInstance);
  78         oldToNewCapabilities.forEach(this::mergeCapabilityProperties);
  79     }
  80
  81     private void mergeCapabilityProperties(CapabilityDefinition prevCapability, CapabilityDefinition currCapability) {
  82         dataDefinitionsValuesMergingBusinessLogic.mergeInstanceDataDefinitions(prevCapability.getProperties(), currCapability.getProperties());
  83     }
  84
  85     private StorageOperationStatus updateComponentCapabilitiesProperties(Component currComponent) {
  86         return toscaOperationFacade.updateComponentCalculatedCapabilitiesProperties(currComponent);
  87     }
  88
  89     private StorageOperationStatus updateInstanceCapabilitiesProperties(Component currComponent, String instanceId) {
  90         return toscaOperationFacade.updateComponentInstanceCapabilityProperties(currComponent, instanceId);
  91     }
  92
  93     private Either<Component, StorageOperationStatus> getCmptWithCapabilitiesProps(String cmptId) {
  94         ComponentParametersView propertiesCapabilitiesFilter = new ComponentParametersView(true);
  95         propertiesCapabilitiesFilter.setIgnoreCapabiltyProperties(false);
  96         propertiesCapabilitiesFilter.setIgnoreComponentInstances(false);
  97         propertiesCapabilitiesFilter.setIgnoreCapabilities(false);
  98         return toscaOperationFacade.getToscaElement(cmptId, propertiesCapabilitiesFilter)
  99                 .right()
 100                 .map(err -> {
 101                    log.debug("failed to fetch cmpt {} with properties capabilities. status: {}", cmptId, err);
 102                    return err;
 103                 });
 104
 105     }
 106
 107 }