added tests for SHOW GRANTS FOR statements

influxql/parser_test.go

@@ -527,6 +527,12 @@ func TestParser_ParseStatement(t *testing.T) {
 			stmt: &influxql.ShowServersStatement{},
 		},
 
+		// SHOW GRANTS
+		{
+			s:    `SHOW GRANTS FOR jdoe`,
+			stmt: &influxql.ShowGrantsForUserStatement{Name: "jdoe"},
+		},
+
 		// SHOW DATABASES
 		{
 			s:    `SHOW DATABASES`,
@@ -1160,8 +1166,10 @@ func TestParser_ParseStatement(t *testing.T) {
 		{s: `SHOW CONTINUOUS`, err: `found EOF, expected QUERIES at line 1, char 17`},
 		{s: `SHOW RETENTION`, err: `found EOF, expected POLICIES at line 1, char 16`},
 		{s: `SHOW RETENTION POLICIES`, err: `found EOF, expected identifier at line 1, char 25`},
-		{s: `SHOW FOO`, err: `found FOO, expected CONTINUOUS, DATABASES, FIELD, MEASUREMENTS, RETENTION, SERIES, SERVERS, TAG, USERS at line 1, char 6`},
+		{s: `SHOW FOO`, err: `found FOO, expected CONTINUOUS, DATABASES, FIELD, GRANTS, MEASUREMENTS, RETENTION, SERIES, SERVERS, TAG, USERS at line 1, char 6`},
 		{s: `SHOW STATS ON`, err: `found EOF, expected string at line 1, char 15`},
+		{s: `SHOW GRANTS`, err: `found EOF, expected FOR at line 1, char 13`},
+		{s: `SHOW GRANTS FOR`, err: `found EOF, expected identifier at line 1, char 17`},
 		{s: `DROP CONTINUOUS`, err: `found EOF, expected QUERY at line 1, char 17`},
 		{s: `DROP CONTINUOUS QUERY`, err: `found EOF, expected identifier at line 1, char 23`},
 		{s: `DROP CONTINUOUS QUERY myquery`, err: `found EOF, expected ON at line 1, char 31`},

server_test.go

@@ -570,6 +570,37 @@ func TestServer_NonExistingUsers(t *testing.T) {
 	}
 }
 
+// Ensure the server does return valid users grant data
+func TestServer_GetGrantPrivileges(t *testing.T) {
+	c := test.NewDefaultMessagingClient()
+	defer c.Close()
+	s := OpenServer(c)
+	defer s.Close()
+
+	// Create some users.
+	s.CreateUser("susy", "pass", false)
+
+	// Grant normal user write privileges on database "bar".
+	s.SetPrivilege(influxql.WritePrivilege, "susy", "bar")
+
+	s.Restart()
+
+	p, err := s.UserPrivileges("susy")
+	if err != nil {
+		t.Fatalf("unexpected missing data for user")
+	}
+
+	if p["bar"] != influxql.WritePrivilege {
+		t.Fatalf("unexpected missing privilege for user")
+	}
+
+	_, err = s.UserPrivileges("Boby")
+
+	if err == nil {
+		t.Fatalf("unexpected grant user data found")
+	}
+}
+
 // Ensure the database can create a new retention policy.
 func TestServer_CreateRetentionPolicy(t *testing.T) {
 	c := test.NewDefaultMessagingClient()