Allow EVAL_RO and EVALSHA_RO to be routed to read replica (#2494)

* fix typo (Lue -> Lua)

* run eval_ro, evalsha_ro test on redis cluster

* Add eval_ro, evalsha_ro to read only commands

* assert that commands are run in a round robin manner

Co-authored-by: zach.lee <zach.lee@sendbird.com>
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>

Author: 3 people

redis/commands/cluster.py

@@ -52,6 +52,8 @@
     [
         "BITCOUNT",
         "BITPOS",
+        "EVAL_RO",
+        "EVALSHA_RO",
         "EXISTS",
         "GEODIST",
         "GEOHASH",

redis/commands/core.py

@@ -5139,7 +5139,7 @@ def eval_ro(
         """
         The read-only variant of the EVAL command
 
-        Execute the read-only Lue ``script`` specifying the ``numkeys`` the script
+        Execute the read-only Lua ``script`` specifying the ``numkeys`` the script
         will touch and the key names and argument values in ``keys_and_args``.
         Returns the result of the script.
 

tests/test_cluster.py

@@ -561,7 +561,15 @@ def parse_response_mock_third(connection, *args, **options):
                 read_cluster.get("foo")
                 read_cluster.get("foo")
                 read_cluster.get("foo")
-                mocks["send_command"].assert_has_calls([call("READONLY")])
+                mocks["send_command"].assert_has_calls(
+                    [
+                        call("READONLY"),
+                        call("GET", "foo"),
+                        call("READONLY"),
+                        call("GET", "foo"),
+                        call("GET", "foo"),
+                    ]
+                )
 
     def test_keyslot(self, r):
         """

tests/test_scripting.py

@@ -67,7 +67,6 @@ def test_eval_multiply(self, r):
 
     @skip_if_server_version_lt("7.0.0")
     @skip_if_redis_enterprise()
-    @pytest.mark.onlynoncluster
     def test_eval_ro(self, r):
         r.set("a", "b")
         assert r.eval_ro("return redis.call('GET', KEYS[1])", 1, "a") == b"b"
@@ -157,7 +156,6 @@ def test_evalsha(self, r):
 
     @skip_if_server_version_lt("7.0.0")
     @skip_if_redis_enterprise()
-    @pytest.mark.onlynoncluster
     def test_evalsha_ro(self, r):
         r.set("a", "b")
         get_sha = r.script_load("return redis.call('GET', KEYS[1])")