From 1470772a00faad4a5b4130e0fe47513e5618e31d Mon Sep 17 00:00:00 2001 From: alex Date: Sat, 11 Jul 2026 11:57:44 +0200 Subject: refactored some more commands to work with the new command registry --- pkg/commands/decr.go | 33 +++++++++++++++++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 pkg/commands/decr.go (limited to 'pkg/commands/decr.go') diff --git a/pkg/commands/decr.go b/pkg/commands/decr.go new file mode 100644 index 0000000..c598b46 --- /dev/null +++ b/pkg/commands/decr.go @@ -0,0 +1,33 @@ +package commands + +import ( + "errors" + "redisClone/pkg/core" + "strconv" +) + +func Decr(args []string, getShard func(k string) *core.Shard) interface{}{ + key := args[1] + shard := getShard(key) + item, exists := shard.Data[key] + if exists { + strValue, ok := item.Value.(string) + if !ok { + err := errors.New("value is not an integer or out of range") + return err + } + + currentInt, err := strconv.Atoi(strValue) + if err != nil { + err := errors.New("value is not an integer or out of range") + return err + } + + newValueStr := strconv.Itoa(currentInt - 1) + shard.Data[key] = core.Item{Value: newValueStr} + return currentInt - 1 + } else { + shard.Data[key] = core.Item{Value: "-1"} + return -1 + } +} \ No newline at end of file -- cgit v1.2.3