1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
package org.openecomp.sdc.asdctool.impl.migration.v1707.jsonmodel;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.openecomp.sdc.be.datatypes.enums.NodeTypeEnum;
import org.openecomp.sdc.be.model.ComponentInstanceProperty;
import org.openecomp.sdc.be.model.Service;
import org.openecomp.sdc.be.model.operations.api.IServiceOperation;
import org.openecomp.sdc.be.model.operations.migration.MigrationMalformedDataLogger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import fj.data.Either;
public class ServicesMigration extends ComponentMigration<Service> {
private static final String DEFAULT_CONFORMANCE_LEVEL = "0.0";
private static Logger LOGGER = LoggerFactory.getLogger(ServicesMigration.class);
@Resource(name = "service-operation")
private IServiceOperation serviceOperation;
@Resource(name = "service-version-migration")
private VersionMigration<Service> versionMigration;
@Override
public String description() {
return "migrate services";
}
@Override
Either<List<Service>, ?> getElementsToMigrate() {
return serviceOperation.getAll();
}
@Override
boolean save(Service element) {
MigrationMalformedDataLogger.logIfServiceUsingMalformedVfs(element);
filterOutDuplicatePropsAndAttrs(element);
element.setConformanceLevel(DEFAULT_CONFORMANCE_LEVEL);
requirementsCapabilitiesMigrationService.overrideInstanceCapabilitiesRequirements(element);
return super.save(element);
}
@Override
boolean doPostSaveOperation(Service element) {
return element.getComponentInstances() == null ||
(requirementsCapabilitiesMigrationService.associateFulfilledRequirements(element, NodeTypeEnum.Service) &&
requirementsCapabilitiesMigrationService.associateFulfilledCapabilities(element, NodeTypeEnum.Service));
}
@Override
boolean doPostMigrateOperation(List<Service> elements) {
LOGGER.info("migrating services versions");
return versionMigration.buildComponentsVersionChain(elements);
}
@Override
void doPreMigrationOperation(List<Service> elements) {
super.doPreMigrationOperation(elements);
setMissingTemplateInfo(elements);
}
private void filterOutDuplicatePropsAndAttrs(Service element) {
if (element.getComponentInstancesProperties() != null) {
removeDuplicatedNameProperties(element);
}
if (element.getComponentInstancesAttributes() != null) {
removeDuplicatedNameAttributes(element);
}
}
private void removeDuplicatedNameProperties(Service service) {
Map<String, List<ComponentInstanceProperty>> componentInstancesProperties = service.getComponentInstancesProperties();
componentInstancesProperties.forEach((uid, properties) -> {
componentInstancesProperties.put(uid, getUniquedNamePropertyList(service, properties));
});
}
private List<ComponentInstanceProperty> getUniquedNamePropertyList(Service service, List<ComponentInstanceProperty> properties) {
if (properties == null) {
return null;
}
List<ComponentInstanceProperty> uniqueNameProperties = new ArrayList<>();
Map<String, List<ComponentInstanceProperty>> collect = properties.stream().collect(Collectors.groupingBy(ComponentInstanceProperty::getName));
collect.forEach((name, duplicatedProperties) -> {
logServiceDuplicateProperties(service, name, duplicatedProperties);
uniqueNameProperties.add(duplicatedProperties.get(0));
});
return uniqueNameProperties;
}
private void logServiceDuplicateProperties(Service service, String name, List<ComponentInstanceProperty> duplicatedProperties) {
if (duplicatedProperties.size() > 1) {
LOGGER.debug("service {} with id {} has instance {} with duplicate property {}", service.getName(), service.getUniqueId(), duplicatedProperties.get(0).getUniqueId(), name);
}
}
private void removeDuplicatedNameAttributes(Service service) {
Map<String, List<ComponentInstanceProperty>> componentInstancesAttributes = service.getComponentInstancesAttributes();
componentInstancesAttributes.forEach((uid, attributes) -> {
componentInstancesAttributes.put(uid, getUniquedNameAttributeList(service, attributes));
});
}
private List<ComponentInstanceProperty> getUniquedNameAttributeList(Service service, List<ComponentInstanceProperty> attributes) {
if (attributes == null) {
return null;
}
List<ComponentInstanceProperty> uniqueNameAttributes = new ArrayList<>();
Map<String, List<ComponentInstanceProperty>> collect = attributes.stream().collect(Collectors.groupingBy(ComponentInstanceProperty::getName));
collect.forEach((name, duplicatedAttributess) -> {
logServiceMalformedAttributes(service, name, duplicatedAttributess);
uniqueNameAttributes.add(duplicatedAttributess.get(0));
});
return uniqueNameAttributes;
}
private void logServiceMalformedAttributes(Service service, String name, List<ComponentInstanceProperty> duplicatedAttributess) {
if (duplicatedAttributess.size() > 1) {
MigrationMalformedDataLogger.logMalformedDataMsg(String.format("service %s with id %s has instance %s with duplicate attribute %s",
service.getName(), service.getUniqueId(), duplicatedAttributess.get(0).getUniqueId(), name));
}
}
// private void filterOutVFInstanceAttrs(Service element, List<String> vfInstancesIds) {
// Map<String, List<ComponentInstanceAttribute>> componentInstancesAttributes = element.getComponentInstancesAttributes();
// if (componentInstancesAttributes != null) {
// element.setComponentInstancesAttributes(filterOutVFInstanceAttributes(componentInstancesAttributes, vfInstancesIds));
// }
// }
//
// private void filterOutVFInstacnecProps(Service element, List<String> vfInstancesIds) {
// Map<String, List<ComponentInstanceProperty>> componentInstancesProperties = element.getComponentInstancesProperties();
// if (componentInstancesProperties != null) {
// element.setComponentInstancesProperties(filterOutVFInstanceProperties(componentInstancesProperties, vfInstancesIds));
// }
// }
//
// private Map<String, List<ComponentInstanceProperty>> filterOutVFInstanceProperties(Map<String, List<ComponentInstanceProperty>> instances, List<String> vfInstanceIds) {
// return instances.entrySet()
// .stream()
// .filter(entry -> !vfInstanceIds.contains(entry.getKey()))
// .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
// }
//
// private Map<String, List<ComponentInstanceAttribute>> filterOutVFInstanceAttributes(Map<String, List<ComponentInstanceAttribute>> instances, List<String> vfInstanceIds) {
// return instances.entrySet()
// .stream()
// .filter(entry -> !vfInstanceIds.contains(entry.getKey()))
// .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
// }
}
|
