fix(finder): fix seriesByTag arg t=~^q

go-graphite · Nov 3, 2023 · 3be28ba · 3be28ba
1 parent d38ebe6
commit 3be28ba
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 2 deletions.
diff --git a/finder/tagged_test.go b/finder/tagged_test.go
@@ -50,6 +50,10 @@ func TestTaggedWhere(t *testing.T) {
 		{"seriesByTag('name=~^cpu|mem')", 0, "Tag1 LIKE '\\\\_\\\\_name\\\\_\\\\_=%' AND match(Tag1, '^__name__=cpu|mem')", "Tag1 LIKE '\\\\_\\\\_name\\\\_\\\\_=%' AND match(Tag1, '^__name__=cpu|mem')", false},
 		{"seriesByTag('name=~^cpu|mem$')", 0, "Tag1 LIKE '\\\\_\\\\_name\\\\_\\\\_=%' AND match(Tag1, '^__name__=cpu|mem$')", "Tag1 LIKE '\\\\_\\\\_name\\\\_\\\\_=%' AND match(Tag1, '^__name__=cpu|mem$')", false},
 		{"seriesByTag('name=rps', 'key=~value')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x LIKE 'key=%' AND match(x, '^key=.*value'), Tags))", "", false},
+		// test for issue #244
+		{"seriesByTag('name=rps', 'key=~^value')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x LIKE 'key=value%' AND match(x, '^key=value'), Tags))", "", false},
+		{"seriesByTag('name=rps', 'key=~^value.*')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x LIKE 'key=value%' AND match(x, '^key=value.*'), Tags))", "", false},
+		{"seriesByTag('name=rps', 'key=~^valu[a-e]')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x LIKE 'key=valu%' AND match(x, '^key=valu[a-e]'), Tags))", "", false},
 		{"seriesByTag('name=rps', 'key=~^value$')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x='key=value', Tags))", "", false},
 		{"seriesByTag('name=rps', 'key=~hello.world')", 0, "(Tag1='__name__=rps') AND (arrayExists((x) -> x LIKE 'key=%' AND match(x, '^key=.*hello.world'), Tags))", "", false},
 		{`seriesByTag('cpu=cpu-total','host=~Vladimirs-MacBook-Pro\.local')`, 0, `(Tag1='cpu=cpu-total') AND (arrayExists((x) -> x LIKE 'host=%' AND match(x, '^host=.*Vladimirs-MacBook-Pro\\.local'), Tags))`, "", false},

diff --git a/pkg/where/match.go b/pkg/where/match.go
@@ -144,10 +144,12 @@ func TreeGlob(field string, query string) string {
 func ConcatMatchKV(key, value string) string {
 	startLine := value[0] == '^'
 	endLine := value[len(value)-1] == '$'
-	if startLine {
+	if startLine && endLine {
 		return key + opEq + value[1:]
 	} else if endLine {
-		return key + opEq + value + "\\\\%"
+		return key + opEq + "\\\\%" + value
+	} else if startLine {
+		return key + opEq + value[1:] + "\\\\%"
 	}
 	return key + opEq + "\\\\%" + value
 }

diff --git a/pkg/where/where_test.go b/pkg/where/where_test.go
@@ -63,6 +63,7 @@ func TestNonRegexpPrefix(t *testing.T) {
 		{`__name__=cpu.load`, `__name__=cpu`},
 		{`__name__=~(cpu|mem)`, `__name__=~`},
 		{`__name__=~cpu|mem`, `__name__=~`},
+		{`__name__=~^host`, `__name__=~`},
 	}
 
 	for _, test := range table {