Add CLUSTER MYSHARDID command (#3423)

and update CLUSTER BUMPEPOCH command and other tests

Author: sazzad16

pom.xml

@@ -80,8 +80,8 @@
 		</dependency>
 		<dependency>
 			<groupId>org.hamcrest</groupId>
-			<artifactId>hamcrest-library</artifactId>
-			<version>1.3</version>
+			<artifactId>hamcrest</artifactId>
+			<version>2.2</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>

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

@@ -8827,7 +8827,7 @@ public String clusterSetConfigEpoch(long configEpoch) {
   public String clusterBumpEpoch() {
     checkIsInMultiOrPipeline();
     connection.sendCommand(CLUSTER, ClusterKeyword.BUMPEPOCH);
-    return connection.getStatusCodeReply();
+    return connection.getBulkReply();
   }
 
   @Override
@@ -8880,6 +8880,13 @@ public String clusterMyId() {
     return connection.getBulkReply();
   }
 
+  @Override
+  public String clusterMyShardId() {
+    checkIsInMultiOrPipeline();
+    connection.sendCommand(CLUSTER, ClusterKeyword.MYSHARDID);
+    return connection.getBulkReply();
+  }
+
   @Override
   public List<Map<String, Object>> clusterLinks() {
     checkIsInMultiOrPipeline();

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

@@ -319,7 +319,8 @@ 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;
+    COUNTKEYSINSLOT, SAVECONFIG, REPLICATE, LINKS, ADDSLOTSRANGE, DELSLOTSRANGE, BUMPEPOCH,
+    MYSHARDID;
 
     private final byte[] raw;
 

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

@@ -93,6 +93,8 @@ public interface ClusterCommands {
 
   String clusterMyId();
 
+  String clusterMyShardId();
+
   /**
    * return the information of all such peer links as an array, where each array element is a map that contains
    * attributes and their values for an individual link.

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

@@ -7,6 +7,9 @@
 
 import java.util.List;
 import java.util.Map;
+
+import org.hamcrest.MatcherAssert;
+import org.hamcrest.Matchers;
 import org.junit.After;
 import org.junit.AfterClass;
 import org.junit.Before;
@@ -211,6 +214,16 @@ public void clusterCountFailureReports() {
     assertEquals(0, node1.clusterCountFailureReports(node1.clusterMyId()));
   }
 
+  @Test
+  public void clusterMyId() {
+    MatcherAssert.assertThat(node1.clusterMyId(), Matchers.not(Matchers.isEmptyOrNullString()));
+  }
+
+  @Test
+  public void clusterMyShardId() {
+    MatcherAssert.assertThat(node1.clusterMyShardId(), Matchers.not(Matchers.isEmptyOrNullString()));
+  }
+
   @Test
   public void testClusterEpoch() {
     try {
@@ -222,7 +235,7 @@ public void testClusterEpoch() {
 
   @Test
   public void ClusterBumpEpoch() {
-    node1.clusterBumpEpoch();
+    MatcherAssert.assertThat(node1.clusterBumpEpoch(), Matchers.matchesPattern("^BUMPED|STILL [0-9]+$"));
   }
 
 }