|
6 | 6 |
|
7 | 7 | from asyncio import Task, create_task, gather, sleep |
8 | 8 | from collections.abc import Callable, Coroutine |
9 | | -from datetime import UTC, datetime, timedelta |
| 9 | +from datetime import datetime, timedelta |
10 | 10 | import logging |
11 | 11 | from typing import Any |
12 | 12 |
|
|
15 | 15 | from ..constants import ENERGY_NODE_TYPES, UTF8 |
16 | 16 | from ..exceptions import CacheError, MessageError, NodeError, StickError, StickTimeout |
17 | 17 | from ..helpers.util import validate_mac |
18 | | -from ..messages.requests import ( |
19 | | - CircleClockSetRequest, |
20 | | - CircleMeasureIntervalRequest, |
21 | | - NodePingRequest, |
22 | | -) |
| 18 | +from ..messages.requests import CircleMeasureIntervalRequest, NodePingRequest |
23 | 19 | from ..messages.responses import ( |
24 | 20 | NODE_AWAKE_RESPONSE_ID, |
25 | 21 | NODE_JOIN_ID, |
@@ -524,25 +520,6 @@ async def stop(self) -> None: |
524 | 520 |
|
525 | 521 | # endregion |
526 | 522 |
|
527 | | - async def energy_reset_request(self, mac: str) -> None: |
528 | | - """Send an energy-reset to a Node.""" |
529 | | - self._validate_energy_node(mac) |
530 | | - node_protocols = self._nodes[mac].node_protocols |
531 | | - request = CircleClockSetRequest( |
532 | | - self._controller.send, |
533 | | - bytes(mac, UTF8), |
534 | | - datetime.now(tz=UTC), |
535 | | - node_protocols.max, |
536 | | - True, |
537 | | - ) |
538 | | - if (response := await request.send()) is None: |
539 | | - raise NodeError(f"Energy-reset for {mac} failed") |
540 | | - |
541 | | - if response.ack_id != NodeResponseType.CLOCK_ACCEPTED: |
542 | | - raise MessageError( |
543 | | - f"Unexpected NodeResponseType {response.ack_id!r} received as response to CircleClockSetRequest" |
544 | | - ) |
545 | | - |
546 | 523 | async def set_energy_intervals( |
547 | 524 | self, mac: str, consumption: int, production: int |
548 | 525 | ) -> None: |
|
0 commit comments