No need to evaluate custom expression if source is http_rby

vincent-pochet · vincent-pochet · commit 21def8fba1c0 · 2025-03-21T14:41:50.000+01:00
diff --git a/api b/api
@@ -1 +1 @@
-Subproject commit 6a315022405d910ee0a0fe15e4c918baab6597d5
+Subproject commit 110d285dcbb4888e2e2f3477511efeb0ba0a13b5
diff --git a/events-processor/processors/events.go b/events-processor/processors/events.go
@@ -80,9 +80,11 @@ func processEvent(event *models.Event) utils.Result[*models.EnrichedEvent] {
 	}
 	sub := subResult.Value()
 
-	expressionResult := evaluateExpression(enrichedEvent, bm)
-	if expressionResult.Failure() {
-		return failedResult(expressionResult, "evaluate_expression", "Error evaluating custom expression")
+	if event.Source != models.HTTP_RUBY {
+		expressionResult := evaluateExpression(enrichedEvent, bm)
+		if expressionResult.Failure() {
+			return failedResult(expressionResult, "evaluate_expression", "Error evaluating custom expression")
+		}
 	}
 
 	var value = fmt.Sprintf("%v", event.Properties[bm.FieldName])

Original file line number	Diff line number	Diff line change
`@@ -80,9 +80,11 @@ func processEvent(event models.Event) utils.Result[models.EnrichedEvent] {`
`80`	`80`	`}`
`81`	`81`	`sub := subResult.Value()`
`82`	`82`
`83`		`- expressionResult := evaluateExpression(enrichedEvent, bm)`
`84`		`- if expressionResult.Failure() {`
`85`		`- return failedResult(expressionResult, "evaluate_expression", "Error evaluating custom expression")`
	`83`	`+ if event.Source != models.HTTP_RUBY {`
	`84`	`+ expressionResult := evaluateExpression(enrichedEvent, bm)`
	`85`	`+ if expressionResult.Failure() {`
	`86`	`+ return failedResult(expressionResult, "evaluate_expression", "Error evaluating custom expression")`
	`87`	`+ }`
`86`	`88`	`}`
`87`	`89`
`88`	`90`	`var value = fmt.Sprintf("%v", event.Properties[bm.FieldName])`