X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/20fec88ce889c3aa0eb020361f4001c362438283..6bbd591d1b9e5cd5797a35703fd8951d421885aa:/services/keepstore/handler_test.go diff --git a/services/keepstore/handler_test.go b/services/keepstore/handler_test.go index 34e711f197..ca609157aa 100644 --- a/services/keepstore/handler_test.go +++ b/services/keepstore/handler_test.go @@ -224,21 +224,15 @@ func TestPutHandler(t *testing.T) { } // Test /index requests: -// - enforce_permissions off | unauthenticated /index request -// - enforce_permissions off | unauthenticated /index/prefix request -// - enforce_permissions off | authenticated /index request | non-superuser -// - enforce_permissions off | authenticated /index/prefix request | non-superuser -// - enforce_permissions off | authenticated /index request | superuser -// - enforce_permissions off | authenticated /index/prefix request | superuser -// - enforce_permissions on | unauthenticated /index request -// - enforce_permissions on | unauthenticated /index/prefix request -// - enforce_permissions on | authenticated /index request | non-superuser -// - enforce_permissions on | authenticated /index/prefix request | non-superuser -// - enforce_permissions on | authenticated /index request | superuser -// - enforce_permissions on | authenticated /index/prefix request | superuser +// - unauthenticated /index request +// - unauthenticated /index/prefix request +// - authenticated /index request | non-superuser +// - authenticated /index/prefix request | non-superuser +// - authenticated /index request | superuser +// - authenticated /index/prefix request | superuser // // The only /index requests that should succeed are those issued by the -// superuser when enforce_permissions = true. +// superuser. They should pass regardless of the value of enforce_permissions. // func TestIndexHandler(t *testing.T) { defer teardown() @@ -289,95 +283,58 @@ func TestIndexHandler(t *testing.T) { api_token: data_manager_token, } - // ---------------------------- - // enforce_permissions disabled - // All /index requests should fail. - enforce_permissions = false + // ------------------------------------------------------------- + // Only the superuser should be allowed to issue /index requests. + + // --------------------------- + // enforce_permissions enabled + // This setting should not affect tests passing. + enforce_permissions = true // unauthenticated /index request - // => PermissionError + // => UnauthorizedError response := IssueRequest(rest, unauthenticated_req) ExpectStatusCode(t, - "enforce_permissions off, unauthenticated request", - PermissionError.HTTPCode, + "enforce_permissions on, unauthenticated request", + UnauthorizedError.HTTPCode, response) // unauthenticated /index/prefix request - // => PermissionError + // => UnauthorizedError response = IssueRequest(rest, unauth_prefix_req) ExpectStatusCode(t, - "enforce_permissions off, unauthenticated /index/prefix request", - PermissionError.HTTPCode, + "permissions on, unauthenticated /index/prefix request", + UnauthorizedError.HTTPCode, response) // authenticated /index request, non-superuser - // => PermissionError + // => UnauthorizedError response = IssueRequest(rest, authenticated_req) ExpectStatusCode(t, - "enforce_permissions off, authenticated request, non-superuser", - PermissionError.HTTPCode, + "permissions on, authenticated request, non-superuser", + UnauthorizedError.HTTPCode, response) // authenticated /index/prefix request, non-superuser - // => PermissionError + // => UnauthorizedError response = IssueRequest(rest, auth_prefix_req) ExpectStatusCode(t, - "enforce_permissions off, authenticated /index/prefix request, non-superuser", - PermissionError.HTTPCode, + "permissions on, authenticated /index/prefix request, non-superuser", + UnauthorizedError.HTTPCode, response) - // authenticated /index request, superuser - // => PermissionError + // superuser /index request + // => OK response = IssueRequest(rest, superuser_req) ExpectStatusCode(t, - "enforce_permissions off, superuser request", - PermissionError.HTTPCode, - response) - - // superuser /index/prefix request - // => PermissionError - response = IssueRequest(rest, superuser_prefix_req) - ExpectStatusCode(t, - "enforce_permissions off, superuser /index/prefix request", - PermissionError.HTTPCode, - response) - - // --------------------------- - // enforce_permissions enabled - // Only the superuser should be allowed to issue /index requests. - enforce_permissions = true - - // unauthenticated /index request - // => PermissionError - response = IssueRequest(rest, unauthenticated_req) - ExpectStatusCode(t, - "enforce_permissions on, unauthenticated request", - PermissionError.HTTPCode, - response) - - // unauthenticated /index/prefix request - // => PermissionError - response = IssueRequest(rest, unauth_prefix_req) - ExpectStatusCode(t, - "permissions on, unauthenticated /index/prefix request", - PermissionError.HTTPCode, - response) - - // authenticated /index request, non-superuser - // => PermissionError - response = IssueRequest(rest, authenticated_req) - ExpectStatusCode(t, - "permissions on, authenticated request, non-superuser", - PermissionError.HTTPCode, + "permissions on, superuser request", + http.StatusOK, response) - // authenticated /index/prefix request, non-superuser - // => PermissionError - response = IssueRequest(rest, auth_prefix_req) - ExpectStatusCode(t, - "permissions on, authenticated /index/prefix request, non-superuser", - PermissionError.HTTPCode, - response) + // ---------------------------- + // enforce_permissions disabled + // Valid Request should still pass. + enforce_permissions = false // superuser /index request // => OK @@ -387,6 +344,8 @@ func TestIndexHandler(t *testing.T) { http.StatusOK, response) + + expected := `^` + TEST_HASH + `\+\d+ \d+\n` + TEST_HASH_2 + `\+\d+ \d+\n$` match, _ := regexp.MatchString(expected, response.Body.String()) @@ -591,7 +550,7 @@ func TestDeleteHandler(t *testing.T) { // // TODO(twp): test concurrency: launch 100 goroutines to update the // pull list simultaneously. Make sure that none of them return 400 -// Bad Request and that pullmgr.GetList() returns a valid list. +// Bad Request and that pullq.GetList() returns a valid list. // func TestPullHandler(t *testing.T) { defer teardown() @@ -630,25 +589,25 @@ func TestPullHandler(t *testing.T) { } var testcases = []pullTest{ { - "user token, good request", + "Valid pull list from an ordinary user", RequestTester{"/pull", user_token, "PUT", good_json}, http.StatusUnauthorized, "Unauthorized\n", }, { - "user token, bad request", + "Invalid pull request from an ordinary user", RequestTester{"/pull", user_token, "PUT", bad_json}, http.StatusUnauthorized, "Unauthorized\n", }, { - "data manager token, good request", + "Valid pull request from the data manager", RequestTester{"/pull", data_manager_token, "PUT", good_json}, http.StatusOK, "Received 3 pull requests\n", }, { - "data manager token, bad request", + "Invalid pull request from the data manager", RequestTester{"/pull", data_manager_token, "PUT", bad_json}, http.StatusBadRequest, "Bad Request\n", @@ -663,12 +622,119 @@ func TestPullHandler(t *testing.T) { // The Keep pull manager should have received one good list with 3 // requests on it. - var saved_pull_list = pullmgr.GetList() - if len(saved_pull_list) != 3 { - t.Errorf( - "saved_pull_list: expected 3 elements, got %d\nsaved_pull_list = %v", - len(saved_pull_list), saved_pull_list) + for i := 0; i < 3; i++ { + item := <-pullq.NextItem + if _, ok := item.(PullRequest); !ok { + t.Errorf("item %v could not be parsed as a PullRequest", item) + } } + + expectChannelEmpty(t, pullq.NextItem) +} + +// TestTrashHandler +// +// Test cases: +// +// Cases tested: syntactically valid and invalid trash lists, from the +// data manager and from unprivileged users: +// +// 1. Valid trash list from an ordinary user +// (expected result: 401 Unauthorized) +// +// 2. Invalid trash list from an ordinary user +// (expected result: 401 Unauthorized) +// +// 3. Valid trash list from the data manager +// (expected result: 200 OK with request body "Received 3 trash +// requests" +// +// 4. Invalid trash list from the data manager +// (expected result: 400 Bad Request) +// +// Test that in the end, the trash collector received a good list +// trash list with the expected number of requests. +// +// TODO(twp): test concurrency: launch 100 goroutines to update the +// pull list simultaneously. Make sure that none of them return 400 +// Bad Request and that replica.Dump() returns a valid list. +// +func TestTrashHandler(t *testing.T) { + defer teardown() + + // Set up a REST router for testing the handlers. + rest := MakeRESTRouter() + + var user_token = "USER TOKEN" + data_manager_token = "DATA MANAGER TOKEN" + + good_json := []byte(`[ + { + "locator":"block1", + "block_mtime":1409082153 + }, + { + "locator":"block2", + "block_mtime":1409082153 + }, + { + "locator":"block3", + "block_mtime":1409082153 + } + ]`) + + bad_json := []byte(`I am not a valid JSON string`) + + type trashTest struct { + name string + req RequestTester + response_code int + response_body string + } + + var testcases = []trashTest{ + { + "Valid trash list from an ordinary user", + RequestTester{"/trash", user_token, "PUT", good_json}, + http.StatusUnauthorized, + "Unauthorized\n", + }, + { + "Invalid trash list from an ordinary user", + RequestTester{"/trash", user_token, "PUT", bad_json}, + http.StatusUnauthorized, + "Unauthorized\n", + }, + { + "Valid trash list from the data manager", + RequestTester{"/trash", data_manager_token, "PUT", good_json}, + http.StatusOK, + "Received 3 trash requests\n", + }, + { + "Invalid trash list from the data manager", + RequestTester{"/trash", data_manager_token, "PUT", bad_json}, + http.StatusBadRequest, + "Bad Request\n", + }, + } + + for _, tst := range testcases { + response := IssueRequest(rest, &tst.req) + ExpectStatusCode(t, tst.name, tst.response_code, response) + ExpectBody(t, tst.name, tst.response_body, response) + } + + // The trash collector should have received one good list with 3 + // requests on it. + for i := 0; i < 3; i++ { + item := <-trashq.NextItem + if _, ok := item.(TrashRequest); !ok { + t.Errorf("item %v could not be parsed as a TrashRequest", item) + } + } + + expectChannelEmpty(t, trashq.NextItem) } // ====================