diff --git a/.vscode/launch.json b/.vscode/launch.json index d5768d519..ec215b721 100644 --- a/.vscode/launch.json +++ b/.vscode/launch.json @@ -6,7 +6,7 @@ "request": "launch", "mode": "auto", "program": "main.go", - "args": ["task", "list", "--tag", "foo=bar"], + "args": ["server", "run"], }, { "name": "Attach to Process", diff --git a/cmd/task/task_test.go b/cmd/task/task_test.go index 849814096..2a31a1abd 100644 --- a/cmd/task/task_test.go +++ b/cmd/task/task_test.go @@ -41,7 +41,7 @@ func TestGetDefaultView(t *testing.T) { func TestList(t *testing.T) { cmd, h := newCommandHooks() - h.List = func(server, view, page, state string, tags []string, size int32, all bool, w io.Writer) error { + h.List = func(server, view, page, state string, tags []string, namePrefix string, size int32, all bool, w io.Writer) error { if view != "FULL" { t.Errorf("expected FULL view, got '%s'", view) } @@ -62,7 +62,7 @@ func TestServerDefault(t *testing.T) { } return nil } - h.List = func(server, view, page, state string, tags []string, size int32, all bool, w io.Writer) error { + h.List = func(server, view, page, state string, tags []string, namePrefix string, size int32, all bool, w io.Writer) error { if server != "http://localhost:8000" { t.Errorf("expected localhost default, got '%s'", server) } @@ -116,7 +116,7 @@ func TestServerEnv(t *testing.T) { } return nil } - h.List = func(server, view, page, state string, tags []string, size int32, all bool, w io.Writer) error { + h.List = func(server, view, page, state string, tags []string, namePrefix string, size int32, all bool, w io.Writer) error { if server != "foobar" { t.Error("expected foobar") } @@ -170,7 +170,7 @@ func TestServerFlagOverride(t *testing.T) { } return nil } - h.List = func(server, view, page, state string, tags []string, size int32, all bool, w io.Writer) error { + h.List = func(server, view, page, state string, tags []string, namePrefix string, size int32, all bool, w io.Writer) error { if server != "flagval" { t.Error("expected flagval") } diff --git a/tes/client.go b/tes/client.go index f8a02e65f..9f00e7ccf 100644 --- a/tes/client.go +++ b/tes/client.go @@ -96,6 +96,7 @@ func (c *Client) ListTasks(ctx context.Context, req *ListTasksRequest) (*ListTas u := c.address + "/v1/tasks?" + v.Encode() fmt.Println("DEBUG u:", u) hreq, _ := http.NewRequest("GET", u, nil) + hreq.SetBasicAuth(c.User, c.Password) fmt.Println("DEBUG hreq:", hreq) // hreq.WithContext(ctx) // hreq.SetBasicAuth(c.User, c.Password) diff --git a/tes/utils_test.go b/tes/utils_test.go index 3f2d7e156..9c7f9c187 100644 --- a/tes/utils_test.go +++ b/tes/utils_test.go @@ -16,7 +16,7 @@ func TestBase64Encode(t *testing.T) { }, } - expected := "ewogICJpZCI6ICJ0YXNrMSIsCiAgImV4ZWN1dG9ycyI6IFsKICAgIHsKICAgICAgImltYWdlIjogImFscGluZSIsCiAgICAgICJjb21tYW5kIjogWwogICAgICAgICJlY2hvIiwKICAgICAgICAiaGVsbG8gd29ybGQiCiAgICAgIF0KICAgIH0KICBdCn0=" + expected := "ewogICJleGVjdXRvcnMiOiAgWwogICAgewogICAgICAiY29tbWFuZCI6ICBbCiAgICAgICAgImVjaG8iLAogICAgICAgICJoZWxsbyB3b3JsZCIKICAgICAgXSwKICAgICAgImltYWdlIjogICJhbHBpbmUiCiAgICB9CiAgXSwKICAiaWQiOiAgInRhc2sxIgp9" encoded, err := Base64Encode(task) if err != nil { diff --git a/tests/funnel_utils.go b/tests/funnel_utils.go index 0eb7aef8c..8b9c90d61 100644 --- a/tests/funnel_utils.go +++ b/tests/funnel_utils.go @@ -16,6 +16,7 @@ import ( "time" dockerTypes "github.com/docker/docker/api/types" + "github.com/docker/docker/api/types/container" dockerFilters "github.com/docker/docker/api/types/filters" docker "github.com/docker/docker/client" runlib "github.com/ohsu-comp-bio/funnel/cmd/run" @@ -424,9 +425,8 @@ func (f *Funnel) findTestServerContainers() []string { } func (f *Funnel) killTestServerContainers(ids []string) { - timeout := 10 * time.Second for _, n := range ids { - err := f.Docker.ContainerStop(context.Background(), strings.TrimPrefix(n, "/"), &timeout) + err := f.Docker.ContainerStop(context.Background(), strings.TrimPrefix(n, "/"), container.StopOptions{}) if err != nil { panic(err) }