Function MakeUser

rest/utilities_testing_user.go:25–54

(t *testing.T, httpClient *http.Client, serverURL, username, password string, roles []string)

)

func MakeUser(t *testing.T, httpClient *http.Client, serverURL, username, password string, roles []string) {
	form := url.Values{}
	form.Add("password", password)
	form.Add("roles", strings.Join(roles, ","))

	retryWorker := func() (shouldRetry bool, err error, value interface{}) {
		req, err := http.NewRequest("PUT", fmt.Sprintf("%s/settings/rbac/users/local/%s", serverURL, username), strings.NewReader(form.Encode()))
		require.NoError(t, err)

		req.SetBasicAuth(base.TestClusterUsername(), base.TestClusterPassword())
		req.Header.Add("Content-Type", "application/x-www-form-urlencoded")

		resp, err := httpClient.Do(req)
		if err != nil {
			return true, err, nil
		}
		defer func() { assert.NoError(t, resp.Body.Close()) }()
		var bodyResp []byte
		if resp.StatusCode != http.StatusOK {
			bodyResp, err = io.ReadAll(resp.Body)
			require.NoError(t, err, "Failed to create user: %s", bodyResp)
		}
		require.Equalf(t, http.StatusOK, resp.StatusCode, "Failed to create user: %s", bodyResp)
		return false, err, nil
	}

	err, _ := base.RetryLoop(base.TestCtx(t), "Admin Auth testing MakeUser", retryWorker, base.CreateSleeperFunc(10, 100))
	require.NoError(t, err)

}

func DeleteUser(t *testing.T, httpClient *http.Client, serverURL, username string) {
	retryWorker := func() (shouldRetry bool, err error, value *http.Response) {