Add CLUSTER SHARDS command support (#2984)

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

@@ -8826,12 +8826,20 @@ public String clusterFailover(ClusterFailoverOption failoverOption) {
   }
 
   @Override
+  @Deprecated
   public List<Object> clusterSlots() {
     checkIsInMultiOrPipeline();
     connection.sendCommand(CLUSTER, ClusterKeyword.SLOTS);
     return connection.getObjectMultiBulkReply();
   }
 
+  @Override
+  public List<Object> clusterShards() {
+    checkIsInMultiOrPipeline();
+    connection.sendCommand(CLUSTER, ClusterKeyword.SHARDS);
+    return connection.getObjectMultiBulkReply();
+  }
+
   @Override
   public String clusterMyId() {
     checkIsInMultiOrPipeline();

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

@@ -357,7 +357,7 @@ public static enum ClusterKeyword implements Rawable {
     MEET, RESET, INFO, FAILOVER, SLOTS, NODES, REPLICAS, SLAVES, MYID, ADDSLOTS, DELSLOTS,
     GETKEYSINSLOT, SETSLOT, NODE, MIGRATING, IMPORTING, STABLE, FORGET, FLUSHSLOTS, KEYSLOT,
     COUNTKEYSINSLOT, SAVECONFIG, REPLICATE, LINKS, ADDSLOTSRANGE, DELSLOTSRANGE, BUMPEPOCH,
-    MYSHARDID;
+    MYSHARDID, SHARDS;
 
     private final byte[] raw;
 

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

@@ -79,8 +79,24 @@ public interface ClusterCommands {
 
   String clusterFailover(ClusterFailoverOption failoverOption);
 
+  /**
+   * {@code CLUSTER SLOTS} command is deprecated since Redis 7.
+   *
+   * @deprecated Use {@link ClusterCommands#clusterShards()}.
+   */
+  @Deprecated
   List<Object> clusterSlots();
 
+  /**
+   * {@code CLUSTER SHARDS} returns details about the shards of the cluster.
+   * This command replaces the {@code CLUSTER SLOTS} command from Redis 7,
+   * by providing a more efficient and extensible representation of the cluster.
+   *
+   * @return a list of shards, with each shard containing two objects, 'slots' and 'nodes'.
+   * @see <a href="https://redis.io/commands/cluster-shards/">CLUSTER SHARDS</a>
+   */
+  List<Object> clusterShards();
+
   String clusterReset();
 
   /**

src/test/java/redis/clients/jedis/commands/jedis/ClusterCommandsTest.java

@@ -189,6 +189,39 @@ public void clusterSlots() {
     node1.clusterDelSlots(3000, 3001, 3002);
   }
 
+  @Test
+  public void clusterShards() {
+    assertEquals("OK", node1.clusterAddSlots(3100, 3101, 3102));
+
+    List<Object> shards = node1.clusterShards();
+    assertNotNull(shards);
+    assertTrue(shards.size() > 0);
+
+    for (Object shardInfoObj : shards) {
+      assertNotNull(shardInfoObj);
+      List<Object> shardInfo = (List<Object>) shardInfoObj;
+      assertTrue(shardInfo.size() >= 4);
+
+      assertTrue(shardInfo.get(0) instanceof byte[]);
+      assertEquals("slots", new String((byte[]) shardInfo.get(0)));
+
+      List<Object> slots = (List<Object>) shardInfo.get(1);
+      for (Object slotInfoObj : slots) {
+        assertTrue(slotInfoObj instanceof Long);
+      }
+
+      assertTrue(shardInfo.get(2) instanceof byte[]);
+      assertEquals("nodes", new String((byte[]) shardInfo.get(2)));
+
+      List<Object> nodes = (List<Object>) shardInfo.get(3);
+      for (Object nodeInfoObj : nodes) {
+        List<Object> nodeInfo = (List<Object>) nodeInfoObj;
+        assertTrue(nodeInfo.size() >= 14);
+      }
+    }
+    node1.clusterDelSlots(3100, 3101, 3102);
+  }
+
   @Test
   public void clusterLinks() throws InterruptedException {
     List<Map<String, Object>> links = node1.clusterLinks();