Add support for CLUSTER DELSLOTSRANGE (#2018)

* delslotsrange

* test

* linters

* skip test

* linters

Author: dvora-h

redis/client.py

@@ -714,6 +714,7 @@ class AbstractRedis:
         "CLUSTER COUNT-FAILURE-REPORTS": lambda x: int(x),
         "CLUSTER COUNTKEYSINSLOT": lambda x: int(x),
         "CLUSTER DELSLOTS": bool_ok,
+        "CLUSTER DELSLOTSRANGE": bool_ok,
         "CLUSTER FAILOVER": bool_ok,
         "CLUSTER FORGET": bool_ok,
         "CLUSTER INFO": parse_cluster_info,

redis/cluster.py

@@ -311,6 +311,7 @@ class RedisCluster(RedisClusterCommands):
             [
                 "CLUSTER COUNTKEYSINSLOT",
                 "CLUSTER DELSLOTS",
+                "CLUSTER DELSLOTSRANGE",
                 "CLUSTER GETKEYSINSLOT",
                 "CLUSTER SETSLOT",
             ],
@@ -324,6 +325,7 @@ class RedisCluster(RedisClusterCommands):
         "CLUSTER COUNT-FAILURE-REPORTS": int,
         "CLUSTER COUNTKEYSINSLOT": int,
         "CLUSTER DELSLOTS": bool,
+        "CLUSTER DELSLOTSRANGE": bool,
         "CLUSTER FAILOVER": bool,
         "CLUSTER FORGET": bool,
         "CLUSTER GETKEYSINSLOT": list,

redis/commands/cluster.py

@@ -287,6 +287,17 @@ def cluster_delslots(self, *slots):
         """
         return [self.execute_command("CLUSTER DELSLOTS", slot) for slot in slots]
 
+    def cluster_delslotsrange(self, *slots):
+        """
+        Similar to the CLUSTER DELSLOTS command.
+        The difference is that CLUSTER DELSLOTS takes a list of hash slots to remove
+        from the node, while CLUSTER DELSLOTSRANGE takes a list of slot ranges to remove
+        from the node.
+
+        For more information check https://redis.io/commands/cluster-delslotsrange
+        """
+        return self.execute_command("CLUSTER DELSLOTSRANGE", *slots)
+
     def cluster_failover(self, target_node, option=None):
         """
         Forces a slave to perform a manual failover of its master

tests/test_cluster.py

@@ -891,6 +891,13 @@ def test_cluster_delslots(self):
         assert node0.redis_connection.connection.read_response.called
         assert node1.redis_connection.connection.read_response.called
 
+    @skip_if_server_version_lt("7.0.0")
+    def test_cluster_delslotsrange(self, r):
+        node = r.get_random_node()
+        mock_node_resp(node, "OK")
+        r.cluster_addslots(node, 1, 2, 3, 4, 5)
+        assert r.cluster_delslotsrange(1, 5)
+
     def test_cluster_failover(self, r):
         node = r.get_random_node()
         mock_node_resp(node, "OK")