|
33 | 33 | from ..exceptions import FeatureError, NodeError |
34 | 34 | from ..helpers.util import version_to_model |
35 | 35 | from ..messages.requests import NodeInfoRequest, NodePingRequest, NodeResetRequest |
36 | | -from ..messages.responses import NodeInfoResponse, NodePingResponse |
| 36 | +from ..messages.responses import NodeInfoResponse, NodePingResponse, NodeResponseType |
37 | 37 | from .helpers import raise_not_loaded |
38 | 38 | from .helpers.cache import NodeCache |
39 | 39 | from .helpers.firmware import FEATURE_SUPPORTED_AT_FIRMWARE, SupportedVersions |
@@ -645,14 +645,17 @@ async def reset_node(self) -> None: |
645 | 645 | """Reset node present in the current Plugwise network.""" |
646 | 646 | timeout = 4 |
647 | 647 | request = NodeResetRequest( |
648 | | - self._send, self._mac_in_bytes, self.node_type, timeout |
| 648 | + self._send, self._mac_in_bytes, int(self.node_type), timeout |
649 | 649 | ) |
650 | 650 | response = await request.send() |
651 | | - if response is None or response.ack_id != NodeType.NODE_RESET_ACK: |
| 651 | + if response is None or getattr(response, "response_type", None) != NodeResponseType.NODE_RESET_ACK: |
| 652 | + ack = getattr(response, "ack_id", None) |
| 653 | + rtype = getattr(response, "response_type", None) |
652 | 654 | _LOGGER.warning( |
653 | | - "Node %s reset response is None or wrong ack_id %s received", |
| 655 | + "Node %s reset not acknowledged (ack_id=%s, response_type=%s)", |
654 | 656 | self._mac_in_str, |
655 | | - response.ack_id, |
| 657 | + ack, |
| 658 | + rtype, |
656 | 659 | ) |
657 | 660 |
|
658 | 661 | async def unload(self) -> None: |
|
0 commit comments