From 3952035579bd42d61746b2c2ad72d8ee05f10f66 Mon Sep 17 00:00:00 2001
From: Dan <Daniel-dev22@email.com>
Date: Mon, 1 Sep 2025 15:54:48 -0400
Subject: [PATCH] format MQTT code with ruff

---
 frigate/comms/mqtt.py | 62 ++++++++++++++++++++++++++-----------------
 1 file changed, 37 insertions(+), 25 deletions(-)

diff --git a/frigate/comms/mqtt.py b/frigate/comms/mqtt.py
index a47175163..84271066a 100644
--- a/frigate/comms/mqtt.py
+++ b/frigate/comms/mqtt.py
@@ -45,7 +45,7 @@ class MqttClient(Communicator):
         self._stop_reconnect = True
         if self._reconnect_thread and self._reconnect_thread.is_alive():
             self._reconnect_thread.join(timeout=5)
-        if hasattr(self, 'client'):
+        if hasattr(self, "client"):
             self.client.disconnect()
 
     def _set_initial_topics(self) -> None:
@@ -203,27 +203,31 @@ class MqttClient(Communicator):
         """Mqtt disconnection callback."""
         self.connected = False
         # Debug reason code thoroughly
-        reason_name = reason_code.getName() if hasattr(reason_code, 'getName') else str(reason_code)
-        reason_value = getattr(reason_code, 'value', reason_code)
-        logger.error(f"MQTT disconnected - reason: '{reason_name}', code: {reason_value}, type: {type(reason_code)}")
-        
+        reason_name = (
+            reason_code.getName()
+            if hasattr(reason_code, "getName")
+            else str(reason_code)
+        )
+        reason_value = getattr(reason_code, "value", reason_code)
+        logger.error(
+            f"MQTT disconnected - reason: '{reason_name}', code: {reason_value}, type: {type(reason_code)}"
+        )
+
         # Don't attempt reconnection if we're stopping or if it was a clean disconnect
         if self._stop_reconnect:
             logger.error("MQTT not reconnecting - stop flag set")
             return
-            
+
         if reason_code == 0:
             logger.error("MQTT not reconnecting - clean disconnect (code 0)")
             return
-            
+
         logger.error("MQTT will attempt reconnection...")
-            
+
         # Start reconnection in a separate thread to avoid blocking
         if not self._reconnect_thread or not self._reconnect_thread.is_alive():
             self._reconnect_thread = threading.Thread(
-                target=self._reconnect_loop,
-                name="mqtt-reconnect",
-                daemon=True
+                target=self._reconnect_loop, name="mqtt-reconnect", daemon=True
             )
             self._reconnect_thread.start()
 
@@ -321,45 +325,53 @@ class MqttClient(Communicator):
         attempt = 0
         while not self._stop_reconnect and not self.connected:
             attempt += 1
-            
-            logger.error(f"Will attempt MQTT reconnection in {self._reconnect_delay} seconds (attempt {attempt})")
-            
+
+            logger.error(
+                f"Will attempt MQTT reconnection in {self._reconnect_delay} seconds (attempt {attempt})"
+            )
+
             # Wait with ability to exit early if stopping
             for _ in range(self._reconnect_delay):
                 if self._stop_reconnect:
                     logger.error("MQTT reconnection stopped during delay")
                     return
                 time.sleep(1)
-                
+
             if self._stop_reconnect:
                 logger.error("MQTT reconnection stopped after delay")
                 break
-                
+
             try:
-                logger.error(f"Creating fresh MQTT client for reconnection attempt {attempt}...")
-                
+                logger.error(
+                    f"Creating fresh MQTT client for reconnection attempt {attempt}..."
+                )
+
                 # Clean up old client if it exists
-                if hasattr(self, 'client'):
+                if hasattr(self, "client"):
                     try:
                         self.client.disconnect()
                         self.client.loop_stop()
                     except Exception:
                         pass  # Ignore cleanup errors
-                
+
                 # Create completely fresh client and attempt connection
                 self._start()
-                
+
                 # Give the connection attempt some time to complete
                 for _ in range(5):  # Wait up to 5 seconds for connection
                     if self.connected:
-                        logger.error(f"MQTT fresh connection successful on attempt {attempt}!")
+                        logger.error(
+                            f"MQTT fresh connection successful on attempt {attempt}!"
+                        )
                         return
                     time.sleep(1)
-                    
-                logger.error(f"MQTT fresh connection attempt {attempt} timed out, will retry")
+
+                logger.error(
+                    f"MQTT fresh connection attempt {attempt} timed out, will retry"
+                )
                 # Continue the loop to retry
             except Exception as e:
                 logger.error(f"MQTT fresh connection attempt {attempt} failed: {e}")
                 # Continue the loop to retry
-                
+
         logger.error("MQTT reconnection loop finished")