Fix tests

Author: uglide

src/test/java/redis/clients/jedis/ClusterCommandObjectsTest.java

@@ -27,7 +27,7 @@ public class ClusterCommandObjectsTest {
 
   @BeforeEach
   public void setUp() {
-    clusterCommandObjects = new ClusterCommandObjects();
+    clusterCommandObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
   }
 
   @Test
@@ -472,7 +472,7 @@ public void testGetKeyHashSlots_withByteArrayKey_worksCorrectly() {
   @Test
   public void testGroupArgumentsByKeyHashSlot_withKeyPreProcessor_usesPreprocessedSlot() {
     // Create ClusterCommandObjects with a key preprocessor that adds a hash tag prefix
-    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects();
+    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
     // The prefix "{sameSlot}:" ensures all keys hash to the same slot
     clusterCmdObjects.setKeyArgumentPreProcessor(
       new redis.clients.jedis.util.PrefixedKeyArgumentPreProcessor("{sameSlot}:"));
@@ -519,7 +519,7 @@ public void testGroupArgumentsByKeyHashSlot_withKeyPreProcessor_usesPreprocessed
    */
   @Test
   public void testGroupArgumentsByKeyValueHashSlot_withKeyPreProcessor_usesPreprocessedSlot() {
-    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects();
+    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
     clusterCmdObjects.setKeyArgumentPreProcessor(
       new redis.clients.jedis.util.PrefixedKeyArgumentPreProcessor("{sameSlot}:"));
 
@@ -557,7 +557,7 @@ public void testGroupArgumentsByKeyValueHashSlot_withKeyPreProcessor_usesPreproc
    */
   @Test
   public void testGroupArgumentsByKeyHashSlot_withKeyPreProcessor_differentSlotsAfterPreprocess() {
-    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects();
+    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
     // This preprocessor changes the hash tag, causing keys to hash to different slots
     clusterCmdObjects.setKeyArgumentPreProcessor(key -> {
       String keyStr = (String) key;
@@ -594,7 +594,7 @@ public void testGroupArgumentsByKeyHashSlot_withKeyPreProcessor_differentSlotsAf
    */
   @Test
   public void testGroupArgumentsByKeyHashSlot_withKeyPreProcessor_binaryKeys() {
-    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects();
+    ClusterCommandObjects clusterCmdObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
     clusterCmdObjects.setKeyArgumentPreProcessor(
       new redis.clients.jedis.util.PrefixedKeyArgumentPreProcessor("{sameSlot}:"));
 

src/test/java/redis/clients/jedis/UnboundRedisClusterClientTest.java

@@ -256,7 +256,7 @@ public void testReadFromReplicas() throws Exception {
 
     DefaultJedisClientConfig READ_REPLICAS_CLIENT_CONFIG = DefaultJedisClientConfig.builder()
         .password(endpoint.getPassword()).readOnlyForRedisClusterReplicas().build();
-    ClusterCommandObjects commandObjects = new ClusterCommandObjects();
+    ClusterCommandObjects commandObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
     try (RedisClusterClient jedisCluster = RedisClusterClient.builder()
         .nodes(Collections.singleton(nodeInfo1))
         .clientConfig(READ_REPLICAS_CLIENT_CONFIG)

src/test/java/redis/clients/jedis/executors/ClusterCommandExecutorTest.java

@@ -1241,7 +1241,7 @@ public void mgetMultiShardReturnsValuesInCorrectOrderWhenKeysSpanMultipleSlots()
     when(connectionHandler.getConnection(ArgumentMatchers.any(CommandArguments.class)))
         .thenReturn(connection);
 
-    ClusterCommandObjects commandObjects = new ClusterCommandObjects();
+    ClusterCommandObjects commandObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
 
     // Try many different key combinations including ones where keys hash to different slots
     for (int i = 0; i < 100; i++) {
@@ -1336,7 +1336,7 @@ public void mgetMultiShardReturnsValuesInCorrectOrderForInterleavedSlots() {
       mockedStatic.when(() -> JedisClusterCRC16.getSlot(key2)).thenReturn(200);
       mockedStatic.when(() -> JedisClusterCRC16.getSlot(key3)).thenReturn(100);
 
-      ClusterCommandObjects commandObjects = new ClusterCommandObjects();
+      ClusterCommandObjects commandObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
 
       // The fix should create 3 separate commands (not 2) to preserve order
       List<CommandObject<List<String>>> mgetCommands = commandObjects.mgetMultiShard(key1, key2,
@@ -1410,7 +1410,7 @@ public void mgetMultiShardCombinesConsecutiveKeysWithSameSlotIntoOneCommand() {
       mockedStatic.when(() -> JedisClusterCRC16.getSlot(key3)).thenReturn(200);
       mockedStatic.when(() -> JedisClusterCRC16.getSlot(key4)).thenReturn(200);
 
-      ClusterCommandObjects commandObjects = new ClusterCommandObjects();
+      ClusterCommandObjects commandObjects = new ClusterCommandObjects(RedisProtocol.RESP2);
 
       // Consecutive keys with the same slot should be combined into one command
       List<CommandObject<List<String>>> mgetCommands = commandObjects.mgetMultiShard(key1, key2,