aioesphomeapi_device_connect_authenticate_subscribe_state_changes.py

1import asyncio
2from aioesphomeapi import APIClient
3
4async def main():
5    """Example usage of aioesphomeapi."""
6    # Establish connection
7    cli = APIClient("192.168.1.123", 6053, "password")
8    await cli.connect(login=True)
9
10    # Subscribe to state changes and service calls
11    async def on_state(state):
12        print(f"State changed: {state}")
13
14    # Start listening for events
15    await cli.subscribe_states(on_state)
16
17    # Keep the script running
18    while True:
19        await asyncio.sleep(1)
20
21if __name__ == "__main__":
22    asyncio.run(main())