Merge branch 'diagnostics' of github.com:allenporter/python-roborock into diagnostics

Author: allenporter

roborock/devices/device_manager.py

@@ -16,8 +16,8 @@
     UserData,
 )
 from roborock.devices.device import DeviceReadyCallback, RoborockDevice
-from roborock.exceptions import RoborockException
 from roborock.diagnostics import Diagnostics
+from roborock.exceptions import RoborockException
 from roborock.map.map_parser import MapParserConfig
 from roborock.mqtt.roborock_session import create_lazy_mqtt_session
 from roborock.mqtt.session import MqttSession

roborock/mqtt/roborock_session.py

@@ -240,6 +240,7 @@ async def _mqtt_client(self, params: MqttParams) -> aiomqtt.Client:
                 async with self._client_lock:
                     self._client = client
                     for topic in self._client_subscribed_topics:
+                        self._diagnostics.increment("resubscribe")
                         _LOGGER.debug("Re-establishing subscription to topic %s", topic)
                         # TODO: If this fails it will break the whole connection. Make
                         # this retry again in the background with backoff.
@@ -321,6 +322,8 @@ def delayed_unsub():
             unsub()  # Remove the callback from CallbackMap
             # If no more callbacks for this topic, start idle timer
             if not self._listeners.get_callbacks(topic):
+                self._diagnostics.increment("unsubscribe_idle_start")
+                _LOGGER.debug("Unsubscribing topic %s, starting idle timer", topic)
                 schedule_unsubscribe()
             else:
                 _LOGGER.debug("Unsubscribing topic %s, still have active callbacks", topic)