Skip to content

Commit 0d401df

Browse files
committed
Import, extra response-check
1 parent 0a53ce9 commit 0d401df

1 file changed

Lines changed: 11 additions & 2 deletions

File tree

plugwise_usb/network/__init__.py

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,11 @@
2020
)
2121
from ..exceptions import CacheError, MessageError, NodeError, StickError, StickTimeout
2222
from ..helpers.util import validate_mac
23-
from ..messages.requests import CircleMeasureIntervalRequest, NodePingRequest
23+
from ..messages.requests import (
24+
CircleMeasureIntervalRequest,
25+
NodePingRequest,
26+
StickNetworkInfoRequest,
27+
)
2428
from ..messages.responses import (
2529
NODE_AWAKE_RESPONSE_ID,
2630
NODE_JOIN_ID,
@@ -30,6 +34,7 @@
3034
NodeRejoinResponse,
3135
NodeResponseType,
3236
PlugwiseResponse,
37+
StickNetworkInfoResponse,
3338
)
3439
from ..nodes import get_plugwise_node
3540
from .registry import StickNetworkRegister
@@ -349,8 +354,12 @@ async def discover_network_coordinator(self, load: bool = False) -> bool:
349354
return False
350355

351356
# Collect network info
352-
request = StickNetworkInfoRequest(self._controller.send)
357+
request = StickNetworkInfoRequest(self._controller.send, None)
353358
if (network_info := await request.send()) is not None:
359+
if not isinstance(network_info, StickNetworkInfoResponse):
360+
raise MessageError(
361+
f"Invalid response message type ({response.__class__.__name__}) received, expected StickNetworkInfoResponse"
362+
)
354363
self._channel = network_info.channel
355364

356365
if await self._discover_node(

0 commit comments

Comments
 (0)