[FEAT] Add new commands

- New commands: exists, hexists, keys, hkeys, lpos, lrem
- Fix copy(client) function
- Handle empty response from host

Project.toml

@@ -1,7 +1,7 @@
 name = "Jedis"
 uuid = "b89ccfe0-2c5f-46f6-b89b-da3e1c2e286f"
 authors = ["Jack Chan <[email protected]>"]
-version = "0.1.0"
+version = "0.1.1"
 
 [deps]
 Sockets = "6462fe0b-24de-5631-8697-dd941f90decc"

src/Jedis.jl

@@ -3,9 +3,9 @@ module Jedis
 export Client, Pipeline, RedisError, get_global_client, set_global_client, disconnect!, reconnect!,
        add!, copy, wait_until_subscribed, wait_until_unsubscribed, wait_until_channel_unsubscribed,
        wait_until_pattern_unsubscribed, execute, auth, select, ping, flushdb, flushall, quit,
-       set, get, del, setex, expire, ttl, multi, exec, multi_exec, pipeline, hset, hget, hgetall,
-       hmget, hdel, rpush, lpush, lpop, rpop, blpop, brpop, llen, lrange, publish, subscribe,
-       unsubscribe, psubscribe, punsubscribe
+       set, get, del, exists, hexists, keys, hkeys, setex, expire, ttl, multi, exec, multi_exec, 
+       pipeline, hset, hget, hgetall, hmget, hdel, rpush, lpush, lpos, lrem, lpop, rpop, blpop, 
+       brpop, llen, lrange, publish, subscribe, unsubscribe, psubscribe, punsubscribe
 
 using Sockets
 

src/client.jl

@@ -92,7 +92,7 @@ end
 
 Creates a new Client instance, copying the connection parameters of the input.
 """
-function copy(client::Client)
+function Base.copy(client::Client)
     return Client(; host=client.host, port=client.port, database=client.database, password=client.password, username=client.username)
 end
 

src/commands.jl

@@ -61,6 +61,34 @@ Delete a key.
 """
 del(key, keys...; client=get_global_client()) = execute(["DEL", key, keys...], client)
 
+"""
+    exists(key[, keys...])
+
+Determine if a key exists.
+"""
+exists(key, keys...; client=get_global_client()) = execute(["EXISTS", key, keys...], client)
+
+"""
+    hexists(key, field)
+
+Determine if a hash field exists.
+"""
+hexists(key, field; client=get_global_client()) = execute(["HEXISTS", key, field], client)
+
+"""
+    keys(pattern)
+
+Find all keys matching the pattern.
+"""
+Base.keys(pattern; client=get_global_client()) = execute(["KEYS", pattern], client)
+
+"""
+    hkeys(key)
+
+Get all fields in a hash.
+"""
+hkeys(key; client=get_global_client()) = execute(["HKEYS", key], client)
+
 """
     setex(key, seconds, value)
 
@@ -199,6 +227,20 @@ Append one or multiple elements to a list.
 """
 rpush(key, element, elements...; client=get_global_client()) = execute(["RPUSH", key, element, elements...], client)
 
+"""
+    lpos(key, element[, rank, num_matches, len])
+
+Return the index of matching element on a list.
+"""
+lpos(key, element, rank="", num_matches="", len=""; client=get_global_client()) = execute(["LPOS", key, element, [isempty(rank) ? "" : "RANK", rank]..., [isempty(num_matches) ? "" : "COUNT", num_matches]..., [isempty(len) ? "" : "MAXLEN", len]...], client)
+
+"""
+    lrem(key, count, element)
+
+Remove elements from a list.
+"""
+lrem(key, count, element; client=get_global_client()) = execute(["LREM", key, count, element], client)
+
 """
     lpop(key)
 

src/protocol.jl

@@ -81,6 +81,11 @@ Reads any bytes before the next CRLF (\r\n) in a TCPScoket, blocks if no bytes a
 """
 function recv(s::TCPSocket)
     line = readline(s)
+
+    if isempty(line)
+        return nothing
+    end
+
     handler = RESPHandler[line[1]]
     return handler(s, line[2:end])
 end