1 package org.openecomp.sdc.be.components.merge.instance;
4 import org.apache.commons.collections.CollectionUtils;
5 import org.openecomp.sdc.be.components.merge.capability.CapabilityResolver;
6 import org.openecomp.sdc.be.components.merge.property.DataDefinitionsValuesMergingBusinessLogic;
7 import org.openecomp.sdc.be.dao.api.ActionStatus;
8 import org.openecomp.sdc.be.dao.utils.MapUtil;
9 import org.openecomp.sdc.be.impl.ComponentsUtils;
10 import org.openecomp.sdc.be.model.CapabilityDefinition;
11 import org.openecomp.sdc.be.model.Component;
12 import org.openecomp.sdc.be.model.ComponentInstance;
13 import org.openecomp.sdc.be.model.ComponentParametersView;
14 import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade;
15 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
16 import org.slf4j.Logger;
17 import org.slf4j.LoggerFactory;
19 import java.util.List;
22 @org.springframework.stereotype.Component
23 public class ComponentCapabilitiesPropertiesMergeBL implements ComponentsMergeCommand {
25 private static final Logger LOGGER = LoggerFactory.getLogger(ComponentCapabilitiesPropertiesMergeBL.class);
27 private DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic;
28 private ToscaOperationFacade toscaOperationFacade;
29 private ComponentsUtils componentsUtils;
30 private CapabilityResolver capabilityResolver;
32 public ComponentCapabilitiesPropertiesMergeBL(DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic, ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils, CapabilityResolver capabilityResolver) {
33 this.dataDefinitionsValuesMergingBusinessLogic = dataDefinitionsValuesMergingBusinessLogic;
34 this.toscaOperationFacade = toscaOperationFacade;
35 this.componentsUtils = componentsUtils;
36 this.capabilityResolver = capabilityResolver;
40 public String description() {
41 return "merge component instances capabilities properties";
45 public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
46 StorageOperationStatus mergeStatus = getCmptWithCapabilitiesProps(currentComponent.getUniqueId())
47 .either(currCmptWithCap -> mergeCmptCalculatedCapabilitiesProperties(prevComponent, currCmptWithCap),
49 return componentsUtils.convertFromStorageResponse(mergeStatus);
52 public ActionStatus mergeComponentInstanceCapabilities(Component currentComponent, Component origInstanceCmpt, String instanceId, List<CapabilityDefinition> prevInstanceCapabilities) {
53 if (CollectionUtils.isEmpty(prevInstanceCapabilities)) {
54 return ActionStatus.OK;
56 Map<CapabilityDefinition, CapabilityDefinition> oldToNewCap = capabilityResolver.resolvePrevCapToNewCapability(currentComponent, origInstanceCmpt, instanceId, prevInstanceCapabilities);
57 oldToNewCap.forEach(this::mergeCapabilityProperties);
58 StorageOperationStatus updateStatus = updateInstanceCapabilitiesProperties(currentComponent, instanceId);
59 return componentsUtils.convertFromStorageResponse(updateStatus);
62 private StorageOperationStatus mergeCmptCalculatedCapabilitiesProperties(Component prevComponent, Component currentComponent) {
63 List<ComponentInstance> prevInstances = prevComponent.getComponentInstances();
64 if (prevInstances == null) {
65 return StorageOperationStatus.OK;
67 prevInstances.forEach(prevInstance -> mergeInstanceCapabilities(prevInstance, currentComponent));
68 return updateComponentCapabilitiesProperties(currentComponent);
71 private void mergeInstanceCapabilities(ComponentInstance prevInstance, Component currComponent) {
72 ComponentInstance currInstance = MapUtil.toMap(currComponent.getComponentInstances(), ComponentInstance::getName).get(prevInstance.getName());
73 Map<CapabilityDefinition, CapabilityDefinition> oldToNewCapabilities = capabilityResolver.resolvePrevCapIdToNewCapability(prevInstance, currInstance);
74 oldToNewCapabilities.forEach(this::mergeCapabilityProperties);
77 private void mergeCapabilityProperties(CapabilityDefinition prevCapability, CapabilityDefinition currCapability) {
78 dataDefinitionsValuesMergingBusinessLogic.mergeInstanceDataDefinitions(prevCapability.getProperties(), currCapability.getProperties());
81 private StorageOperationStatus updateComponentCapabilitiesProperties(Component currComponent) {
82 return toscaOperationFacade.updateComponentCalculatedCapabilitiesProperties(currComponent);
85 private StorageOperationStatus updateInstanceCapabilitiesProperties(Component currComponent, String instanceId) {
86 return toscaOperationFacade.updateComponentInstanceCapabilityProperties(currComponent, instanceId);
89 private Either<Component, StorageOperationStatus> getCmptWithCapabilitiesProps(String cmptId) {
90 ComponentParametersView propertiesCapabilitiesFilter = new ComponentParametersView(true);
91 propertiesCapabilitiesFilter.setIgnoreCapabiltyProperties(false);
92 propertiesCapabilitiesFilter.setIgnoreComponentInstances(false);
93 propertiesCapabilitiesFilter.setIgnoreCapabilities(false);
94 return toscaOperationFacade.getToscaElement(cmptId, propertiesCapabilitiesFilter)
97 LOGGER.debug("failed to fetch cmpt {} with properties capabilities. status: {}", cmptId, err);