feature: support hlen protocol

funky-eyes · Apr 17, 2024 · f5cf985 · f5cf985
1 parent 986d06f
commit f5cf985
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java b/src/main/java/icu/funkye/redispike/handler/process/impl/hash/HLenRequestProcessor.java
@@ -63,6 +63,6 @@ public void onFailure(AerospikeException exception) {
                 logger.error(exception.getMessage(), exception);
                 write(ctx, request);
             }
-        }, client.getWritePolicyDefault(), key, "hlen", "count_bins");
+        }, client.getWritePolicyDefault(), key, "hlen", "hash_count_bins");
     }
 }
diff --git a/src/main/resources/lua/hlen.lua b/src/main/resources/lua/hlen.lua
@@ -1,4 +1,4 @@
-function count_bins(rec)
+function hash_count_bins(rec)
     local bins = record.bin_names(rec)
     local bin_count = #bins
     return bin_count

diff --git a/src/test/java/icu/funkye/redispike/ServerTest.java b/src/test/java/icu/funkye/redispike/ServerTest.java
@@ -160,8 +160,8 @@ public void testhHash() {
             map.put("d", "e");
             result = jedis.hset(key, map);
             Assertions.assertEquals(result, 2);
-            /*            result = jedis.hlen(key);
-                        Assertions.assertEquals(result, map.size());*/
+            result = jedis.hlen(key);
+            Assertions.assertEquals(result, map.size());
             List<String> list = jedis.hmget(key, "b", "d");
             Assertions.assertEquals(list.size(), 2);
             list = jedis.hvals(key);