Add unit tests

Author: peperon

tests/test_asyncio/test_sentinel.py

@@ -3,6 +3,8 @@
 
 import pytest
 import pytest_asyncio
+from redis.asyncio.client import StrictRedis
+
 import redis.asyncio.sentinel
 from redis import exceptions
 from redis.asyncio.sentinel import (
@@ -363,3 +365,27 @@ async def test_redis_master_usage(deployed_sentinel):
     r = await deployed_sentinel.master_for("redis-py-test", db=0)
     await r.set("foo", "bar")
     assert (await r.get("foo")) == "bar"
+
+
+@pytest.mark.onlynoncluster
+async def test_sentinel_commands_with_strict_redis_client(request):
+    sentinel_ips = request.config.getoption("--sentinels")
+    sentinel_host, sentinel_port = sentinel_ips.split(",")[0].split(":")
+    protocol = request.config.getoption("--protocol", 2)
+
+    client = StrictRedis(
+        host=sentinel_host, port=sentinel_port, decode_responses=True, protocol=protocol
+    )
+    # skipping commands that change the state of the sentinel setup
+    assert isinstance(
+        await client.sentinel_get_master_addr_by_name("redis-py-test"), tuple
+    )
+    assert isinstance(await client.sentinel_master("redis-py-test"), dict)
+    assert isinstance(await client.sentinel_masters(), dict)
+
+    assert isinstance(await client.sentinel_sentinels("redis-py-test"), list)
+    assert isinstance(await client.sentinel_slaves("redis-py-test"), list)
+
+    assert isinstance(await client.sentinel_ckquorum("redis-py-test"), bool)
+
+    await client.close()

tests/test_sentinel.py

@@ -2,6 +2,8 @@
 from unittest import mock
 
 import pytest
+from redis.client import StrictRedis
+
 import redis.sentinel
 from redis import exceptions
 from redis.sentinel import (
@@ -342,3 +344,25 @@ def test_redis_master_usage(deployed_sentinel):
     r = deployed_sentinel.master_for("redis-py-test", db=0)
     r.set("foo", "bar")
     assert r.get("foo") == "bar"
+
+
+@pytest.mark.onlynoncluster
+def test_sentinel_commands_with_strict_redis_client(request):
+    sentinel_ips = request.config.getoption("--sentinels")
+    sentinel_host, sentinel_port = sentinel_ips.split(",")[0].split(":")
+    protocol = request.config.getoption("--protocol", 2)
+
+    client = StrictRedis(
+        host=sentinel_host, port=sentinel_port, decode_responses=True, protocol=protocol
+    )
+    # skipping commands that change the state of the sentinel setup
+    assert isinstance(client.sentinel_get_master_addr_by_name("redis-py-test"), tuple)
+    assert isinstance(client.sentinel_master("redis-py-test"), dict)
+    assert isinstance(client.sentinel_masters(), dict)
+
+    assert isinstance(client.sentinel_sentinels("redis-py-test"), list)
+    assert isinstance(client.sentinel_slaves("redis-py-test"), list)
+
+    assert isinstance(client.sentinel_ckquorum("redis-py-test"), bool)
+
+    client.close()