Skip to content

Commit 70251be

Browse files
committed
Fix subscription-guarding
1 parent a6d9c4f commit 70251be

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

plugwise_usb/network/__init__.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -177,10 +177,9 @@ async def _subscribe_to_node_events(self) -> None:
177177
(NODE_AWAKE_RESPONSE_ID,),
178178
None,
179179
)
180-
if self.accept_join_request:
181-
self._unsubscribe_node_join = await self._controller.subscribe_to_messages(
182-
self.node_join_available_message, None, (NODE_JOIN_ID,), None
183-
)
180+
self._unsubscribe_node_join = await self._controller.subscribe_to_messages(
181+
self.node_join_available_message, None, (NODE_JOIN_ID,), None
182+
)
184183
self._unsubscribe_node_rejoin = await self._controller.subscribe_to_messages(
185184
self.node_rejoin_message, None, (NODE_REJOIN_ID,), None
186185
)
@@ -245,7 +244,7 @@ async def node_join_available_message(self, response: PlugwiseResponse) -> bool:
245244
f"Invalid response message type ({response.__class__.__name__}) received, expected NodeJoinAvailableResponse"
246245
)
247246
mac = response.mac_decoded
248-
if await self.register_node(mac):
247+
if self.accept_join_request:
249248
await self._notify_node_event_subscribers(NodeEvent.JOIN, mac)
250249
return True
251250

0 commit comments

Comments
 (0)