v1.1.1: Fix RCE spread sensors — real-time state tracking

- Added async_track_state_change_event listener for RCE entity
- Coordinator recalculates spread instantly on RCE state change
  (not just every 30 min ENTSO-E API cycle)
- Added debug logging in _read_rce_price() for troubleshooting
- Fixed test mock for homeassistant.helpers.event

Author: GregECAT

custom_components/entsoe_prices/coordinator.py

@@ -6,7 +6,8 @@
 import logging
 
 from aiohttp import ClientSession
-from homeassistant.core import HomeAssistant
+from homeassistant.core import HomeAssistant, callback
+from homeassistant.helpers.event import async_track_state_change_event
 from homeassistant.helpers.update_coordinator import (
     DataUpdateCoordinator,
     UpdateFailed,
@@ -62,6 +63,32 @@ def __init__(
         )
         self._rce_entity = rce_entity
 
+        # Track RCE sensor changes to recalculate spread in real-time
+        if rce_entity:
+            _LOGGER.debug("RCE spread enabled, tracking entity: %s", rce_entity)
+            async_track_state_change_event(
+                hass, [rce_entity], self._on_rce_state_change
+            )
+
+    @callback
+    def _on_rce_state_change(self, event) -> None:
+        """Handle RCE sensor state change — recalculate spread."""
+        if self.data is None:
+            return
+        rce_price = self._read_rce_price()
+        rce_max = self._read_rce_max()
+        _LOGGER.debug(
+            "RCE state changed → recalculating spread (rce=%.4f, max=%s)",
+            rce_price if rce_price is not None else 0,
+            rce_max,
+        )
+        self.data = self.api_client.compute_spread(
+            self.data,
+            rce_price_mwh=rce_price,
+            rce_max_today_mwh=rce_max,
+        )
+        self.async_set_updated_data(self.data)
+
     async def _async_update_data(self) -> PriceData:
         """Fetch data from ENTSO-E and enrich with RCE spread."""
         try:
@@ -73,6 +100,10 @@ async def _async_update_data(self) -> PriceData:
         if self._rce_entity:
             rce_price = self._read_rce_price()
             rce_max = self._read_rce_max()
+            _LOGGER.debug(
+                "RCE spread computation: entity=%s, rce_price=%s, rce_max=%s",
+                self._rce_entity, rce_price, rce_max,
+            )
             data = self.api_client.compute_spread(
                 data,
                 rce_price_mwh=rce_price,
@@ -84,11 +115,23 @@ async def _async_update_data(self) -> PriceData:
     def _read_rce_price(self) -> float | None:
         """Read current RCE price from HA sensor (PLN/MWh)."""
         state = self.hass.states.get(self._rce_entity)
-        if state is None or state.state in ("unavailable", "unknown"):
+        if state is None:
+            _LOGGER.warning("RCE entity %s not found in HA states", self._rce_entity)
+            return None
+        if state.state in ("unavailable", "unknown"):
+            _LOGGER.debug(
+                "RCE entity %s has state '%s', skipping", self._rce_entity, state.state
+            )
             return None
         try:
-            return float(state.state)
-        except (ValueError, TypeError):
+            val = float(state.state)
+            _LOGGER.debug("RCE price read: %s = %.4f PLN/MWh", self._rce_entity, val)
+            return val
+        except (ValueError, TypeError) as exc:
+            _LOGGER.warning(
+                "Cannot parse RCE price from %s (state='%s'): %s",
+                self._rce_entity, state.state, exc,
+            )
             return None
 
     def _read_rce_max(self) -> float | None:

custom_components/entsoe_prices/manifest.json

@@ -1,7 +1,7 @@
 {
   "domain": "entsoe_prices",
   "name": "ENTSO-E Ceny Energii",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "documentation": "https://github.com/GregECAT/entsoe-e",
   "issue_tracker": "https://github.com/GregECAT/entsoe-e/issues",
   "attribution": "Dane z platformy ENTSO-E Transparency. Kurs walut z API NBP. Wydawca: Smarting HOME (smartinghome.pl). Dokumentacja API: https://documenter.getpostman.com/view/7009892/2s93JtP3F6",

tests/test_api.py

@@ -18,6 +18,7 @@
 sys.modules["homeassistant.core"] = MagicMock()
 sys.modules["homeassistant.helpers"] = MagicMock()
 sys.modules["homeassistant.helpers.aiohttp_client"] = MagicMock()
+sys.modules["homeassistant.helpers.event"] = MagicMock()
 sys.modules["homeassistant.helpers.update_coordinator"] = MagicMock()
 sys.modules["homeassistant.helpers.entity"] = MagicMock()
 sys.modules["homeassistant.helpers.entity_platform"] = MagicMock()