fix(status): propagate offline poll updates

Author: Komzpa

custom_components/ecoflow_cloud/devices/data_holder.py

@@ -108,6 +108,9 @@ def add_status(self, data: PreparedData):
         self.__accept_prepared_data(data, self.set_status.append)
         self.set_status_time = dt.utcnow()
 
+    def mark_status_changed(self) -> None:
+        self.status_change_time = dt.utcnow()
+
     def add_data(self, data: PreparedData):
         if data.params is not None and self.module_sn is not None:
             if "moduleSn" not in data.params:

custom_components/ecoflow_cloud/devices/status_coordinator.py

@@ -16,6 +16,7 @@
 from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
 
 from ..api import EcoflowApiClient
+from .data_coordinator import EcoflowBroadcastDataHolder
 
 _LOGGER = logging.getLogger(__name__)
 
@@ -44,9 +45,7 @@ def unregister(self, entry_id: str) -> None:
 
     def _actualize_interval(self) -> None:
         interval = min(
-            (d.device_data.options.assume_offline_sec
-             for c in self._clients.values()
-             for d in c.devices.values()),
+            (d.device_data.options.assume_offline_sec for c in self._clients.values() for d in c.devices.values()),
             default=DEFAULT_STATUS_POLL_INTERVAL_SEC,
         )
         self.update_interval = datetime.timedelta(seconds=interval)
@@ -80,9 +79,7 @@ async def _async_update_data(self) -> None:
 
         # Only poll if at least one device needs status clarification
         needs_poll = any(
-            device.status_tracker.wants_status_poll
-            for devices in all_devices.values()
-            for device in devices
+            device.status_tracker.wants_status_poll for devices in all_devices.values() for device in devices
         )
         if not needs_poll:
             _LOGGER.debug("No devices need status poll — skipping")
@@ -98,4 +95,7 @@ async def _async_update_data(self) -> None:
 
             for api_device in api_devices:
                 for device in all_devices.get(api_device.sn, []):
-                    device.status_tracker.on_explicit_status(api_device.status == 1)
+                    online = api_device.status == 1
+                    device.status_tracker.on_explicit_status(online)
+                    device.data.mark_status_changed()
+                    device.coordinator.async_set_updated_data(EcoflowBroadcastDataHolder(device.data, online))

custom_components/ecoflow_cloud/entities/__init__.py

@@ -175,6 +175,7 @@ def _updated(self, data: dict[str, Any]):
         # update value
         values = self._mqtt_key_expr.find(data)
         if len(values) == 1 or (len(values) > 1 and self._multiple_value_sum):
+            was_available = bool(self._attr_available)
             self._attr_available = True
             if self._auto_enable:
                 self._attr_entity_registry_enabled_default = True
@@ -184,7 +185,7 @@ def _updated(self, data: dict[str, Any]):
             if len(values) > 1 and self._multiple_value_sum:
                 for v in values[1:]:
                     total += v.value
-            if self._update_value(total):
+            if self._update_value(total) or not was_available:
                 self.schedule_update_ha_state()
 
     @property

custom_components/ecoflow_cloud/sensor.py

@@ -135,6 +135,7 @@ class DcModeStateSensorEntity(MiscSensorEntity):
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
         self._raw_code: int | None = None
+        self._configured_code: int | None = None
 
     def _runtime_mode(self) -> tuple[int | None, str | None]:
         params = self._device.data.params
@@ -189,8 +190,16 @@ def _updated(self, data: dict[str, Any]):
         if runtime_code is None:
             return
 
+        configured_code = params.get("mppt.cfgChgType")
+        if configured_code is not None:
+            configured_code = int(configured_code)
+
+        was_available = bool(self._attr_available)
         self._attr_available = True
-        if self._update_value(runtime_code):
+        updated = self._update_value(runtime_code)
+        configured_changed = configured_code != self._configured_code
+        self._configured_code = configured_code
+        if updated or configured_changed or not was_available:
             self.schedule_update_ha_state()