X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3da10f0c0f5a0c0c91d49436a5995c890b03d228..47a5c66948792602f657e5e1157bfd172d23c546:/services/datamanager/keep/keep_test.go?ds=inline diff --git a/services/datamanager/keep/keep_test.go b/services/datamanager/keep/keep_test.go deleted file mode 100644 index 2ccf17d45f..0000000000 --- a/services/datamanager/keep/keep_test.go +++ /dev/null @@ -1,81 +0,0 @@ -package keep - -import ( - "encoding/json" - "git.curoverse.com/arvados.git/sdk/go/keepclient" - . "gopkg.in/check.v1" - "net/http" - "net/http/httptest" - "testing" -) - -// Gocheck boilerplate -func Test(t *testing.T) { - TestingT(t) -} - -type KeepSuite struct{} - -var _ = Suite(&KeepSuite{}) - -type TestHandler struct { - request TrashList -} - -func (ts *TestHandler) ServeHTTP(writer http.ResponseWriter, req *http.Request) { - r := json.NewDecoder(req.Body) - r.Decode(&ts.request) -} - -func (s *KeepSuite) TestSendTrashLists(c *C) { - th := TestHandler{} - server := httptest.NewServer(&th) - - tl := map[string]TrashList{ - server.URL: TrashList{TrashRequest{"000000000000000000000000deadbeef", 99}}} - - kc := keepclient.KeepClient{Client: &http.Client{}} - kc.SetServiceRoots(map[string]string{"xxxx": server.URL}, - map[string]string{"xxxx": server.URL}, - map[string]string{}) - - err := SendTrashLists("", &kc, tl) - server.Close() - - c.Check(err, IsNil) - - c.Check(th.request, - DeepEquals, - tl[server.URL]) - -} - -type TestHandlerError struct { -} - -func (tse *TestHandlerError) ServeHTTP(writer http.ResponseWriter, req *http.Request) { - http.Error(writer, "I'm a teapot", 418) -} - -func sendTrashListError(c *C, server *httptest.Server) { - tl := map[string]TrashList{ - server.URL: TrashList{TrashRequest{"000000000000000000000000deadbeef", 99}}} - - kc := keepclient.KeepClient{Client: &http.Client{}} - kc.SetServiceRoots(map[string]string{"xxxx": server.URL}, - map[string]string{"xxxx": server.URL}, - map[string]string{}) - - err := SendTrashLists("", &kc, tl) - - c.Check(err, NotNil) - c.Check(err[0], NotNil) -} - -func (s *KeepSuite) TestSendTrashListErrorResponse(c *C) { - sendTrashListError(c, httptest.NewServer(&TestHandlerError{})) -} - -func (s *KeepSuite) TestSendTrashListUnreachable(c *C) { - sendTrashListError(c, httptest.NewUnstartedServer(&TestHandler{})) -}