1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
"""Run an example script to quickly test the guardian."""
import asyncio
import logging
from aioguardian import Client
from aioguardian.errors import GuardianError
_LOGGER = logging.getLogger(__name__)
async def main() -> None:
"""Create the aiohttp session and run the example."""
logging.basicConfig(level=logging.INFO)
async with Client("172.16.11.208") as guardian:
try:
valve_status_response = await guardian.valve.status()
_LOGGER.info(
"valve_status_response command response: %s", valve_status_response
)
valve_open_response = await guardian.valve.open()
_LOGGER.info(
"valve_open_response command response: %s", valve_open_response
)
# Give the valve a chance to open fully so that the valve_close command
# doesn't error out:
await asyncio.sleep(3)
valve_close_response = await guardian.valve.close()
_LOGGER.info(
"valve_close_response command response: %s", valve_close_response
)
except GuardianError as err:
_LOGGER.info(err)
asyncio.run(main())
|
