Add decoding for ReportStatsEvent

Author: nanomad

deebot_client/hardware/deebot/2pv572.py

@@ -92,7 +92,7 @@
         play_sound=CapabilityExecute(PlaySound),
         state=CapabilityEvent(StateEvent, [GetChargeState(), GetCleanState()]),
         stats=CapabilityStats(
-            clean=CapabilityEvent(StatsEvent, [GetCleanSum()]),
+            clean=CapabilityEvent(StatsEvent, []),
             report=CapabilityEvent(ReportStatsEvent, []),
             total=CapabilityEvent(TotalStatsEvent, [GetCleanSum()]),
         ),

deebot_client/messages/xml/clean.py

@@ -5,11 +5,14 @@
 from typing import TYPE_CHECKING
 
 from deebot_client.events import (
+    CleanJobStatus,
     FanSpeedEvent,
     FanSpeedLevel,
     Position,
     PositionsEvent,
+    ReportStatsEvent,
     StateEvent,
+    StatsEvent,
 )
 from deebot_client.logging_filter import get_logger
 from deebot_client.message import HandlingResult
@@ -81,14 +84,46 @@ class CleanReportServer(XmlMessage):
     NAME = "CleanReportServer"
 
     @classmethod
-    def _handle_xml(cls, _event_bus: EventBus, _xml: Element) -> HandlingResult:
+    def _handle_xml(cls, event_bus: EventBus, xml: Element) -> HandlingResult:
         """Handle xml message and notify the correct event subscribers.
 
         b"<ctl ts='1744467262312' td='CleanReportServer' act='s' type='auto' cs='1134230540'/>"
         b"<ctl ts='1744467393682' td='CleanReportServer' act='h' type='auto' sts='1744467262' cs='1134230540' area='1' last='76' mapCount='6'/>"
 
         :return: A message response
         """
+        event_reported = False
+        if act := xml.attrib.get("act"):
+            clean_session = xml.attrib.get("cs")
+            last = xml.attrib.get("last")
+            area = xml.attrib.get("area")
+            type = xml.attrib.get("type")
+            clean_action = CleanAction.from_xml(act)
+            if clean_action == CleanAction.STOP:
+                event_bus.notify(StatsEvent(area=area, time=last, type=type))
+                event_reported = True
+            if clean_session:
+                if clean_action == CleanAction.STOP:
+                    job_status = CleanJobStatus.FINISHED
+                elif clean_action == CleanAction.START:
+                    job_status = CleanJobStatus.CLEANING
+                elif clean_action == CleanAction.PAUSE:
+                    job_status = CleanJobStatus.PAUSED
+                else:
+                    job_status = CleanJobStatus.NO_STATUS
+                event_bus.notify(
+                    ReportStatsEvent(
+                        area=area,
+                        time=last,
+                        type=type,
+                        cleaning_id=clean_session,
+                        status=job_status,
+                        content=[],
+                    )
+                )
+                event_reported = True
+        if event_reported:
+            return HandlingResult.success()
         return HandlingResult.analyse()