1 package org.openecomp.sdc.asdctool.impl.migration.v1707.jsonmodel;
4 import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
5 import org.openecomp.sdc.be.model.ComponentInstanceProperty;
6 import org.openecomp.sdc.be.model.Service;
7 import org.openecomp.sdc.be.model.operations.api.IServiceOperation;
8 import org.openecomp.sdc.be.model.operations.migration.MigrationMalformedDataLogger;
9 import org.slf4j.Logger;
10 import org.slf4j.LoggerFactory;
12 import javax.annotation.Resource;
13 import java.util.ArrayList;
14 import java.util.List;
16 import java.util.stream.Collectors;
18 public class ServicesMigration extends ComponentMigration<Service> {
20 private static final String DEFAULT_CONFORMANCE_LEVEL = "0.0";
21 private static Logger LOGGER = LoggerFactory.getLogger(ServicesMigration.class);
23 @Resource(name = "service-operation")
24 private IServiceOperation serviceOperation;
26 @Resource(name = "service-version-migration")
27 private VersionMigration<Service> versionMigration;
30 public String description() {
31 return "migrate services";
35 Either<List<Service>, ?> getElementsToMigrate() {
36 return serviceOperation.getAll();
40 boolean save(Service element) {
41 MigrationMalformedDataLogger.logIfServiceUsingMalformedVfs(element);
42 filterOutDuplicatePropsAndAttrs(element);
43 element.setConformanceLevel(DEFAULT_CONFORMANCE_LEVEL);
44 requirementsCapabilitiesMigrationService.overrideInstanceCapabilitiesRequirements(element);
45 return super.save(element);
49 boolean doPostSaveOperation(Service element) {
50 return element.getComponentInstances() == null ||
51 (requirementsCapabilitiesMigrationService.associateFulfilledRequirements(element, NodeTypeEnum.Service) &&
52 requirementsCapabilitiesMigrationService.associateFulfilledCapabilities(element, NodeTypeEnum.Service));
56 boolean doPostMigrateOperation(List<Service> elements) {
57 LOGGER.info("migrating services versions");
58 return versionMigration.buildComponentsVersionChain(elements);
61 private void filterOutDuplicatePropsAndAttrs(Service element) {
62 if (element.getComponentInstancesProperties() != null) {
63 removeDuplicatedNameProperties(element);
65 if (element.getComponentInstancesAttributes() != null) {
66 removeDuplicatedNameAttributes(element);
70 private void removeDuplicatedNameProperties(Service service) {
71 Map<String, List<ComponentInstanceProperty>> componentInstancesProperties = service.getComponentInstancesProperties();
72 componentInstancesProperties.forEach((uid, properties) -> {
73 componentInstancesProperties.put(uid, getUniquedNamePropertyList(service, properties));
77 private List<ComponentInstanceProperty> getUniquedNamePropertyList(Service service, List<ComponentInstanceProperty> properties) {
78 if (properties == null) {
81 List<ComponentInstanceProperty> uniqueNameProperties = new ArrayList<>();
82 Map<String, List<ComponentInstanceProperty>> collect = properties.stream().collect(Collectors.groupingBy(ComponentInstanceProperty::getName));
83 collect.forEach((name, duplicatedProperties) -> {
84 logServiceDuplicateProperties(service, name, duplicatedProperties);
85 uniqueNameProperties.add(duplicatedProperties.get(0));
87 return uniqueNameProperties;
90 private void logServiceDuplicateProperties(Service service, String name, List<ComponentInstanceProperty> duplicatedProperties) {
91 if (duplicatedProperties.size() > 1) {
92 LOGGER.debug("service {} with id {} has instance {} with duplicate property {}", service.getName(), service.getUniqueId(), duplicatedProperties.get(0).getUniqueId(), name);
96 private void removeDuplicatedNameAttributes(Service service) {
97 Map<String, List<ComponentInstanceProperty>> componentInstancesAttributes = service.getComponentInstancesAttributes();
98 componentInstancesAttributes.forEach((uid, attributes) -> {
99 componentInstancesAttributes.put(uid, getUniquedNameAttributeList(service, attributes));
103 private List<ComponentInstanceProperty> getUniquedNameAttributeList(Service service, List<ComponentInstanceProperty> attributes) {
104 if (attributes == null) {
107 List<ComponentInstanceProperty> uniqueNameAttributes = new ArrayList<>();
108 Map<String, List<ComponentInstanceProperty>> collect = attributes.stream().collect(Collectors.groupingBy(ComponentInstanceProperty::getName));
109 collect.forEach((name, duplicatedAttributess) -> {
110 logServiceMalformedAttributes(service, name, duplicatedAttributess);
111 uniqueNameAttributes.add(duplicatedAttributess.get(0));
113 return uniqueNameAttributes;
116 private void logServiceMalformedAttributes(Service service, String name, List<ComponentInstanceProperty> duplicatedAttributess) {
117 if (duplicatedAttributess.size() > 1) {
118 MigrationMalformedDataLogger.logMalformedDataMsg(String.format("service %s with id %s has instance %s with duplicate attribute %s",
119 service.getName(), service.getUniqueId(), duplicatedAttributess.get(0).getUniqueId(), name));
123 // private void filterOutVFInstanceAttrs(Service element, List<String> vfInstancesIds) {
124 // Map<String, List<ComponentInstanceAttribute>> componentInstancesAttributes = element.getComponentInstancesAttributes();
125 // if (componentInstancesAttributes != null) {
126 // element.setComponentInstancesAttributes(filterOutVFInstanceAttributes(componentInstancesAttributes, vfInstancesIds));
130 // private void filterOutVFInstacnecProps(Service element, List<String> vfInstancesIds) {
131 // Map<String, List<ComponentInstanceProperty>> componentInstancesProperties = element.getComponentInstancesProperties();
132 // if (componentInstancesProperties != null) {
133 // element.setComponentInstancesProperties(filterOutVFInstanceProperties(componentInstancesProperties, vfInstancesIds));
137 // private Map<String, List<ComponentInstanceProperty>> filterOutVFInstanceProperties(Map<String, List<ComponentInstanceProperty>> instances, List<String> vfInstanceIds) {
138 // return instances.entrySet()
140 // .filter(entry -> !vfInstanceIds.contains(entry.getKey()))
141 // .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
144 // private Map<String, List<ComponentInstanceAttribute>> filterOutVFInstanceAttributes(Map<String, List<ComponentInstanceAttribute>> instances, List<String> vfInstanceIds) {
145 // return instances.entrySet()
147 // .filter(entry -> !vfInstanceIds.contains(entry.getKey()))
148 // .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));