diff options
| author | EuAndreh <eu@euandre.org> | 2025-01-25 21:18:54 -0300 |
|---|---|---|
| committer | EuAndreh <eu@euandre.org> | 2025-01-25 21:18:54 -0300 |
| commit | 6c1b42c2f918b4d6c8f4f63c53ceb0449cf658d2 (patch) | |
| tree | d6d57a15aa340836aa98d87949cf68d2bff79ab1 /src/dedo.go | |
| parent | tests/dedo.go: Add missing call to test_commands() (diff) | |
| download | dedo-6c1b42c2f918b4d6c8f4f63c53ceb0449cf658d2.tar.gz dedo-6c1b42c2f918b4d6c8f4f63c53ceb0449cf658d2.tar.xz | |
src/dedo.go: Add "rm" command
Diffstat (limited to '')
| -rw-r--r-- | src/dedo.go | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/src/dedo.go b/src/dedo.go index 66919f0..e5702e2 100644 --- a/src/dedo.go +++ b/src/dedo.go @@ -3880,6 +3880,17 @@ func setExec(args argsT, db *DB, r io.Reader, w io.Writer) error { }) } +func rmExec(args argsT, db *DB, r io.Reader, w io.Writer) error { + return db.Update(func(tx *Tx) error { + bucket := tx.Bucket(args.bucket) + if bucket == nil { + return ErrBucketNotFound + } + + return bucket.Delete(args.key) + }) +} + func listExec(args argsT, db *DB, r io.Reader, w io.Writer) error { return db.View(func(tx *Tx) error { if len(args.bucket) == 0 { @@ -4007,6 +4018,11 @@ var commands = map[string]commandT{ getopt: setGetopt, exec: setExec, }, + "rm": commandT{ + name: "rm", + getopt: getGetopt, + exec: rmExec, + }, "list": commandT{ name: "list", getopt: noopGetopt, |