Fix event stream timeout at session level (#508)

Moves timeout fix from request level (#501) to session level, which is more appropriate since the session is created specifically for the Dahua client.

Changes:
- Add timeout=ClientTimeout(total=None) to ClientSession creation in __init__.py
- Revert request-level timeout fix from client.py

The session-level fix prevents the default 5-minute timeout from disconnecting infinite event streams while keeping regular API requests properly scoped.

Tested in production with no timeout errors.

Author: rmaher001

custom_components/dahua/__init__.py

@@ -12,7 +12,7 @@
 from homeassistant.components.tag import async_scan_tag
 import hashlib
 
-from aiohttp import ClientError, ClientResponseError, ClientSession, TCPConnector
+from aiohttp import ClientError, ClientResponseError, ClientSession, ClientTimeout, TCPConnector
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import CALLBACK_TYPE, HomeAssistant
 from homeassistant.exceptions import ConfigEntryNotReady, PlatformNotReady
@@ -98,7 +98,8 @@ def __init__(self, hass: HomeAssistant, events: list, address: str, port: int, r
         """Initialize the coordinator."""
         # Self signed certs are used over HTTPS so we'll disable SSL verification
         connector = TCPConnector(enable_cleanup_closed=True, ssl=SSL_CONTEXT)
-        self._session = ClientSession(connector=connector)
+        # Disable total timeout for infinite event stream (default 5-minute timeout causes disconnects)
+        self._session = ClientSession(connector=connector, timeout=ClientTimeout(total=None))
 
         # The client used to communicate with Dahua devices
         self.client: DahuaClient = DahuaClient(username, password, address, port, rtsp_port, self._session)

custom_components/dahua/client.py

@@ -759,18 +759,13 @@ async def stream_events(self, on_receive, events: list, channel: int):
         """
         # Use codes=[All] for all codes
         codes = ",".join(events)
-        heartbeat_interval = 5
-        url = "{0}/cgi-bin/eventManager.cgi?action=attach&codes=[{1}]&heartbeat={2}".format(
-            self._base, codes, heartbeat_interval
-        )
+        url = "{0}/cgi-bin/eventManager.cgi?action=attach&codes=[{1}]&heartbeat=5".format(self._base, codes)
         if self._username is not None and self._password is not None:
             response = None
 
             try:
                 auth = DigestAuth(self._username, self._password, self._session)
-                # Disable timeout for infinite event stream (fixes 5-minute disconnection)
-                timeout = aiohttp.ClientTimeout(total=None)
-                response = await auth.request("GET", url, timeout=timeout)
+                response = await auth.request("GET", url)
                 response.raise_for_status()
 
                 # https://docs.aiohttp.org/en/stable/streams.html