blob: 06f0bab65de3f1b35b999afea4a8cb59da9de503 (
plain)
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
|
package org.onap.sdc.dcae.rule.editor.translators;
import org.onap.sdc.dcae.composition.restmodels.ruleeditor.MappingRules;
import org.onap.sdc.dcae.composition.restmodels.ruleeditor.Rule;
import org.onap.sdc.dcae.rule.editor.utils.ValidationUtils;
import java.util.*;
import java.util.stream.Collectors;
public class MappingRulesTranslator implements IRuleElementTranslator<MappingRules> {
private static MappingRulesTranslator mappingRulesTranslator = new MappingRulesTranslator();
public static MappingRulesTranslator getInstance() {
return mappingRulesTranslator;
}
private MappingRulesTranslator() {
}
private RuleTranslator ruleTranslator = RuleTranslator.getInstance();
public Object translateToHpJson(MappingRules mappingRules) {
return new MappingRulesTranslation(mappingRules);
}
private List<Object> getPhaseTranslation(Collection<Rule> currentPhase) {
return currentPhase.stream().map(ruleTranslator::translateToHpJson).collect(Collectors.toList());
}
private class MappingRulesTranslation {
private List<Object> processing;
private MappingRulesTranslation(MappingRules mappingRules) {
String firstRunPhase;
// single phase
if(mappingRules.getRules().values().stream().noneMatch(r -> ValidationUtils.validateNotEmpty(r.getGroupId()))) {
processing = getPhaseTranslation(mappingRules.getRules().values());
firstRunPhase = mappingRules.getRules().values().iterator().next().getPhase();
} else {
// 1810 US427299 phase grouping - support user defined phase names
Map<String, List<Rule>> reorderByGroupId = mappingRules.getRules().values().stream().collect(Collectors.groupingBy(Rule::getGroupId, LinkedHashMap::new, Collectors.toList()));
List<String> phaseNames = new ArrayList<>();
processing = new ArrayList<>();
reorderByGroupId.forEach((k,v) -> {
String currentPhaseName = v.get(0).getPhase();
// if phase name already triggered no need to call RunPhase processor again.
if(!processing.isEmpty() && !phaseNames.contains(currentPhaseName)) {
((RuleTranslation)processing.get(processing.size()-1)).processors.add(new RunPhaseProcessorsTranslation(currentPhaseName));
}
processing.addAll(getPhaseTranslation(v));
phaseNames.add(currentPhaseName);
});
firstRunPhase = phaseNames.get(0);
}
//hardcoded entry point processor - added as a phase unit
processing.add(0, ruleTranslator.entryPhaseTranslation(mappingRules.getEntryPhase(), firstRunPhase, mappingRules.getFilter()));
//hardcoded map_publish processor - added as processor unit to last phase unit
((RuleTranslation)processing.get(processing.size()-1)).processors.add(new RunPhaseProcessorsTranslation(mappingRules.getPublishPhase()));
}
}
}
|
