Fix review comments #597

Author: rootart

django_redis/client/default.py

@@ -517,6 +517,17 @@ def encode(self, value: EncodableT) -> Union[bytes, int]:
 
         return value
 
+    def _decode_iterable_result(
+        self, result: Any, covert_to_set: bool = True
+    ) -> Union[List[Any], None, Any]:
+        if result is None:
+            return None
+        if isinstance(result, list):
+            if covert_to_set:
+                return {self.decode(value) for value in result}
+            return [self.decode(value) for value in result]
+        return self.decode(result)
+
     def get_many(
         self,
         keys: Iterable[KeyT],
@@ -828,7 +839,7 @@ def sdiff(
         *keys: KeyT,
         version: Optional[int] = None,
         client: Optional[Redis] = None,
-    ) -> Set:
+    ) -> Set[Any]:
         if client is None:
             client = self.get_client(write=False)
 
@@ -855,7 +866,7 @@ def sinter(
         *keys: KeyT,
         version: Optional[int] = None,
         client: Optional[Redis] = None,
-    ) -> Set:
+    ) -> Set[Any]:
         if client is None:
             client = self.get_client(write=False)
 
@@ -910,7 +921,7 @@ def smembers(
         key: KeyT,
         version: Optional[int] = None,
         client: Optional[Redis] = None,
-    ) -> Set:
+    ) -> Set[Any]:
         if client is None:
             client = self.get_client(write=False)
 
@@ -945,11 +956,7 @@ def spop(
 
         nkey = self.make_key(key, version=version)
         result = client.spop(nkey, count)
-        if result is None:
-            return None
-        if isinstance(result, list):
-            return {self.decode(value) for value in result}
-        return self.decode(result)
+        return self._decode_iterable_result(result)
 
     def srandmember(
         self,
@@ -963,11 +970,7 @@ def srandmember(
 
         key = self.make_key(key, version=version)
         result = client.srandmember(key, count)
-        if result is None:
-            return None
-        if isinstance(result, list):
-            return [self.decode(value) for value in result]
-        return self.decode(result)
+        return self._decode_iterable_result(result, covert_to_set=False)
 
     def srem(
         self,
@@ -1035,7 +1038,7 @@ def sunion(
         *keys: KeyT,
         version: Optional[int] = None,
         client: Optional[Redis] = None,
-    ) -> Set:
+    ) -> Set[Any]:
         if client is None:
             client = self.get_client(write=False)
 

django_redis/client/sharded.py

@@ -367,7 +367,7 @@ def smembers(
         key: KeyT,
         version: Optional[int] = None,
         client: Optional[Redis] = None,
-    ) -> Set:
+    ) -> Set[Any]:
         if client is None:
             key = self.make_key(key, version=version)
             client = self.get_server(key)