Adding ROLE Command (#1610)

Co-authored-by: Chayim <[email protected]>

Author: AvitalFineRedis

redis/commands/core.py

@@ -333,6 +333,16 @@ def bgsave(self, schedule=True, **kwargs):
             pieces.append("SCHEDULE")
         return self.execute_command("BGSAVE", *pieces, **kwargs)
 
+    def role(self):
+        """
+        Provide information on the role of a Redis instance in
+        the context of replication, by returning if the instance
+        is currently a master, slave, or sentinel.
+
+        For more information check https://redis.io/commands/role
+        """
+        return self.execute_command("ROLE")
+
     def client_kill(self, address, **kwargs):
         """Disconnects the client at ``address`` (ip:port)
 
@@ -864,11 +874,15 @@ def slowlog_get(self, num=None, **kwargs):
 
         For more information check https://redis.io/commands/slowlog-get
         """
+        from redis.client import NEVER_DECODE
+
         args = ["SLOWLOG GET"]
         if num is not None:
             args.append(num)
         decode_responses = self.get_connection_kwargs().get("decode_responses", False)
-        return self.execute_command(*args, decode_responses=decode_responses, **kwargs)
+        if decode_responses is True:
+            kwargs[NEVER_DECODE] = []
+        return self.execute_command(*args, **kwargs)
 
     def slowlog_len(self, **kwargs):
         """

tests/test_commands.py

@@ -653,6 +653,13 @@ def test_ping(self, r):
     def test_quit(self, r):
         assert r.quit()
 
+    @skip_if_server_version_lt("2.8.12")
+    @pytest.mark.onlynoncluster
+    def test_role(self, r):
+        assert r.role()[0] == b"master"
+        assert isinstance(r.role()[1], int)
+        assert isinstance(r.role()[2], list)
+
     @pytest.mark.onlynoncluster
     def test_slowlog_get(self, r, slowlog):
         assert r.slowlog_reset()