Skip to content

Commit 7596bce

Browse files
committed
feat: enhance correlation rule
1 parent f958832 commit 7596bce

4 files changed

Lines changed: 2 additions & 39 deletions

File tree

backend/src/main/java/com/park/utmstack/domain/correlation/rules/UtmCorrelationRules.java

Lines changed: 1 addition & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -87,16 +87,8 @@ public class UtmCorrelationRules implements Serializable {
8787
@Setter(AccessLevel.NONE)
8888
private List<String> ruleReferences;
8989

90-
@JsonIgnore
9190
@Column(name = "rule_definition_def", nullable = false)
92-
private String ruleDefinitionDef;
93-
94-
@Transient
95-
@JsonSerialize
96-
@JsonDeserialize
97-
@Getter(AccessLevel.NONE)
98-
@Setter(AccessLevel.NONE)
99-
private RuleDefinition ruleDefinition;
91+
private String ruleDefinition;
10092

10193
@Column(name = "rule_last_update")
10294
private Instant ruleLastUpdate;
@@ -165,22 +157,6 @@ public void setRuleReferences(List<String> ruleReferences) throws UtmSerializati
165157
this.ruleReferences = ruleReferences;
166158
}
167159

168-
169-
public RuleDefinition getRuleDefinition() throws UtmSerializationException {
170-
if (StringUtils.hasText(ruleDefinitionDef))
171-
ruleDefinition = UtilSerializer.jsonDeserialize(RuleDefinition.class, ruleDefinitionDef);
172-
return ruleDefinition;
173-
}
174-
175-
public void setRuleDefinition(RuleDefinition ruleDefinition) throws UtmSerializationException {
176-
if (ruleDefinition == null)
177-
this.ruleDefinitionDef = null;
178-
else
179-
this.ruleDefinitionDef = UtilSerializer.jsonSerialize(ruleDefinition);
180-
181-
this.ruleDefinition = ruleDefinition;
182-
}
183-
184160
public List<SearchRequest> getAfterEvents() throws UtmSerializationException {
185161
if (StringUtils.hasText(afterEventsDef))
186162
afterEvents = UtilSerializer.jsonDeserializeList(SearchRequest.class, afterEventsDef);

backend/src/main/java/com/park/utmstack/service/dto/correlation/UtmCorrelationRulesDTO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public class UtmCorrelationRulesDTO implements Serializable {
5252
@NotEmpty
5353
private Set<UtmDataTypes> dataTypes;
5454

55-
private RuleDefinition definition;
55+
private String definition;
5656

5757
private Boolean systemOwner;
5858

backend/src/main/java/com/park/utmstack/service/dto/correlation/validators/CorrelationRuleValidator.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,6 @@ public void validate(Object target, Errors errors) {
2121
if (dto.getDataTypes() == null || dto.getDataTypes().isEmpty()) {
2222
errors.rejectValue("dataTypes", "DataTypesEmpty", "The rule must have at least one data type.");
2323
}
24-
25-
if (dto.getDefinition() == null || dto.getDefinition().getRuleVariables().isEmpty()) {
26-
errors.rejectValue("definition.ruleVariables", "RuleVariablesEmpty", "The rule must have at least one rule variable.");
27-
}
28-
29-
if (dto.getDefinition() != null && !StringUtils.hasText(dto.getDefinition().getRuleExpression())) {
30-
errors.rejectValue("definition.ruleExpression", "RuleExpressionEmpty", "The rule's expression must not be empty.");
31-
}
3224
}
3325
}
3426

backend/src/main/java/com/park/utmstack/web/rest/correlation/rules/UtmCorrelationRulesResource.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -140,11 +140,6 @@ public ResponseEntity<Void> updateCorrelationRule(@Valid @RequestBody UtmCorrela
140140
try {
141141
if (correlationRulesDTO.getDefinition() == null) {
142142
throw new BadRequestException(ctx + ": The rule's definition field can't be null.");
143-
} else {
144-
if (correlationRulesDTO.getDefinition().getRuleVariables().isEmpty()
145-
|| !StringUtils.hasText(correlationRulesDTO.getDefinition().getRuleExpression())) {
146-
throw new BadRequestException(ctx + ": The rule's definition variables or expression field is null or empty, please check.");
147-
}
148143
}
149144
rulesService.updateRule(this.utmCorrelationRulesMapper.toEntity(correlationRulesDTO));
150145
return ResponseEntity.noContent().build();

0 commit comments

Comments
 (0)