Merge branch 'master' of https://github.com/alash3al/redix

Author: alash3al

README.md

@@ -136,6 +136,7 @@ Supported Commands
 - `HINCR <HASHMAP> <key> [<by>]`
 - `HTTL <HASHMAP> <key>`, the same as `TTL` but for `HASHMAP`
 - `HKEYS <HASHMAP>`
+- `HLEN <HASHMAP>`
 
 ## # LIST
 > I applied a new concept, you can push or push-unique values into the list,

commands_hash.go

@@ -225,6 +225,34 @@ func hexistsCommand(c Context) {
 	c.WriteInt(found)
 }
 
+func hlenCommand(c Context) {
+	if len(c.args) < 1 {
+		c.WriteError("HLEN command requires at least one argument: HLEN <hashmap>")
+		return
+	}
+
+	found := 0
+	prefix := c.args[0] + "/{HASH}/"
+
+	err := c.db.Scan(kvstore.ScannerOptions{
+		FetchValues:   false,
+		IncludeOffset: true,
+		Prefix:        prefix,
+		Offset:        prefix,
+		Handler: func(_, _ string) bool {
+			found++
+			return true
+		},
+	})
+
+	if err != nil {
+		c.WriteError(err.Error())
+		return
+	}
+
+	c.WriteInt(found)
+}
+
 // hincrCommand - HINCR <hash> <key> [<number>]
 func hincrCommand(c Context) {
 	if len(c.args) < 2 {

kvstore/leveldb/leveldb.go

@@ -213,7 +213,7 @@ func (ldb *LevelDB) Scan(scannerOpt kvstore.ScannerOptions) error {
 	for iter.Next() {
 		key := iter.Key()
 		val := strings.SplitN(string(iter.Value()), ";", 2)[1]
-		if valid(key) && !scannerOpt.Handler(string(key), string(val)) {
+		if !valid(key) || !scannerOpt.Handler(string(key), string(val)) {
 			break
 		}
 	}

vars.go

@@ -77,6 +77,7 @@ var (
 		"hexists": hexistsCommand,
 		"hincr":   hincrCommand,
 		"httl":    httlCommand,
+		"hlen":    hlenCommand,
 
 		// pubsub
 		"publish":        publishCommand,