| package client | |
| import ( | |
| "net/http" | |
| "testing" | |
| cerrdefs "github.com/containerd/errdefs" | |
| "github.com/moby/moby/api/types/image" | |
| "gotest.tools/v3/assert" | |
| is "gotest.tools/v3/assert/cmp" | |
| ) | |
| func TestImagePruneError(t *testing.T) { | |
| client, err := New(WithMockClient(errorMock(http.StatusInternalServerError, "Server error"))) | |
| assert.NilError(t, err) | |
| _, err = client.ImagePrune(t.Context(), ImagePruneOptions{}) | |
| assert.Check(t, is.ErrorType(err, cerrdefs.IsInternal)) | |
| } | |
| func TestImagePrune(t *testing.T) { | |
| const expectedURL = "/images/prune" | |
| listCases := []struct { | |
| filters Filters | |
| expectedQueryParams map[string]string | |
| }{ | |
| { | |
| filters: Filters{}, | |
| expectedQueryParams: map[string]string{ | |
| "until": "", | |
| "filter": "", | |
| "filters": "", | |
| }, | |
| }, | |
| { | |
| filters: make(Filters).Add("dangling", "true"), | |
| expectedQueryParams: map[string]string{ | |
| "until": "", | |
| "filter": "", | |
| "filters": `{"dangling":{"true":true}}`, | |
| }, | |
| }, | |
| { | |
| filters: make(Filters).Add("dangling", "false"), | |
| expectedQueryParams: map[string]string{ | |
| "until": "", | |
| "filter": "", | |
| "filters": `{"dangling":{"false":true}}`, | |
| }, | |
| }, | |
| { | |
| filters: make(Filters). | |
| Add("dangling", "true"). | |
| Add("label", "label1=foo", "label2!=bar"), | |
| expectedQueryParams: map[string]string{ | |
| "until": "", | |
| "filter": "", | |
| "filters": `{"dangling":{"true":true},"label":{"label1=foo":true,"label2!=bar":true}}`, | |
| }, | |
| }, | |
| } | |
| for _, listCase := range listCases { | |
| client, err := New(WithMockClient(func(req *http.Request) (*http.Response, error) { | |
| if err := assertRequest(req, http.MethodPost, expectedURL); err != nil { | |
| return nil, err | |
| } | |
| query := req.URL.Query() | |
| for key, expected := range listCase.expectedQueryParams { | |
| actual := query.Get(key) | |
| assert.Check(t, is.Equal(expected, actual)) | |
| } | |
| return mockJSONResponse(http.StatusOK, nil, image.PruneReport{ | |
| ImagesDeleted: []image.DeleteResponse{ | |
| {Deleted: "image_id1"}, | |
| {Deleted: "image_id2"}, | |
| }, | |
| SpaceReclaimed: 9999, | |
| })(req) | |
| })) | |
| assert.NilError(t, err) | |
| res, err := client.ImagePrune(t.Context(), ImagePruneOptions{Filters: listCase.filters}) | |
| assert.NilError(t, err) | |
| assert.Check(t, is.Len(res.Report.ImagesDeleted, 2)) | |
| assert.Check(t, is.Equal(uint64(9999), res.Report.SpaceReclaimed)) | |
| } | |
| } |