🚑 Fix AsyncClient initialization to avoid blocking event loop

Prevent event loop blocking caused by lazy httpx client initialization

The AsyncSignalRGBClient was previously initializing the httpx.AsyncClient
lazily during async operations, which could block the event loop when
the SSL certificates were loaded. This change ensures:

- Initialize httpx.AsyncClient immediately during constructor call
- Add client() property accessor to safely access the client instance
- Properly handle client existence checks before closing in __aexit__
- Fix code style issues and linting warnings in async implementation
- Add consistent null checks before aclose() calls in cleanup methods

This fix is particularly important when using the library in async
frameworks like Home Assistant where blocking the event loop can cause
performance issues.

Author: hyperb1iss

signalrgb/async_client.py

@@ -57,15 +57,21 @@ def __init__(self, host: str = DEFAULT_HOST, port: int = DEFAULT_PORT, timeout:
         self._base_url = f"http://{host}:{port}"
         self._timeout = timeout
         self._effects_cache: list[Effect] | None = None
-        self._client = httpx.AsyncClient(timeout=timeout)
+        self._client = httpx.AsyncClient(timeout=self._timeout)
 
     async def __aenter__(self) -> AsyncSignalRGBClient:
         """Async context manager entry."""
         return self
 
     async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None:
         """Async context manager exit."""
-        await self._client.aclose()
+        if self._client:
+            await self._client.aclose()
+
+    @property
+    def client(self) -> httpx.AsyncClient:
+        """Get the HTTPX client instance."""
+        return self._client
 
     @asynccontextmanager
     async def _request_context(self, method: str, endpoint: str, **kwargs: Any) -> AsyncIterator[dict[str, Any]]:
@@ -93,7 +99,7 @@ async def _request_context(self, method: str, endpoint: str, **kwargs: Any) -> A
             pass
 
         try:
-            response = await self._client.request(method, url, **kwargs)
+            response = await self.client.request(method, url, **kwargs)
             response.raise_for_status()
 
             if debug:
@@ -114,7 +120,7 @@ async def _request_context(self, method: str, endpoint: str, **kwargs: Any) -> A
                         error = Error.from_dict(json_data["errors"][0])
                     else:
                         error = Error(title=str(e))
-                except Exception: # noqa: BLE001
+                except Exception:  # noqa: BLE001
                     error = Error(title=str(e))
             else:
                 error = Error(title=str(e))
@@ -679,7 +685,8 @@ async def aclose(self) -> None:
 
         This method ensures resources are properly released when the client is no longer needed.
         """
-        await self._client.aclose()
+        if self._client:
+            await self._client.aclose()
 
     async def get_effects_cached(self) -> list[Effect]:
         """Get effects with caching.

signalrgb/client.py

@@ -22,7 +22,8 @@
 )
 
 # Define a TypeVar for the return type
-T = TypeVar('T')
+T = TypeVar("T")
+
 
 class SignalRGBClient:
     """Client for interacting with the SignalRGB API.