Guard subscribing to NODE_JOIN_ID

bouwew · bouwew · commit c121ca84672a · 2025-05-05T11:34:56.000+02:00
diff --git a/plugwise_usb/network/__init__.py b/plugwise_usb/network/__init__.py
@@ -177,9 +177,10 @@ async def _subscribe_to_node_events(self) -> None:
             (NODE_AWAKE_RESPONSE_ID,),
             None,
         )
-        self._unsubscribe_node_join = await self._controller.subscribe_to_messages(
-            self.node_join_available_message, None, (NODE_JOIN_ID,), None
-        )
+        if self.accept_join_request:
+            self._unsubscribe_node_join = await self._controller.subscribe_to_messages(
+                self.node_join_available_message, None, (NODE_JOIN_ID,), None
+            )
         self._unsubscribe_node_rejoin = await self._controller.subscribe_to_messages(
             self.node_rejoin_message, None, (NODE_REJOIN_ID,), None
         )

Original file line number	Diff line number	Diff line change
`@@ -177,9 +177,10 @@ async def _subscribe_to_node_events(self) -> None:`
`177`	`177`	`(NODE_AWAKE_RESPONSE_ID,),`
`178`	`178`	`None,`
`179`	`179`	`)`
`180`		`- self._unsubscribe_node_join = await self._controller.subscribe_to_messages(`
`181`		`- self.node_join_available_message, None, (NODE_JOIN_ID,), None`
`182`		`- )`
	`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`	`+ )`
`183`	`184`	`self._unsubscribe_node_rejoin = await self._controller.subscribe_to_messages(`
`184`	`185`	`self.node_rejoin_message, None, (NODE_REJOIN_ID,), None`
`185`	`186`	`)`