forked from TrueCloudLab/restic
Merge pull request #4446 from 2000yeshu/feat-cat
Check for arguments before opening remote connection in cat command
This commit is contained in:
commit
a04964bb86
2 changed files with 58 additions and 2 deletions
|
@ -3,6 +3,7 @@ package main
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
|
|
||||||
|
@ -33,9 +34,34 @@ func init() {
|
||||||
cmdRoot.AddCommand(cmdCat)
|
cmdRoot.AddCommand(cmdCat)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func validateCatArgs(args []string) error {
|
||||||
|
var allowedCmds = []string{"config", "index", "snapshot", "key", "masterkey", "lock", "pack", "blob", "tree"}
|
||||||
|
|
||||||
|
if len(args) < 1 {
|
||||||
|
return errors.Fatal("type not specified")
|
||||||
|
}
|
||||||
|
|
||||||
|
validType := false
|
||||||
|
for _, v := range allowedCmds {
|
||||||
|
if v == args[0] {
|
||||||
|
validType = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !validType {
|
||||||
|
return errors.Fatalf("invalid type %q, must be one of [%s]", args[0], strings.Join(allowedCmds, "|"))
|
||||||
|
}
|
||||||
|
|
||||||
|
if args[0] != "masterkey" && args[0] != "config" && len(args) != 2 {
|
||||||
|
return errors.Fatal("ID not specified")
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
func runCat(ctx context.Context, gopts GlobalOptions, args []string) error {
|
func runCat(ctx context.Context, gopts GlobalOptions, args []string) error {
|
||||||
if len(args) < 1 || (args[0] != "masterkey" && args[0] != "config" && len(args) != 2) {
|
if err := validateCatArgs(args); err != nil {
|
||||||
return errors.Fatal("type or ID not specified")
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
repo, err := OpenRepository(ctx, gopts)
|
repo, err := OpenRepository(ctx, gopts)
|
||||||
|
|
30
cmd/restic/cmd_cat_test.go
Normal file
30
cmd/restic/cmd_cat_test.go
Normal file
|
@ -0,0 +1,30 @@
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"strings"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
rtest "github.com/restic/restic/internal/test"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestCatArgsValidation(t *testing.T) {
|
||||||
|
for _, test := range []struct {
|
||||||
|
args []string
|
||||||
|
err string
|
||||||
|
}{
|
||||||
|
{[]string{}, "Fatal: type not specified"},
|
||||||
|
{[]string{"masterkey"}, ""},
|
||||||
|
{[]string{"invalid"}, `Fatal: invalid type "invalid"`},
|
||||||
|
{[]string{"snapshot"}, "Fatal: ID not specified"},
|
||||||
|
{[]string{"snapshot", "12345678"}, ""},
|
||||||
|
} {
|
||||||
|
t.Run("", func(t *testing.T) {
|
||||||
|
err := validateCatArgs(test.args)
|
||||||
|
if test.err == "" {
|
||||||
|
rtest.Assert(t, err == nil, "unexpected error %q", err)
|
||||||
|
} else {
|
||||||
|
rtest.Assert(t, strings.Contains(err.Error(), test.err), "unexpected error expected %q to contain %q", err, test.err)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in a new issue