X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/eb8dc9dee0793139aac55f4aa65a7b2de433afea..53b1b5bbe6d6ae007e8ce546ba2539e0c061e25a:/sdk/go/arvadosclient/arvadosclient_test.go diff --git a/sdk/go/arvadosclient/arvadosclient_test.go b/sdk/go/arvadosclient/arvadosclient_test.go index ca1d93319d..2c508dcb4a 100644 --- a/sdk/go/arvadosclient/arvadosclient_test.go +++ b/sdk/go/arvadosclient/arvadosclient_test.go @@ -1,11 +1,10 @@ package arvadosclient import ( - "fmt" + "git.curoverse.com/arvados.git/sdk/go/arvadostest" . "gopkg.in/check.v1" "net/http" "os" - "os/exec" "testing" ) @@ -15,51 +14,92 @@ func Test(t *testing.T) { } var _ = Suite(&ServerRequiredSuite{}) +var _ = Suite(&UnitSuite{}) // Tests that require the Keep server running type ServerRequiredSuite struct{} -func pythonDir() string { - cwd, _ := os.Getwd() - return fmt.Sprintf("%s/../../python/tests", cwd) +func (s *ServerRequiredSuite) SetUpSuite(c *C) { + arvadostest.StartAPI() + arvadostest.StartKeep(2, false) } -func (s *ServerRequiredSuite) SetUpSuite(c *C) { - os.Chdir(pythonDir()) - if err := exec.Command("python", "run_test_server.py", "start").Run(); err != nil { - panic("'python run_test_server.py start' returned error") - } - if err := exec.Command("python", "run_test_server.py", "start_keep").Run(); err != nil { - panic("'python run_test_server.py start_keep' returned error") - } +func (s *ServerRequiredSuite) SetUpTest(c *C) { + arvadostest.ResetEnv() } -func (s *ServerRequiredSuite) TestMakeArvadosClient(c *C) { - os.Setenv("ARVADOS_API_HOST", "localhost:3000") - os.Setenv("ARVADOS_API_TOKEN", "4axaw8zxe0qm22wa6urpp5nskcne8z88cvbupv653y1njyi05h") +func (s *ServerRequiredSuite) TestMakeArvadosClientSecure(c *C) { os.Setenv("ARVADOS_API_HOST_INSECURE", "") - kc, err := MakeArvadosClient() - c.Check(kc.ApiServer, Equals, "localhost:3000") - c.Check(kc.ApiToken, Equals, "4axaw8zxe0qm22wa6urpp5nskcne8z88cvbupv653y1njyi05h") + c.Assert(err, Equals, nil) + c.Check(kc.ApiServer, Equals, os.Getenv("ARVADOS_API_HOST")) + c.Check(kc.ApiToken, Equals, os.Getenv("ARVADOS_API_TOKEN")) c.Check(kc.ApiInsecure, Equals, false) +} +func (s *ServerRequiredSuite) TestMakeArvadosClientInsecure(c *C) { os.Setenv("ARVADOS_API_HOST_INSECURE", "true") - - kc, err = MakeArvadosClient() - c.Check(kc.ApiServer, Equals, "localhost:3000") - c.Check(kc.ApiToken, Equals, "4axaw8zxe0qm22wa6urpp5nskcne8z88cvbupv653y1njyi05h") + kc, err := MakeArvadosClient() + c.Assert(err, Equals, nil) c.Check(kc.ApiInsecure, Equals, true) + c.Check(kc.ApiServer, Equals, os.Getenv("ARVADOS_API_HOST")) + c.Check(kc.ApiToken, Equals, os.Getenv("ARVADOS_API_TOKEN")) c.Check(kc.Client.Transport.(*http.Transport).TLSClientConfig.InsecureSkipVerify, Equals, true) +} - c.Assert(err, Equals, nil) +func (s *ServerRequiredSuite) TestGetInvalidUUID(c *C) { + arv, err := MakeArvadosClient() + + getback := make(Dict) + err = arv.Get("collections", "", nil, &getback) + c.Assert(err, Equals, ErrInvalidArgument) + c.Assert(len(getback), Equals, 0) + + err = arv.Get("collections", "zebra-moose-unicorn", nil, &getback) + c.Assert(err, Equals, ErrInvalidArgument) + c.Assert(len(getback), Equals, 0) + + err = arv.Get("collections", "acbd18db4cc2f85cedef654fccc4a4d8", nil, &getback) + c.Assert(err, Equals, ErrInvalidArgument) + c.Assert(len(getback), Equals, 0) } -func (s *ServerRequiredSuite) TestCreatePipelineTemplate(c *C) { - os.Setenv("ARVADOS_API_HOST", "localhost:3000") - os.Setenv("ARVADOS_API_TOKEN", "4axaw8zxe0qm22wa6urpp5nskcne8z88cvbupv653y1njyi05h") - os.Setenv("ARVADOS_API_HOST_INSECURE", "true") +func (s *ServerRequiredSuite) TestGetValidUUID(c *C) { + arv, err := MakeArvadosClient() + + getback := make(Dict) + err = arv.Get("collections", "zzzzz-4zz18-abcdeabcdeabcde", nil, &getback) + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, http.StatusNotFound) + c.Assert(len(getback), Equals, 0) + + err = arv.Get("collections", "acbd18db4cc2f85cedef654fccc4a4d8+3", nil, &getback) + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, http.StatusNotFound) + c.Assert(len(getback), Equals, 0) +} + +func (s *ServerRequiredSuite) TestInvalidResourceType(c *C) { + arv, err := MakeArvadosClient() + + getback := make(Dict) + err = arv.Get("unicorns", "zzzzz-zebra-unicorn7unicorn", nil, &getback) + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, http.StatusNotFound) + c.Assert(len(getback), Equals, 0) + + err = arv.Update("unicorns", "zzzzz-zebra-unicorn7unicorn", nil, &getback) + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, http.StatusNotFound) + c.Assert(len(getback), Equals, 0) + + err = arv.List("unicorns", nil, &getback) + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, http.StatusNotFound) + c.Assert(len(getback), Equals, 0) +} +func (s *ServerRequiredSuite) TestCreatePipelineTemplate(c *C) { arv, err := MakeArvadosClient() getback := make(Dict) @@ -75,6 +115,13 @@ func (s *ServerRequiredSuite) TestCreatePipelineTemplate(c *C) { c.Assert(getback["components"].(map[string]interface{})["c2"].(map[string]interface{})["script"], Equals, "script2") uuid := getback["uuid"].(string) + + getback = make(Dict) + err = arv.Get("pipeline_templates", uuid, nil, &getback) + c.Assert(err, Equals, nil) + c.Assert(getback["name"], Equals, "tmp") + c.Assert(getback["components"].(map[string]interface{})["c1"].(map[string]interface{})["script"], Equals, "script1") + getback = make(Dict) err = arv.Update("pipeline_templates", uuid, Dict{ @@ -89,3 +136,73 @@ func (s *ServerRequiredSuite) TestCreatePipelineTemplate(c *C) { c.Assert(err, Equals, nil) c.Assert(getback["name"], Equals, "tmp2") } + +func (s *ServerRequiredSuite) TestErrorResponse(c *C) { + arv, _ := MakeArvadosClient() + + getback := make(Dict) + + { + err := arv.Create("logs", + Dict{"log": Dict{"bogus_attr": "foo"}}, + &getback) + c.Assert(err, ErrorMatches, "arvados API server error: .*") + c.Assert(err, ErrorMatches, ".*unknown attribute: bogus_attr.*") + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, 422) + } + + { + err := arv.Create("bogus", + Dict{"bogus": Dict{}}, + &getback) + c.Assert(err, ErrorMatches, "arvados API server error: .*") + c.Assert(err, ErrorMatches, ".*Path not found.*") + c.Assert(err, FitsTypeOf, APIServerError{}) + c.Assert(err.(APIServerError).HttpStatusCode, Equals, 404) + } +} + +func (s *ServerRequiredSuite) TestAPIDiscovery_Get_defaultCollectionReplication(c *C) { + arv, err := MakeArvadosClient() + value, err := arv.Discovery("defaultCollectionReplication") + c.Assert(err, IsNil) + c.Assert(value, NotNil) +} + +func (s *ServerRequiredSuite) TestAPIDiscovery_Get_noSuchParameter(c *C) { + arv, err := MakeArvadosClient() + value, err := arv.Discovery("noSuchParameter") + c.Assert(err, NotNil) + c.Assert(value, IsNil) +} + +type UnitSuite struct{} + +func (s *UnitSuite) TestUUIDMatch(c *C) { + c.Assert(UUIDMatch("zzzzz-tpzed-000000000000000"), Equals, true) + c.Assert(UUIDMatch("zzzzz-zebra-000000000000000"), Equals, true) + c.Assert(UUIDMatch("00000-00000-zzzzzzzzzzzzzzz"), Equals, true) + c.Assert(UUIDMatch("ZEBRA-HORSE-AFRICANELEPHANT"), Equals, false) + c.Assert(UUIDMatch(" zzzzz-tpzed-000000000000000"), Equals, false) + c.Assert(UUIDMatch("d41d8cd98f00b204e9800998ecf8427e"), Equals, false) + c.Assert(UUIDMatch("d41d8cd98f00b204e9800998ecf8427e+0"), Equals, false) + c.Assert(UUIDMatch(""), Equals, false) +} + +func (s *UnitSuite) TestPDHMatch(c *C) { + c.Assert(PDHMatch("zzzzz-tpzed-000000000000000"), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e"), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e+0"), Equals, true) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e+12345"), Equals, true) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e 12345"), Equals, false) + c.Assert(PDHMatch("D41D8CD98F00B204E9800998ECF8427E+12345"), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e+12345 "), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e+abcdef"), Equals, false) + c.Assert(PDHMatch("da39a3ee5e6b4b0d3255bfef95601890afd80709"), Equals, false) + c.Assert(PDHMatch("da39a3ee5e6b4b0d3255bfef95601890afd80709+0"), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427+12345"), Equals, false) + c.Assert(PDHMatch("d41d8cd98f00b204e9800998ecf8427e+12345\n"), Equals, false) + c.Assert(PDHMatch("+12345"), Equals, false) + c.Assert(PDHMatch(""), Equals, false) +}