Skip to content

Add async Websocket client #212

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
GrandMoff100 merged 9 commits into from
Mar 22, 2026
Merged

Add async Websocket client #212

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
d7132f5
Add base Websocket class
mj23000 Sep 10, 2025
dfd0349
Add Async Websocket client
mj23000 Sep 10, 2025
85f2e60
Rework structure and fix typing
mj23000 Sep 15, 2025
17c8845
Fix typing
mj23000 Sep 22, 2025
71e40fb
Add testing
mj23000 Sep 24, 2025
a731185
Use breaks instead of zip(range(1), ...) in async event tests
mj23000 Sep 25, 2025
b4de87a
fixes from rebase
adamlogan73 Mar 22, 2026
01ba5b3
Add config entry websocket methods and fix Domain.from_json usage
adamlogan73 Mar 22, 2026
4e70cdf
Add async config entry methods and improve test coverage to 99%
adamlogan73 Mar 22, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 15 additions & 11 deletions homeassistant_api/models/domains.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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


Expand Down Expand Up @@ -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,
Expand All @@ -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,
],
],
]:
"""
Expand Down
Loading
Loading