Add -f option to force remove current context and switch to default if required

This commit is contained in:
Guillaume Tardif 2020-06-15 16:28:43 +02:00
parent ddc44d7abe
commit eb505ecd75
3 changed files with 46 additions and 15 deletions

View File

@ -32,37 +32,61 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/spf13/cobra"
apicontext "github.com/docker/api/context" apicontext "github.com/docker/api/context"
"github.com/docker/api/context/store" "github.com/docker/api/context/store"
"github.com/docker/api/multierror" "github.com/docker/api/multierror"
"github.com/spf13/cobra"
) )
type removeOpts struct {
force bool
}
func removeCommand() *cobra.Command { func removeCommand() *cobra.Command {
return &cobra.Command{ var opts removeOpts
cmd := &cobra.Command{
Use: "rm CONTEXT [CONTEXT...]", Use: "rm CONTEXT [CONTEXT...]",
Short: "Remove one or more contexts", Short: "Remove one or more contexts",
Aliases: []string{"remove"}, Aliases: []string{"remove"},
Args: cobra.MinimumNArgs(1), Args: cobra.MinimumNArgs(1),
RunE: func(cmd *cobra.Command, args []string) error { RunE: func(cmd *cobra.Command, args []string) error {
return runRemove(cmd.Context(), args) return runRemove(cmd.Context(), args, opts.force)
}, },
} }
cmd.Flags().BoolVarP(&opts.force, "force", "f", false, "force removing current context")
return cmd
} }
func runRemove(ctx context.Context, args []string) error { func runRemove(ctx context.Context, args []string, force bool) error {
currentContext := apicontext.CurrentContext(ctx) currentContext := apicontext.CurrentContext(ctx)
s := store.ContextStore(ctx) s := store.ContextStore(ctx)
var errs *multierror.Error var errs *multierror.Error
for _, n := range args { for _, contextName := range args {
if currentContext == n { if currentContext == contextName {
errs = multierror.Append(errs, errors.New("cannot delete current context")) if force {
} else if err := s.Remove(n); err != nil { err := runUse(ctx, "default")
errs = multierror.Append(errs, err) if err != nil {
errs = multierror.Append(errs, errors.New("cannot delete current context"))
} else {
errs = removeContext(s, contextName, errs)
}
} else {
errs = multierror.Append(errs, errors.New("cannot delete current context"))
}
} else { } else {
fmt.Println(n) errs = removeContext(s, contextName, errs)
} }
} }
return errs.ErrorOrNil() return errs.ErrorOrNil()
} }
func removeContext(s store.Store, n string, errs *multierror.Error) *multierror.Error {
if err := s.Remove(n); err != nil {
errs = multierror.Append(errs, err)
} else {
fmt.Println(n)
}
return errs
}

View File

@ -21,8 +21,7 @@ func (m *LocalBackendTestSuite) BeforeTest(suiteName string, testName string) {
} }
func (m *LocalBackendTestSuite) AfterTest(suiteName string, testName string) { func (m *LocalBackendTestSuite) AfterTest(suiteName string, testName string) {
m.NewDockerCommand("context", "rm", "test-context").ExecOrDie() m.NewDockerCommand("context", "rm", "-f", "test-context").ExecOrDie()
m.NewDockerCommand("context", "use", "default").ExecOrDie()
} }
func (m *LocalBackendTestSuite) TestPs() { func (m *LocalBackendTestSuite) TestPs() {

View File

@ -80,12 +80,20 @@ func (s *E2eSuite) TestContextCreateParseErrorDoesNotDelegateToLegacy() {
} }
func (s *E2eSuite) TestCannotRemoveCurrentContext() { func (s *E2eSuite) TestCannotRemoveCurrentContext() {
s.NewDockerCommand("context", "create", "test-context", "--from", "default").ExecOrDie() s.NewDockerCommand("context", "create", "test-context-rm", "--from", "default").ExecOrDie()
s.NewDockerCommand("context", "use", "test-context").ExecOrDie() s.NewDockerCommand("context", "use", "test-context-rm").ExecOrDie()
_, err := s.NewDockerCommand("context", "rm", "test-context").Exec() _, err := s.NewDockerCommand("context", "rm", "test-context-rm").Exec()
Expect(err.Error()).To(ContainSubstring("cannot delete current context")) Expect(err.Error()).To(ContainSubstring("cannot delete current context"))
} }
func (s *E2eSuite) TestCanForceRemoveCurrentContext() {
s.NewDockerCommand("context", "create", "test-context-rmf", "--from", "default").ExecOrDie()
s.NewDockerCommand("context", "use", "test-context-rmf").ExecOrDie()
s.NewDockerCommand("context", "rm", "-f", "test-context-rmf").ExecOrDie()
out := s.NewDockerCommand("context", "ls").ExecOrDie()
Expect(out).To(ContainSubstring("default *"))
}
func (s *E2eSuite) TestClassicLoginWithparameters() { func (s *E2eSuite) TestClassicLoginWithparameters() {
output, err := s.NewDockerCommand("login", "-u", "nouser", "-p", "wrongpasword").Exec() output, err := s.NewDockerCommand("login", "-u", "nouser", "-p", "wrongpasword").Exec()
Expect(output).To(ContainSubstring("Get https://registry-1.docker.io/v2/: unauthorized: incorrect username or password")) Expect(output).To(ContainSubstring("Get https://registry-1.docker.io/v2/: unauthorized: incorrect username or password"))