summaryrefslogtreecommitdiff
path: root/internal/mapr/server/parsername_test.go
blob: cce1a459a422d9ea25efafab1927d93bc1939706 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package server

import (
	"testing"

	"github.com/mimecast/dtail/internal/mapr"
)

// TestResolveParserName locks the log-format selection rules that decide which
// parser (and therefore which fields) a mapr query gets. These rules are the
// root cause of a common surprise: a query without a "from TABLE" clause is
// downgraded to the "generic" parser, which exposes none of the dynamic
// key=value fields or the default-format "$"-variables. See
// doc/querylanguage.md ("Selecting the log format and dynamic fields").
func TestResolveParserName(t *testing.T) {
	tests := []struct {
		name       string
		query      string
		configured string
		want       string
	}{
		{
			name:  "explicit logformat wins over everything",
			query: "from STATS select $line logformat generickv",
			want:  "generickv",
		},
		{
			name:  "explicit logformat wins even without a from clause",
			query: "select service logformat generickv",
			want:  "generickv",
		},
		{
			name:  "no from clause downgrades to generic",
			query: "select service,sum(bytes) group by service",
			want:  "generic",
		},
		{
			name:  "from TABLE without configured format uses default",
			query: "from STATS select lifetimeConnections",
			want:  "default",
		},
		{
			name:       "from TABLE honours the configured default format",
			query:      "from STATS select lifetimeConnections",
			configured: "mimecast",
			want:       "mimecast",
		},
	}

	for _, tc := range tests {
		t.Run(tc.name, func(t *testing.T) {
			query, err := mapr.NewQuery(tc.query)
			if err != nil {
				t.Fatalf("NewQuery(%q) failed: %v", tc.query, err)
			}
			if got := resolveParserName(query, tc.configured); got != tc.want {
				t.Errorf("resolveParserName(%q, %q) = %q, want %q",
					tc.query, tc.configured, got, tc.want)
			}
		})
	}
}