1 package org.openecomp.sdc.be.components.merge.instance;
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.jsonjanusgraph.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;
20 import java.util.List;
23 import static org.openecomp.sdc.be.components.merge.resource.ResourceDataMergeBusinessLogic.ANY_ORDER_COMMAND;
25 @org.springframework.stereotype.Component
26 @Order(ANY_ORDER_COMMAND)
27 public class ComponentCapabilitiesPropertiesMergeBL implements VspComponentsMergeCommand {
29 private static final Logger log = Logger.getLogger(ComponentCapabilitiesPropertiesMergeBL.class);
31 private final DataDefinitionsValuesMergingBusinessLogic dataDefinitionsValuesMergingBusinessLogic;
32 private final ToscaOperationFacade toscaOperationFacade;
33 private final ComponentsUtils componentsUtils;
34 private final CapabilityResolver capabilityResolver;
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;
44 public String description() {
45 return "merge component instances capabilities properties";
49 public ActionStatus mergeComponents(Component prevComponent, Component currentComponent) {
50 StorageOperationStatus mergeStatus = getCmptWithCapabilitiesProps(currentComponent.getUniqueId())
51 .either(currCmptWithCap -> mergeCmptCalculatedCapabilitiesProperties(prevComponent, currCmptWithCap),
53 return componentsUtils.convertFromStorageResponse(mergeStatus);
56 public ActionStatus mergeComponentInstanceCapabilities(Component currentComponent, Component origInstanceCmpt, String instanceId, List<CapabilityDefinition> prevInstanceCapabilities) {
57 if (CollectionUtils.isEmpty(prevInstanceCapabilities)) {
58 return ActionStatus.OK;
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);
66 private StorageOperationStatus mergeCmptCalculatedCapabilitiesProperties(Component prevComponent, Component currentComponent) {
67 List<ComponentInstance> prevInstances = prevComponent.getComponentInstances();
68 if (prevInstances == null) {
69 return StorageOperationStatus.OK;
71 prevInstances.forEach(prevInstance -> mergeInstanceCapabilities(prevInstance, currentComponent));
72 return updateComponentCapabilitiesProperties(currentComponent);
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);
81 private void mergeCapabilityProperties(CapabilityDefinition prevCapability, CapabilityDefinition currCapability) {
82 dataDefinitionsValuesMergingBusinessLogic.mergeInstanceDataDefinitions(prevCapability.getProperties(), currCapability.getProperties());
85 private StorageOperationStatus updateComponentCapabilitiesProperties(Component currComponent) {
86 return toscaOperationFacade.updateComponentCalculatedCapabilitiesProperties(currComponent);
89 private StorageOperationStatus updateInstanceCapabilitiesProperties(Component currComponent, String instanceId) {
90 return toscaOperationFacade.updateComponentInstanceCapabilityProperties(currComponent, instanceId);
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)
101 log.debug("failed to fetch cmpt {} with properties capabilities. status: {}", cmptId, err);