refactored some more commands to work with the new command registry

1 files changed, 33 insertions, 0 deletions

diff --git a/pkg/commands/incr.go b/pkg/commands/incr.go
new file mode 100644
index 0000000..1b9a493
--- /dev/null
+++ b/pkg/commands/incr.go
@@ -0,0 +1,33 @@
+package commands
+
+import (
+	"errors"
+	"redisClone/pkg/core"
+	"strconv"
+)
+
+func Incr(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