Fix RuntimeError: no running event loop in MQTT reconnection

- Fixed RuntimeError when _on_connection_interrupted_internal tries to create
  reconnection task from MQTT callback thread without event loop
- Fixed RuntimeWarning about _reconnect_with_backoff coroutine never being awaited
- Added _start_reconnect_task() helper method to properly create tasks within event loop
- Uses existing _schedule_coroutine() for thread-safe task scheduling
- Prevents crashes during automatic reconnection after connection interruptions

Fixes issue seen in Home Assistant logs:
RuntimeError: no running event loop
RuntimeWarning: coroutine '_reconnect_with_backoff' was never awaited

Author: eman

CHANGELOG.rst

@@ -205,6 +205,16 @@ Changed
 Fixed
 -----
 
+- **Critical Bug**: Thread-safe reconnection task creation from MQTT callbacks
+  
+  - Fixed ``RuntimeError: no running event loop`` when connection is interrupted
+  - Fixed ``RuntimeWarning: coroutine '_reconnect_with_backoff' was never awaited``
+  - Connection interruption callbacks run in separate threads without event loops
+  - Implemented ``_start_reconnect_task()`` helper method to properly create reconnection tasks
+  - Uses existing ``_schedule_coroutine()`` method for thread-safe task scheduling
+  - Prevents crashes during automatic reconnection after connection interruptions
+  - Ensures reconnection tasks are properly awaited and executed
+
 - **Critical Bug**: Thread-safe event emission from MQTT callbacks
 
   - Fixed ``RuntimeError: no running event loop in thread 'Dummy-1'``

src/nwp500/mqtt_client.py

@@ -273,7 +273,7 @@ def _on_connection_interrupted_internal(self, connection, error, **kwargs):
             and (not self._reconnect_task or self._reconnect_task.done())
         ):
             _logger.info("Starting automatic reconnection...")
-            self._reconnect_task = asyncio.create_task(self._reconnect_with_backoff())
+            self._schedule_coroutine(self._start_reconnect_task())
 
     def _on_connection_resumed_internal(self, connection, return_code, session_present, **kwargs):
         """Internal handler for connection resumption."""
@@ -299,6 +299,16 @@ def _on_connection_resumed_internal(self, connection, return_code, session_prese
         if self.config.enable_command_queue:
             self._schedule_coroutine(self._send_queued_commands())
 
+    async def _start_reconnect_task(self):
+        """
+        Start the reconnect task within the event loop.
+        
+        This is a helper method to create the reconnect task from within
+        a coroutine that's scheduled via _schedule_coroutine.
+        """
+        if not self._reconnect_task or self._reconnect_task.done():
+            self._reconnect_task = asyncio.create_task(self._reconnect_with_backoff())
+
     async def _reconnect_with_backoff(self):
         """
         Attempt to reconnect with exponential backoff.