| package client |
| |
| import ( |
| "context" |
| "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(context.Background(), "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(context.Background(), "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(context.Background(), "image_id", opts) |
| assert.NilError(t, err) |
| assert.Check(t, is.Len(res.Items, 2)) |
| } |
| } |