blob: 5788c2ae35693ddb546ad253fd97688fbe9d392f [file] [edit]
package client
import (
"fmt"
"net/http"
"testing"
cerrdefs "github.com/containerd/errdefs"
"gotest.tools/v3/assert"
is "gotest.tools/v3/assert/cmp"
)
func TestSwarmLeaveError(t *testing.T) {
client, err := New(WithMockClient(errorMock(http.StatusInternalServerError, "Server error")))
assert.NilError(t, err)
_, err = client.SwarmLeave(t.Context(), SwarmLeaveOptions{})
assert.Check(t, is.ErrorType(err, cerrdefs.IsInternal))
}
func TestSwarmLeave(t *testing.T) {
const expectedURL = "/swarm/leave"
leaveCases := []struct {
force bool
expectedForce string
}{
{
expectedForce: "",
},
{
force: true,
expectedForce: "1",
},
}
for _, leaveCase := range leaveCases {
client, err := New(WithMockClient(func(req *http.Request) (*http.Response, error) {
if err := assertRequest(req, http.MethodPost, expectedURL); err != nil {
return nil, err
}
force := req.URL.Query().Get("force")
if force != leaveCase.expectedForce {
return nil, fmt.Errorf("force not set in URL query properly. expected '%s', got %s", leaveCase.expectedForce, force)
}
return mockResponse(http.StatusOK, nil, "")(req)
}))
assert.NilError(t, err)
_, err = client.SwarmLeave(t.Context(), SwarmLeaveOptions{Force: leaveCase.force})
assert.NilError(t, err)
}
}