1 files changed, 47 insertions, 0 deletions
diff --git a/dcaedt_be/src/main/java/org/onap/sdc/dcae/rule/editor/translators/ConditionGroupTranslator.java b/dcaedt_be/src/main/java/org/onap/sdc/dcae/rule/editor/translators/ConditionGroupTranslator.java
new file mode 100644
index 0000000..093c239
--- /dev/null
+++ b/dcaedt_be/src/main/java/org/onap/sdc/dcae/rule/editor/translators/ConditionGroupTranslator.java
@@ -0,0 +1,47 @@
+package org.onap.sdc.dcae.rule.editor.translators;
+
+import org.onap.sdc.dcae.composition.restmodels.ruleeditor.*;
+import org.onap.sdc.dcae.rule.editor.enums.ConditionTypeEnum;
+import org.onap.sdc.dcae.rule.editor.enums.OperatorTypeEnum;
+import org.onap.sdc.dcae.rule.editor.utils.ValidationUtils;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+public class ConditionGroupTranslator implements IRuleElementTranslator<ConditionGroup> {
+
+	private static ConditionGroupTranslator conditionGroupTranslator = new ConditionGroupTranslator();
+
+	public static ConditionGroupTranslator getInstance() {
+		return conditionGroupTranslator;
+	}
+
+	private ConditionGroupTranslator(){}
+
+	public Translation translateToHpJson(ConditionGroup conditionGroup) {
+		String clazz = ConditionTypeEnum.getTypeByName(conditionGroup.getType()).getFilterClass();
+		FiltersTranslation translation = new FiltersTranslation(clazz, conditionGroup.getChildren().stream()
+				.map(this::getTranslation)
+				.collect(Collectors.toList()));
+		flattenNestedFilters(translation, clazz);
+		return translation;
+	}
+
+
+	private IRuleElementTranslator getConditionTranslator(BaseCondition condition){
+		return condition instanceof ConditionGroup ? ConditionGroupTranslator.getInstance() :
+				ValidationUtils.validateNotEmpty(OperatorTypeEnum.getTypeByName(((Condition)condition).getOperator()).getModifiedType()) ? FieldConditionTranslator.getInstance() : ConditionTranslator.getInstance();
+	}
+
+	private Translation getTranslation(BaseCondition condition) {
+		return getConditionTranslator(condition).translateToHpJson(condition);
+	}
+
+	private void flattenNestedFilters(FiltersTranslation filtersTranslation, String clazz) {
+		Map<Boolean, List<Translation>> partitioned = filtersTranslation.filters.stream().collect(Collectors.partitioningBy(f -> clazz.equals(((ProcessorTranslation) f).clazz)));
+		filtersTranslation.filters.removeAll(partitioned.get(Boolean.TRUE));
+		filtersTranslation.filters.addAll(partitioned.get(Boolean.TRUE).stream().map(f -> ((FiltersTranslation) f).filters).flatMap(List::stream).collect(Collectors.toList()));
+	}
+
+}