| package client | |
| import ( | |
| "fmt" | |
| "net/http" | |
| "testing" | |
| cerrdefs "github.com/containerd/errdefs" | |
| "github.com/moby/moby/api/types/image" | |
| ocispec "github.com/opencontainers/image-spec/specs-go/v1" | |
| "gotest.tools/v3/assert" | |
| is "gotest.tools/v3/assert/cmp" | |
| ) | |
| func TestImageRemoveError(t *testing.T) { | |
| client, err := New(WithMockClient(errorMock(http.StatusInternalServerError, "Server error"))) | |
| assert.NilError(t, err) | |
| _, err = client.ImageRemove(t.Context(), "image_id", ImageRemoveOptions{}) | |
| assert.Check(t, is.ErrorType(err, cerrdefs.IsInternal)) | |
| } | |
| func TestImageRemoveImageNotFound(t *testing.T) { | |
| client, err := New(WithMockClient(errorMock(http.StatusNotFound, "no such image: unknown"))) | |
| assert.NilError(t, err) | |
| _, err = client.ImageRemove(t.Context(), "unknown", ImageRemoveOptions{}) | |
| assert.Check(t, is.ErrorContains(err, "no such image: unknown")) | |
| assert.Check(t, is.ErrorType(err, cerrdefs.IsNotFound)) | |
| } | |
| func TestImageRemove(t *testing.T) { | |
| const expectedURL = "/images/image_id" | |
| removeCases := []struct { | |
| force bool | |
| pruneChildren bool | |
| platform *ocispec.Platform | |
| expectedQueryParams map[string]string | |
| }{ | |
| { | |
| force: false, | |
| pruneChildren: false, | |
| expectedQueryParams: map[string]string{ | |
| "force": "", | |
| "noprune": "1", | |
| }, | |
| }, | |
| { | |
| force: true, | |
| pruneChildren: true, | |
| expectedQueryParams: map[string]string{ | |
| "force": "1", | |
| "noprune": "", | |
| }, | |
| }, | |
| { | |
| platform: &ocispec.Platform{ | |
| Architecture: "amd64", | |
| OS: "linux", | |
| }, | |
| expectedQueryParams: map[string]string{ | |
| "platforms": `{"architecture":"amd64","os":"linux"}`, | |
| }, | |
| }, | |
| } | |
| for _, removeCase := range removeCases { | |
| client, err := New(WithMockClient(func(req *http.Request) (*http.Response, error) { | |
| if err := assertRequest(req, http.MethodDelete, expectedURL); err != nil { | |
| return nil, err | |
| } | |
| query := req.URL.Query() | |
| for key, expected := range removeCase.expectedQueryParams { | |
| actual := query.Get(key) | |
| if actual != expected { | |
| return nil, fmt.Errorf("%s not set in URL query properly. Expected '%s', got %s", key, expected, actual) | |
| } | |
| } | |
| return mockJSONResponse(http.StatusOK, nil, []image.DeleteResponse{ | |
| {Untagged: "image_id1"}, | |
| {Deleted: "image_id"}, | |
| })(req) | |
| })) | |
| assert.NilError(t, err) | |
| opts := ImageRemoveOptions{ | |
| Force: removeCase.force, | |
| PruneChildren: removeCase.pruneChildren, | |
| } | |
| if removeCase.platform != nil { | |
| opts.Platforms = []ocispec.Platform{*removeCase.platform} | |
| } | |
| res, err := client.ImageRemove(t.Context(), "image_id", opts) | |
| assert.NilError(t, err) | |
| assert.Check(t, is.Len(res.Items, 2)) | |
| } | |
| } |