Add big fat warning if node setup takes too long

Author: marcelveldt

matter_server/server/device_controller.py

@@ -1067,8 +1067,42 @@ async def _setup_node(self, node_id: int) -> None:
             return
         self._nodes_in_setup.add(node_id)
         node_logger = LOGGER.getChild(f"node_{node_id}")
-        try:
-            async with self._node_setup_throttle:
+        node_data = self._nodes[node_id]
+        log_timers: dict[int, asyncio.TimerHandle] = {}
+
+        def log_node_long_setup(time_start: float) -> None:
+            """Temporary measure to track a locked-up SDK issue in some (special) circumstances."""
+            time_mins = int((time.time() - time_start) / 60)
+            node_model = node_data.attributes.get(
+                "0/40/14", node_data.attributes.get("0/40/3", "")
+            )
+            node_name = f"Node {node_id} ({node_model})"
+
+            node_logger.error(
+                f"\n\nATTENTION: {node_name} did not complete setup in {time_mins} minutes.\n"  # noqa: G004
+                "This is an indication of a (connectivity) issue with this device. \n"
+                "Try powercycling this device and/or relocate it closer to a Border Router or \n"
+                "WiFi Access Point. If this issue persists, please create an issue report on \n"
+                "the Matter channel of the Home Assistant Discord server or on Github:\n"
+                "https://github.com/home-assistant/core/issues/new?assignees=&labels="
+                "integration%3A%20matter&projects=&template=bug_report.yml\n",
+            )
+            # reschedule itself
+            if TYPE_CHECKING:
+                assert self.server.loop
+            log_timers[node_id] = self.server.loop.call_later(
+                15 * 60, log_node_long_setup, time_start
+            )
+
+        async with self._node_setup_throttle:
+            time_start = time.time()
+            # we want to track nodes that take too long so we log it when we detect that
+            if TYPE_CHECKING:
+                assert self.server.loop
+            log_timers[node_id] = self.server.loop.call_later(
+                15 * 60, log_node_long_setup, time_start
+            )
+            try:
                 node_logger.info("Setting-up node...")
 
                 # try to resolve the node using the sdk first before do anything else
@@ -1086,7 +1120,7 @@ async def _setup_node(self, node_id: int) -> None:
                     return
 
                 # (re)interview node (only) if needed
-                node_data = self._nodes[node_id]
+
                 if (
                     # re-interview if we dont have any node attributes (empty node)
                     not node_data.attributes
@@ -1120,8 +1154,9 @@ async def _setup_node(self, node_id: int) -> None:
                     )
                     # NOTE: the node will be picked up by mdns discovery automatically
                     # when it becomes available again.
-        finally:
-            self._nodes_in_setup.discard(node_id)
+            finally:
+                log_timers[node_id].cancel()
+                self._nodes_in_setup.discard(node_id)
 
     async def _resolve_node(
         self, node_id: int, retries: int = 2, attempt: int = 1