add tests for decr_version

Author: amirreza8002

tests/test_backend.py

@@ -536,6 +536,28 @@ def test_ttl_incr_version_no_timeout(self, cache: ValkeyCache):
 
         assert my_value == "hello world!"
 
+    def test_decr_version(self, cache: ValkeyCache):
+        cache.set("keytest", 2, version=3)
+        res = cache.get("keytest", version=3)
+        assert res == 2
+
+        cache.decr_version("keytest", version=3)
+
+        res = cache.get("keytest", version=3)
+        assert res is None
+
+        res = cache.get("keytest", version=2)
+        assert res == 2
+
+    def test_ttl_decr_version_no_timeout(self, cache: ValkeyCache):
+        cache.set("my_key", "hello world!", version=3, timeout=None)
+
+        cache.decr_version("my_key", version=3)
+
+        my_value = cache.get("my_key", version=2)
+
+        assert my_value == "hello world!"
+
     def test_delete_pattern(self, cache: ValkeyCache):
         if isinstance(cache.client, DefaultClusterClient):
             pytest.skip("cluster client has a specific test")

tests/test_cache_options.py

@@ -36,6 +36,7 @@ def reverse_key(key: str) -> str:
     "hlen",
     "incr",
     "incr_version",
+    "decr_version",
     "keys",
     "lock",
     "mget",

tests/tests_async/test_backend.py

@@ -516,6 +516,28 @@ async def test_ttl_incr_version_no_timeout(self, cache: AsyncValkeyCache):
 
         assert my_value == "hello world!"
 
+    async def test_decr_version(self, cache: AsyncValkeyCache):
+        await cache.aset("keytest", 2, version=3)
+        res = await cache.aget("keytest", version=3)
+        assert res == 2
+
+        await cache.decr_version("keytest", version=3)
+
+        res = await cache.aget("keytest", version=3)
+        assert res is None
+
+        res = await cache.aget("keytest", version=2)
+        assert res == 2
+
+    async def test_ttl_decr_version_no_timeout(self, cache: AsyncValkeyCache):
+        await cache.set("my_key", "hello world!", timeout=None, version=3)
+
+        await cache.adecr_version("my_key", version=3)
+
+        my_value = await cache.get("my_key", version=2)
+
+        assert my_value == "hello world!"
+
     async def test_delete_pattern(self, cache: AsyncValkeyCache):
         for key in ["foo-aa", "foo-ab", "foo-bb", "foo-bc"]:
             await cache.aset(key, "foo")

tests/tests_async/test_cache_options.py

@@ -30,6 +30,7 @@
     "hlen",
     "incr",
     "incr_version",
+    "decr_version",
     "keys",
     "lock",
     "mget",