Fixing last linter errors. Fixes needed for pubsub message handling with hiredis.

Author: petyaslavova

redis/_parsers/hiredis.py

@@ -196,6 +196,12 @@ def __init__(self, socket_read_size: int):
         self._reader = None
         self.pubsub_push_handler_func = self.handle_pubsub_push_response
         self.invalidation_push_handler_func = None
+        self._hiredis_PushNotificationType = None
+
+    async def handle_pubsub_push_response(self, response):
+        logger = getLogger("push_response")
+        logger.debug("Push response: " + str(response))
+        return response
 
     def on_connect(self, connection):
         import hiredis
@@ -215,7 +221,7 @@ def on_connect(self, connection):
 
         try:
             self._hiredis_PushNotificationType = getattr(
-                hiredis, "PushNotificationType", None
+                hiredis, "PushNotification", None
             )
         except AttributeError:
             # hiredis < 3.2
@@ -257,6 +263,7 @@ async def read_response(
             response = self._reader.gets(False)
         else:
             response = self._reader.gets()
+
         while response is NOT_ENOUGH_DATA:
             await self.read_from_socket()
             if disable_decoding:

redis/asyncio/connection.py

@@ -576,11 +576,7 @@ async def read_response(
         read_timeout = timeout if timeout is not None else self.socket_timeout
         host_error = self._host_error()
         try:
-            if (
-                read_timeout is not None
-                and self.protocol in ["3", 3]
-                and not HIREDIS_AVAILABLE
-            ):
+            if read_timeout is not None and self.protocol in ["3", 3]:
                 async with async_timeout(read_timeout):
                     response = await self._parser.read_response(
                         disable_decoding=disable_decoding, push_request=push_request

tests/test_asyncio/test_pubsub.py

@@ -17,7 +17,6 @@
 import redis.asyncio as redis
 from redis.exceptions import ConnectionError
 from redis.typing import EncodableT
-from redis.utils import HIREDIS_AVAILABLE
 from tests.conftest import get_protocol_version, skip_if_server_version_lt
 
 from .compat import aclosing, create_task, mock