Support XINFO STREAM FULL

src/main/java/redis/clients/jedis/BuilderFactory.java

@@ -7,6 +7,9 @@
 import org.json.JSONObject;
 
 import redis.clients.jedis.exceptions.JedisException;
+import redis.clients.jedis.resps.StreamConsumerFullInfo;
+import redis.clients.jedis.resps.StreamFullInfo;
+import redis.clients.jedis.resps.StreamGroupFullInfo;
 import redis.clients.jedis.resps.LCSMatchResult.MatchedPosition;
 import redis.clients.jedis.resps.LCSMatchResult.Position;
 import redis.clients.jedis.resps.*;
@@ -1109,6 +1112,128 @@ public String toString() {
     }
   };
 
+  private static final Builder<List<StreamConsumerFullInfo>> STREAM_CONSUMER_FULL_INFO_LIST = new Builder<List<StreamConsumerFullInfo>>() {
+
+    final Map<String, Builder> mappingFunctions = createDecoderMap();
+
+    private Map<String, Builder> createDecoderMap() {
+
+      Map<String, Builder> tempMappingFunctions = new HashMap<>();
+      tempMappingFunctions.put(StreamConsumerFullInfo.NAME, STRING);
+      tempMappingFunctions.put(StreamConsumerFullInfo.SEEN_TIME, LONG);
+      tempMappingFunctions.put(StreamConsumerFullInfo.PEL_COUNT, LONG);
+      tempMappingFunctions.put(StreamConsumerFullInfo.PENDING, LONG_LIST);
+
+      return tempMappingFunctions;
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public List<StreamConsumerFullInfo> build(Object data) {
+      if (null == data) {
+        return null;
+      }
+
+      List<StreamConsumerFullInfo> list = new ArrayList<>();
+      List<Object> streamsEntries = (List<Object>) data;
+
+      for (Object streamsEntry : streamsEntries) {
+        List<Object> consumerInfoList = (List<Object>) streamsEntry;
+        Iterator<Object> consumerInfoIterator = consumerInfoList.iterator();
+        StreamConsumerFullInfo consumerInfo = new StreamConsumerFullInfo(createMapFromDecodingFunctions(consumerInfoIterator, mappingFunctions));
+        list.add(consumerInfo);
+      }
+      return list;
+    }
+
+    @Override
+    public String toString() {
+      return "List<StreamConsumerFullInfo>";
+    }
+  };
+
+  private static final Builder<List<StreamGroupFullInfo>> STREAM_GROUP_FULL_INFO_LIST = new Builder<List<StreamGroupFullInfo>>() {
+
+    final Map<String, Builder> mappingFunctions = createDecoderMap();
+
+    private Map<String, Builder> createDecoderMap() {
+
+      Map<String, Builder> tempMappingFunctions = new HashMap<>();
+      tempMappingFunctions.put(StreamGroupFullInfo.NAME, STRING);
+      tempMappingFunctions.put(StreamGroupFullInfo.CONSUMERS, STREAM_CONSUMER_FULL_INFO_LIST);
+      tempMappingFunctions.put(StreamGroupFullInfo.PENDING, STRING_LIST);
+      tempMappingFunctions.put(StreamGroupFullInfo.LAST_DELIVERED, STREAM_ENTRY_ID);
+      tempMappingFunctions.put(StreamGroupFullInfo.PEL_COUNT, LONG);
+
+      return tempMappingFunctions;
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public List<StreamGroupFullInfo> build(Object data) {
+      if (null == data) {
+        return null;
+      }
+
+      List<StreamGroupFullInfo> list = new ArrayList<>();
+      List<Object> streamsEntries = (List<Object>) data;
+
+      for (Object streamsEntry : streamsEntries) {
+
+        List<Object> groupInfo = (List<Object>) streamsEntry;
+
+        Iterator<Object> groupInfoIterator = groupInfo.iterator();
+
+        StreamGroupFullInfo groupFullInfo = new StreamGroupFullInfo(createMapFromDecodingFunctions(
+                groupInfoIterator, mappingFunctions));
+        list.add(groupFullInfo);
+
+      }
+      return list;
+    }
+
+    @Override
+    public String toString() {
+      return "List<StreamGroupFullInfo>";
+    }
+  };
+
+  public static final Builder<StreamFullInfo> STREAM_INFO_FULL = new Builder<StreamFullInfo>() {
+
+    final Map<String, Builder> mappingFunctions = createDecoderMap();
+
+    private Map<String, Builder> createDecoderMap() {
+
+      Map<String, Builder> tempMappingFunctions = new HashMap<>();
+      tempMappingFunctions.put(StreamFullInfo.LAST_GENERATED_ID, STREAM_ENTRY_ID);
+      tempMappingFunctions.put(StreamFullInfo.LENGTH, LONG);
+      tempMappingFunctions.put(StreamFullInfo.RADIX_TREE_KEYS, LONG);
+      tempMappingFunctions.put(StreamFullInfo.RADIX_TREE_NODES, LONG);
+      tempMappingFunctions.put(StreamFullInfo.GROUPS, STREAM_GROUP_FULL_INFO_LIST);
+      tempMappingFunctions.put(StreamFullInfo.ENTRIES, STREAM_ENTRY_LIST);
+
+      return tempMappingFunctions;
+    }
+
+    @Override
+    @SuppressWarnings("unchecked")
+    public StreamFullInfo build(Object data) {
+      if (null == data) {
+        return null;
+      }
+
+      List<Object> streamsEntries = (List<Object>) data;
+      Iterator<Object> iterator = streamsEntries.iterator();
+
+      return new StreamFullInfo(createMapFromDecodingFunctions(iterator, mappingFunctions));
+    }
+
+    @Override
+    public String toString() {
+      return "StreamFullInfo";
+    }
+  };
+
   public static final Builder<StreamPendingSummary> STREAM_PENDING_SUMMARY = new Builder<StreamPendingSummary>() {
     @Override
     @SuppressWarnings("unchecked")

src/main/java/redis/clients/jedis/CommandObjects.java

@@ -2292,6 +2292,22 @@ public final CommandObject<Object> xinfoStream(byte[] key) {
     return new CommandObject<>(commandArguments(XINFO).add(STREAM).key(key), BuilderFactory.RAW_OBJECT);
   }
 
+  public final CommandObject<StreamFullInfo> xinfoStreamFull(byte[] key, int count) {
+    return new CommandObject<>(commandArguments(XINFO).add(STREAM).key(key).add(FULL).add(COUNT).add(count), BuilderFactory.STREAM_INFO_FULL);
+  }
+
+  public final CommandObject<StreamFullInfo> xinfoStreamFull(byte[] key) {
+    return new CommandObject<>(commandArguments(XINFO).add(STREAM).key(key).add(FULL), BuilderFactory.STREAM_INFO_FULL);
+  }
+
+  public final CommandObject<StreamFullInfo> xinfoStreamFull(String key, int count) {
+    return new CommandObject<>(commandArguments(XINFO).add(STREAM).key(key).add(FULL).add(COUNT).add(count), BuilderFactory.STREAM_INFO_FULL);
+  }
+
+  public final CommandObject<StreamFullInfo> xinfoStreamFull(String key) {
+    return new CommandObject<>(commandArguments(XINFO).add(STREAM).key(key).add(FULL), BuilderFactory.STREAM_INFO_FULL);
+  }
+
   public final CommandObject<List<Object>> xinfoGroup(byte[] key) {
     return new CommandObject<>(commandArguments(XINFO).add(GROUPS).key(key), BuilderFactory.RAW_OBJECT_LIST);
   }

src/main/java/redis/clients/jedis/Jedis.java

@@ -4532,6 +4532,30 @@ public Object xinfoStream(byte[] key) {
     return connection.executeCommand(commandObjects.xinfoStream(key));
   }
 
+  @Override
+  public StreamFullInfo xinfoStreamFull(byte[] key) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(byte[] key, int count) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(String key) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(String key, int count) {
+    checkIsInMultiOrPipeline();
+    return connection.executeCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
   @Override
   public List<Object> xinfoGroup(byte[] key) {
     checkIsInMultiOrPipeline();

src/main/java/redis/clients/jedis/MultiNodePipelineBase.java

@@ -1403,6 +1403,27 @@ public Response<StreamInfo> xinfoStream(String key) {
     return appendCommand(commandObjects.xinfoStream(key));
   }
 
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
   @Override
   public Response<List<StreamGroupInfo>> xinfoGroup(String key) {
     return appendCommand(commandObjects.xinfoGroup(key));

src/main/java/redis/clients/jedis/Pipeline.java

@@ -2694,6 +2694,27 @@ public Response<Object> xinfoStream(byte[] key) {
     return appendCommand(commandObjects.xinfoStream(key));
   }
 
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
   @Override
   public Response<List<Object>> xinfoGroup(byte[] key) {
     return appendCommand(commandObjects.xinfoGroup(key));

src/main/java/redis/clients/jedis/Protocol.java

@@ -258,7 +258,7 @@ public static enum Keyword implements Rawable {
     RETRYCOUNT, USAGE, SAMPLES, STREAM, GROUPS, CONSUMERS, SETUSER, GETUSER, DELUSER, WHOAMI, USERS,
     CAT, GENPASS, LOG, INCR, SAVE, JUSTID, WITHVALUES, UNBLOCK, NOMKSTREAM, MINID, DB, ABSTTL, TO,
     TIMEOUT, ABORT, NX, XX, EX, PX, EXAT, PXAT, CH, WITHCOORD, WITHDIST, WITHHASH, STOREDIST, COPY,
-    KEEPTTL, AUTH, AUTH2, INFO, CHANNELS, NUMPAT, NUMSUB, LCS, KEYS, STRINGS,
+    KEEPTTL, AUTH, AUTH2, INFO, CHANNELS, NUMPAT, NUMSUB, LCS, KEYS, STRINGS, FULL,
     ANY, FROMMEMBER, FROMLONLAT, BYRADIUS, BYBOX;
 
     private final byte[] raw;

src/main/java/redis/clients/jedis/TransactionBase.java

@@ -1457,6 +1457,27 @@ public Response<StreamInfo> xinfoStream(String key) {
     return appendCommand(commandObjects.xinfoStream(key));
   }
 
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(byte[] key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key) {
+    return appendCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public Response<StreamFullInfo> xinfoStreamFull(String key, int count) {
+    return appendCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
   @Override
   public Response<List<StreamGroupInfo>> xinfoGroup(String key) {
     return appendCommand(commandObjects.xinfoGroup(key));

src/main/java/redis/clients/jedis/UnifiedJedis.java

@@ -2575,6 +2575,26 @@ public StreamInfo xinfoStream(String key) {
     return executeCommand(commandObjects.xinfoStream(key));
   }
 
+  @Override
+  public StreamFullInfo xinfoStreamFull(byte[] key) {
+    return executeCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(byte[] key, int count) {
+    return executeCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(String key) {
+    return executeCommand(commandObjects.xinfoStreamFull(key));
+  }
+
+  @Override
+  public StreamFullInfo xinfoStreamFull(String key, int count) {
+    return executeCommand(commandObjects.xinfoStreamFull(key, count));
+  }
+
   @Override
   public List<StreamGroupInfo> xinfoGroup(String key) {
     return executeCommand(commandObjects.xinfoGroup(key));

src/main/java/redis/clients/jedis/commands/StreamBinaryCommands.java

@@ -4,6 +4,7 @@
 import java.util.Map;
 
 import redis.clients.jedis.params.*;
+import redis.clients.jedis.resps.StreamFullInfo;
 
 public interface StreamBinaryCommands {
 
@@ -57,6 +58,21 @@ List<Object> xautoclaimJustId(byte[] key, byte[] groupName, byte[] consumerName,
 
   Object xinfoStream(byte[] key);
 
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  StreamFullInfo xinfoStreamFull(byte[] key);
+
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @param count stream info count
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  StreamFullInfo xinfoStreamFull(byte[] key, int count);
+
   List<Object> xinfoGroup(byte[] key);
 
   List<Object> xinfoConsumers(byte[] key, byte[] group);

src/main/java/redis/clients/jedis/commands/StreamCommands.java

@@ -237,6 +237,21 @@ Map.Entry<StreamEntryID, List<StreamEntryID>> xautoclaimJustId(String key, Strin
    */
   StreamInfo xinfoStream (String key);
 
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  StreamFullInfo xinfoStreamFull(String key);
+
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @param count stream info count
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  StreamFullInfo xinfoStreamFull(String key, int count);
+
   /**
    * Introspection command used in order to retrieve different information about groups in the stream
    * @param key Stream name

src/main/java/redis/clients/jedis/commands/StreamPipelineBinaryCommands.java

@@ -5,6 +5,7 @@
 
 import redis.clients.jedis.Response;
 import redis.clients.jedis.params.*;
+import redis.clients.jedis.resps.StreamFullInfo;
 
 public interface StreamPipelineBinaryCommands {
 //
@@ -60,6 +61,21 @@ Response<List<Object>> xautoclaimJustId(byte[] key, byte[] groupName, byte[] con
 
   Response<Object> xinfoStream(byte[] key);
 
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  Response<StreamFullInfo> xinfoStreamFull(byte[] key);
+
+  /**
+   * Introspection command used in order to retrieve all information about the stream
+   * @param key Stream name
+   * @param count stream info count
+   * @return {@link StreamFullInfo} that contains information about the stream
+   */
+  Response<StreamFullInfo> xinfoStreamFull(byte[] key, int count);
+
   Response<List<Object>> xinfoGroup(byte[] key);
 
   Response<List<Object>> xinfoConsumers(byte[] key, byte[] group);