Hlen

README.md

@@ -142,6 +142,12 @@ SELECT CLUSTER_COUNTKEYSINSLOT(<key_id>)
 SELECT DBSIZE()
 ```
 
+### HLEN
+
+```sql
+SELECT HLEN('some-key')
+```
+
 ### LLEN
 
 ```sql

commands.md

@@ -114,7 +114,7 @@
 | HINCRBY                       | 🚧
 | HINCRBYFLOAT                  | 🚧
 | HKEYS                         | 🚧
-| HLEN                          | 🚧
+| HLEN                          | ✅ [`HLEN`](https://github.com/augmentable-dev/reqlite/tree/main/internal/redis/hlen)
 | HMGET                         | 🚧
 | HMSET                         | 🚧
 | HSET                          | 🚧

internal/redis/hlen/hlen.go

@@ -0,0 +1,35 @@
+package hlen
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/go-redis/redis/v8"
+	"go.riyazali.net/sqlite"
+)
+
+type hlen struct {
+	rdb *redis.Client
+}
+
+func (f *hlen) Args() int           { return -1 }
+func (f *hlen) Deterministic() bool { return false }
+func (f *hlen) Apply(ctx *sqlite.Context, values ...sqlite.Value) {
+	var key string
+
+	if len(values) >= 1 {
+		key = values[0].Text()
+	} else {
+		ctx.ResultError(fmt.Errorf("must supply argument to redis hlen command"))
+		return
+	}
+
+	result := f.rdb.HLen(context.TODO(), key)
+
+	ctx.ResultInt64(result.Val())
+}
+
+// New returns a sqlite function for reading the contents of a file
+func New(rdb *redis.Client) sqlite.Function {
+	return &hlen{rdb}
+}

internal/redis/hlen/hlen_test.go

@@ -0,0 +1,46 @@
+package hlen_test
+
+import (
+	"testing"
+
+	"github.com/augmentable-dev/reqlite/internal/redis/hlen"
+	_ "github.com/augmentable-dev/reqlite/internal/sqlite"
+	"github.com/go-redis/redismock/v8"
+	"github.com/jmoiron/sqlx"
+	_ "github.com/mattn/go-sqlite3"
+	"go.riyazali.net/sqlite"
+)
+
+func TestHLen(t *testing.T) {
+	rdb, mock := redismock.NewClientMock()
+
+	sqlite.Register(func(api *sqlite.ExtensionApi) (sqlite.ErrorCode, error) {
+		if err := api.CreateFunction("hlen", hlen.New(rdb)); err != nil {
+			return sqlite.SQLITE_ERROR, err
+		}
+		return sqlite.SQLITE_OK, nil
+	})
+
+	mock.ExpectHLen("mykey").SetVal(1024)
+	db, err := sqlx.Open("sqlite3", ":memory:")
+	if err != nil {
+		t.Fatal(err)
+	}
+	defer db.Close()
+
+	row := db.QueryRow("SELECT hlen('mykey')")
+	err = row.Err()
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	var s string
+	err = row.Scan(&s)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if err := mock.ExpectationsWereMet(); err != nil {
+		t.Error(err)
+	}
+}

pkg/ext/ext.go

@@ -17,6 +17,7 @@ import (
 	"github.com/augmentable-dev/reqlite/internal/redis/dump"
 	"github.com/augmentable-dev/reqlite/internal/redis/echo"
 	"github.com/augmentable-dev/reqlite/internal/redis/hgetall"
+	"github.com/augmentable-dev/reqlite/internal/redis/hlen"
 	"github.com/augmentable-dev/reqlite/internal/redis/llen"
 	"github.com/augmentable-dev/reqlite/internal/redis/lrange"
 	"github.com/go-redis/redis/v8"
@@ -98,6 +99,10 @@ func init() {
 			return sqlite.SQLITE_ERROR, err
 		}
 
+		if err := api.CreateFunction("hlen", hlen.New(rdb)); err != nil {
+			return sqlite.SQLITE_ERROR, err
+		}
+
 		if err := api.CreateFunction("llen", llen.New(rdb)); err != nil {
 			return sqlite.SQLITE_ERROR, err
 		}