From f49c29874c046a8f45d9e9ecf036878f531feccf Mon Sep 17 00:00:00 2001
From: Rightup <lloyd@rightup.co.uk>
Date: Tue, 14 Jul 2026 08:51:33 +0100
Subject: [PATCH] fix(mqtt_handler): change log level from info to debug for
 connection messages

---
 repeater/data_acquisition/mqtt_handler.py | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/repeater/data_acquisition/mqtt_handler.py b/repeater/data_acquisition/mqtt_handler.py
index d5abd88..5e92c34 100644
--- a/repeater/data_acquisition/mqtt_handler.py
+++ b/repeater/data_acquisition/mqtt_handler.py
@@ -327,7 +327,7 @@ class _BrokerConnection:
         """MQTT connection callback"""
         rc_value = int(getattr(rc, "value", rc)) if rc is not None else -1
         if rc_value == 0:
-            logger.info(f"Connected to {self.broker['name']}")
+            logger.debug(f"Connected to {self.broker['name']}")
             self._running = True
             self._reconnect_attempts = 0  # Reset counter on success
             # Successful connect can race with a previously scheduled timer; cancel it.
@@ -362,7 +362,7 @@ class _BrokerConnection:
         self._running = False
 
         if self._shutdown_requested:
-            logger.info(f"Clean disconnect from {self.broker['name']}")
+            logger.debug(f"Clean disconnect from {self.broker['name']}")
             if self._on_disconnect_callback:
                 self._on_disconnect_callback(self.broker["name"])
             return
@@ -381,7 +381,7 @@ class _BrokerConnection:
             if was_running:  # Only reconnect if we were intentionally connected
                 self._schedule_reconnect(reason=error_msg)
         else:
-            logger.info(f"Clean disconnect from {self.broker['name']}")
+            logger.debug(f"Clean disconnect from {self.broker['name']}")
 
         if self._on_disconnect_callback:
             self._on_disconnect_callback(self.broker["name"])
@@ -398,7 +398,7 @@ class _BrokerConnection:
         delay = min(5 * (2**self._reconnect_attempts), self._max_reconnect_delay)
         self._reconnect_attempts += 1
 
-        logger.info(
+        logger.debug(
             f"Scheduling reconnect to {self.broker['name']} in {delay}s (attempt {self._reconnect_attempts}, reason: {reason})"
         )
         self._reconnect_timer = threading.Timer(delay, lambda: self._attempt_reconnect(reason))
@@ -418,7 +418,7 @@ class _BrokerConnection:
             return
 
         try:
-            logger.info(f"Attempting reconnection to {self.broker['name']} (reason: {reason})...")
+            logger.debug(f"Attempting reconnection to {self.broker['name']} (reason: {reason})...")
 
             # Stop the loop if it's still running (websocket mode requires clean restart)
             try:
@@ -598,7 +598,7 @@ class _BrokerConnection:
         if not self._running:
             return
 
-        logger.info(f"JWT token expiring soon for {self.broker['name']}, refreshing...")
+        logger.debug(f"JWT token expiring soon for {self.broker['name']}, refreshing...")
         self._running = False
         self._jwt_refresh_timer = None