Fix ingester related test cases

nikhilsinhaparseable · Oct 26, 2023 · 9683042 · 9683042
1 parent ac65b60
commit 9683042
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/model.go b/model.go
@@ -369,5 +369,5 @@ func RoleReader(stream string) string {
 }
 
 func RoleIngester(stream string) string {
-	return fmt.Sprintf(`[{"privilege": "ingest", "resource": {"stream": "%s"}}]`, stream)
+	return fmt.Sprintf(`[{"privilege": "ingester", "resource": {"stream": "%s"}}]`, stream)
 }
diff --git a/quest_test.go b/quest_test.go
@@ -196,7 +196,7 @@ func TestSmokeRoles(t *testing.T) {
 			body:     RoleWriter(NewGlob.Stream),
 		},
 		{
-			roleName: "ingest",
+			roleName: "ingester",
 			body:     RoleIngester(NewGlob.Stream),
 		},
 	}

diff --git a/test_utils.go b/test_utils.go
@@ -294,7 +294,7 @@ func checkAPIAccess(t *testing.T, client HTTPClient, stream string, role string)
 		require.NoErrorf(t, err, "Request failed: %s", err)
 		require.Equalf(t, 403, response.StatusCode, "Server returned http code: %s and response: %s", response.Status, readAsString(response.Body))
 
-	case "ingest":
+	case "ingester":
 		// Check access to non-protected API
 		req, _ := client.NewRequest("GET", "liveness", nil)
 		response, err := client.Do(req)