add missing import

elastic · Mar 7, 2023 · d23d628 · d23d628
1 parent 70f14b9
commit d23d628
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 0 deletions.
diff --git a/x-pack/filebeat/input/cel/input.go b/x-pack/filebeat/input/cel/input.go
@@ -821,6 +821,7 @@ func newProgram(ctx context.Context, src, root string, client *http.Client, limi
 		lib.Collections(),
 		lib.Crypto(),
 		lib.JSON(nil),
+		lib.Strings(),
 		lib.Time(),
 		lib.Try(),
 		lib.File(mimetypes),

diff --git a/x-pack/filebeat/input/cel/input_test.go b/x-pack/filebeat/input/cel/input_test.go
@@ -294,6 +294,32 @@ int(has(state.cursor) && has(state.cursor.next) ? state.cursor.next : 0).as(inde
 			{"next": 3.0},
 		},
 	},
+	{
+		name: "strings_split",
+		config: map[string]interface{}{
+			"interval": 1,
+			"program": `
+{
+	"events": state.data.split(":").map(s,
+		{
+			"message": s
+		}
+	)
+}
+`,
+			"state": map[string]interface{}{
+				"data": "first:second:third",
+			},
+			"resource": map[string]interface{}{
+				"url": "",
+			},
+		},
+		want: []map[string]interface{}{
+			{"message": "first"},
+			{"message": "second"},
+			{"message": "third"},
+		},
+	},
 
 	// FS-based tests.
 	{