Add async Websocket client (#212)

* Add base Websocket class

* Add Async Websocket client

* Rework structure and fix typing

* Fix typing

* Add testing

* Use breaks instead of zip(range(1), ...) in async event tests

* fixes from rebase

* Add config entry websocket methods and fix Domain.from_json usage

Use Domain.from_json_with_client() in websocket clients since Domain
requires a client reference. Add config entry methods (get, disable,
enable, ignore flow, subentries, subscribe) to RawWebsocketClient.

* Add async config entry methods and improve test coverage to 99%

Add async counterparts for all config entry websocket methods in
RawAsyncWebsocketClient. Add async tests for websocket state, entity,
config entry, and error path coverage. Fix conftest return type
annotation, replace zip(range) with break, and use pytest.raises
instead of try/except in error tests.

---------

Co-authored-by: Adam Logan <adamlogan73@gmail.com>

Author: mj23000

homeassistant_api/models/domains.py

@@ -383,9 +383,9 @@ class ServiceFieldSelectorObject(BaseModel):
 class ServiceFieldSelectorQRCode(BaseModel):
     data: str
     scale: Optional[Union[int, float]] = None
-    error_correction_level: Optional[
-        ServiceFieldSelectorQRCodeErrorCorrectionLevel
-    ] = None
+    error_correction_level: Optional[ServiceFieldSelectorQRCodeErrorCorrectionLevel] = (
+        None
+    )
     center_image: Optional[str] = None
 
 
@@ -614,14 +614,13 @@ def trigger(
 
     async def async_trigger(
         self, **service_data
-    ) -> Union[Tuple[State, ...], Tuple[Tuple[State, ...], dict[str, JSONType]]]:
+    ) -> Union[
+        Tuple[State, ...],
+        None,
+        dict[str, JSONType],
+        tuple[tuple[State, ...], dict[str, JSONType]],
+    ]:
         """Triggers the service associated with this object."""
-        from homeassistant_api import WebsocketClient  # prevent circular import
-
-        if isinstance(self.domain._client, WebsocketClient):
-            raise NotImplementedError(
-                "WebsocketClient does not support async/await syntax."
-            )
         try:
             return await self.domain._client.async_trigger_service_with_response(
                 self.domain.domain_id,
@@ -647,7 +646,12 @@ def __call__(
         Coroutine[
             Any,
             Any,
-            Union[Tuple[State, ...], Tuple[Tuple[State, ...], dict[str, JSONType]]],
+            Union[
+                Tuple[State, ...],
+                Tuple[Tuple[State, ...], dict[str, JSONType]],
+                dict[str, JSONType],
+                None,
+            ],
         ],
     ]:
         """