refactor(del): refactors flow for clarity

This commit is contained in:
Lewis Wynne 2025-12-18 16:21:30 +00:00
parent 533c1a6cec
commit e3cdadd5fd

View file

@ -62,20 +62,20 @@ func del(cmd *cobra.Command, args []string) error {
return fmt.Errorf("cannot remove: no keys provided") return fmt.Errorf("cannot remove: no keys provided")
} }
targetKeys, deleteTargets, err := resolveDeleteTargets(store, args, globPatterns, separators) targets, err := resolveDeleteTargets(store, args, globPatterns, separators)
if err != nil { if err != nil {
return err return err
} }
if len(targetKeys) == 0 { if len(targets) == 0 {
return fmt.Errorf("cannot remove: No such key") return fmt.Errorf("cannot remove: No such key")
} }
if !force && config.WarnOnDelete { if !force && config.WarnOnDelete {
var confirm string var confirm string
quotedTargets := make([]string, 0, len(targetKeys)) quotedTargets := make([]string, 0, len(targets))
for _, t := range targetKeys { for _, target := range targets {
quotedTargets = append(quotedTargets, fmt.Sprintf("%q", t)) quotedTargets = append(quotedTargets, fmt.Sprintf("%q", target.display))
} }
message := fmt.Sprintf("remove %s: are you sure? (y/n)", strings.Join(quotedTargets, ", ")) message := fmt.Sprintf("remove %s: are you sure? (y/n)", strings.Join(quotedTargets, ", "))
fmt.Println(message) fmt.Println(message)
@ -87,17 +87,17 @@ func del(cmd *cobra.Command, args []string) error {
} }
} }
for _, target := range deleteTargets { for _, target := range targets {
trans := TransactionArgs{ trans := TransactionArgs{
key: target, key: target.full,
readonly: false, readonly: false,
sync: false, sync: false,
transact: func(tx *badger.Txn, k []byte) error { transact: func(tx *badger.Txn, k []byte) error {
if err := tx.Delete(k); errors.Is(err, badger.ErrKeyNotFound) { if err := tx.Delete(k); errors.Is(err, badger.ErrKeyNotFound) {
return fmt.Errorf("cannot remove '%s': No such key", target) return fmt.Errorf("cannot remove '%s': No such key", target.full)
} }
if err != nil { if err != nil {
return fmt.Errorf("cannot remove '%s': %v", target, err) return fmt.Errorf("cannot remove '%s': %v", target.full, err)
} }
return nil return nil
}, },
@ -118,6 +118,11 @@ func init() {
rootCmd.AddCommand(delCmd) rootCmd.AddCommand(delCmd)
} }
type resolvedTarget struct {
full string
display string
}
func keyExists(store *Store, arg string) (bool, error) { func keyExists(store *Store, arg string) (bool, error) {
var notFound bool var notFound bool
trans := TransactionArgs{ trans := TransactionArgs{
@ -147,32 +152,39 @@ func formatKeyForPrompt(store *Store, arg string) (string, error) {
return spec.Display(), nil return spec.Display(), nil
} }
func resolveDeleteTargets(store *Store, exactArgs []string, globPatterns []string, separators []rune) ([]string, []string, error) { func resolveDeleteTargets(store *Store, exactArgs []string, globPatterns []string, separators []rune) ([]resolvedTarget, error) {
targetSet := make(map[string]struct{}) targetSet := make(map[string]struct{})
var targetKeys []string var targets []resolvedTarget
var deleteTargets []string
addTarget := func(spec KeySpec) {
full := spec.Full()
if _, seen := targetSet[full]; seen {
return
}
targetSet[full] = struct{}{}
targets = append(targets, resolvedTarget{
full: full,
display: spec.Display(),
})
}
for _, arg := range exactArgs { for _, arg := range exactArgs {
exists, err := keyExists(store, arg) exists, err := keyExists(store, arg)
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("cannot remove '%s': %v", arg, err) return nil, fmt.Errorf("cannot remove '%s': %v", arg, err)
} }
if !exists { if !exists {
continue continue
} }
formatted, err := formatKeyForPrompt(store, arg) spec, err := store.parseKey(arg, true)
if err != nil { if err != nil {
return nil, nil, err return nil, err
}
if _, seen := targetSet[arg]; !seen {
targetSet[arg] = struct{}{}
targetKeys = append(targetKeys, formatted)
deleteTargets = append(deleteTargets, arg)
} }
addTarget(spec)
} }
if len(globPatterns) == 0 { if len(globPatterns) == 0 {
return targetKeys, deleteTargets, nil return targets, nil
} }
type compiledPattern struct { type compiledPattern struct {
@ -185,12 +197,12 @@ func resolveDeleteTargets(store *Store, exactArgs []string, globPatterns []strin
for _, raw := range globPatterns { for _, raw := range globPatterns {
spec, err := store.parseKey(raw, true) spec, err := store.parseKey(raw, true)
if err != nil { if err != nil {
return nil, nil, err return nil, err
} }
pattern := spec.Key pattern := spec.Key
m, err := glob.Compile(pattern, separators...) m, err := glob.Compile(pattern, separators...)
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("cannot remove '%s': %v", raw, err) return nil, fmt.Errorf("cannot remove '%s': %v", raw, err)
} }
compiled = append(compiled, compiledPattern{ compiled = append(compiled, compiledPattern{
rawArg: raw, rawArg: raw,
@ -215,24 +227,19 @@ func resolveDeleteTargets(store *Store, exactArgs []string, globPatterns []strin
for _, p := range compiled { for _, p := range compiled {
keys, err := getKeys(p.db) keys, err := getKeys(p.db)
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("cannot remove '%s': %v", p.rawArg, err) return nil, fmt.Errorf("cannot remove '%s': %v", p.rawArg, err)
} }
for _, k := range keys { for _, k := range keys {
if p.matcher.Match(k) { if p.matcher.Match(k) {
full := fmt.Sprintf("%s@%s", k, p.db) addTarget(KeySpec{
if _, seen := targetSet[full]; seen { Raw: k,
continue RawKey: k,
} Key: k,
targetSet[full] = struct{}{} DB: p.db,
display, err := formatKeyForPrompt(store, full) })
if err != nil {
return nil, nil, err
}
targetKeys = append(targetKeys, display)
deleteTargets = append(deleteTargets, full)
} }
} }
} }
return targetKeys, deleteTargets, nil return targets, nil
} }