From eb81c510cc9eba0c1ed81baf0f8bb81fc6a562aa Mon Sep 17 00:00:00 2001
From: Gabriel Erzse <gabriel.erzse@gmail.com>
Date: Mon, 25 Mar 2024 15:08:55 +0200
Subject: [PATCH] Align Pipelined commands with UnifiedJedis (#3787)

* Align Pipelined commands with UnifiedJedis

Add some Pipelined commands that are available in UnifiedJedis but are
missing the pipelined version.

* Pipeline does not need scriptKill

Co-authored-by: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com>

* Undo script commands changes

---------

Co-authored-by: Gabriel Erzse <gabriel.erzse@redis.com>
Co-authored-by: M Sazzadul Hoque <7600764+sazzad16@users.noreply.github.com>
---
 .../java/redis/clients/jedis/PipeliningBase.java  | 15 +++++++++++++++
 .../commands/CuckooFilterPipelineCommands.java    |  2 ++
 .../RedisTimeSeriesPipelineCommands.java          |  4 ++++
 3 files changed, 21 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/PipeliningBase.java b/src/main/java/redis/clients/jedis/PipeliningBase.java
index 409b36270a..a9376f19d5 100644
--- a/src/main/java/redis/clients/jedis/PipeliningBase.java
+++ b/src/main/java/redis/clients/jedis/PipeliningBase.java
@@ -3879,6 +3879,16 @@ public Response<String> tsDeleteRule(String sourceKey, String destKey) {
   public Response<List<String>> tsQueryIndex(String... filters) {
     return appendCommand(commandObjects.tsQueryIndex(filters));
   }
+
+  @Override
+  public Response<TSInfo> tsInfo(String key) {
+    return appendCommand(commandObjects.tsInfo(key));
+  }
+
+  @Override
+  public Response<TSInfo> tsInfoDebug(String key) {
+    return appendCommand(commandObjects.tsInfoDebug(key));
+  }
   // RedisTimeSeries commands
 
   // RedisBloom commands
@@ -3987,6 +3997,11 @@ public Response<Boolean> cfExists(String key, String item) {
     return appendCommand(commandObjects.cfExists(key, item));
   }
 
+  @Override
+  public Response<List<Boolean>> cfMExists(String key, String... items) {
+    return appendCommand(commandObjects.cfMExists(key, items));
+  }
+
   @Override
   public Response<Boolean> cfDel(String key, String item) {
     return appendCommand(commandObjects.cfDel(key, item));
diff --git a/src/main/java/redis/clients/jedis/bloom/commands/CuckooFilterPipelineCommands.java b/src/main/java/redis/clients/jedis/bloom/commands/CuckooFilterPipelineCommands.java
index b911d741ea..c40d6a861b 100644
--- a/src/main/java/redis/clients/jedis/bloom/commands/CuckooFilterPipelineCommands.java
+++ b/src/main/java/redis/clients/jedis/bloom/commands/CuckooFilterPipelineCommands.java
@@ -26,6 +26,8 @@ public interface CuckooFilterPipelineCommands {
 
   Response<Boolean> cfExists(String key, String item);
 
+  Response<List<Boolean>> cfMExists(String key, String... items);
+
   Response<Boolean> cfDel(String key, String item);
 
   Response<Long> cfCount(String key, String item);
diff --git a/src/main/java/redis/clients/jedis/timeseries/RedisTimeSeriesPipelineCommands.java b/src/main/java/redis/clients/jedis/timeseries/RedisTimeSeriesPipelineCommands.java
index 85ad9e0b1e..288b3f195e 100644
--- a/src/main/java/redis/clients/jedis/timeseries/RedisTimeSeriesPipelineCommands.java
+++ b/src/main/java/redis/clients/jedis/timeseries/RedisTimeSeriesPipelineCommands.java
@@ -59,4 +59,8 @@ public interface RedisTimeSeriesPipelineCommands {
   Response<String> tsDeleteRule(String sourceKey, String destKey);
 
   Response<List<String>> tsQueryIndex(String... filters);
+
+  Response<TSInfo> tsInfo(String key);
+
+  Response<TSInfo> tsInfoDebug(String key);
 }