Merge pull request #11 from aLAN-LDZ/refactor_and_fifo

Refactor and fifo

Author: aLAN-LDZ

custom_components/solaraccelerator/__init__.py

@@ -95,6 +95,16 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
         # przy starcie (z RestoreEntity) i przy każdej zmianie z UI.
         "command_delay": DEFAULT_COMMAND_DELAY,
         "verify_settling": DEFAULT_VERIFY_SETTLING,
+        # Diagnostyka write_managera — kumulatywne statystyki per entity_id (retry, ok/fail)
+        # i meta ostatniego batcha. Aktualizowane w WriteManager._process_batch.
+        "write_stats": {
+            "entities": {},      # entity_id → {total_commands, total_retries, last_retries, last_status, last_error, last_value, last_attempt_at}
+            "last_batch_at": None,
+            "last_batch_size": 0,
+            "last_batch_acked": 0,
+            "last_batch_failed": 0,
+            "last_batch_retried": 0,  # liczba komend które wymagały >=1 retry
+        },
     }
 
     # WriteManager — kolejka komend do falownika z worker'em w tle.
@@ -109,16 +119,15 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
 
 
 async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
-    """Wyładuj integrację — anuluj taski w tle, zatrzymaj write_manager i odepnij platformy."""
-    coordinator_data = hass.data[DOMAIN].get(entry.entry_id, {})
+    """Wyładuj integrację — zatrzymaj write_manager i odepnij platformy.
 
-    # Anuluj obie pętle w tle — inaczej zostałyby "wiszące" po reloadzie
-    if task := coordinator_data.get("_task"):
-        task.cancel()
-    if live_task := coordinator_data.get("_live_task"):
-        live_task.cancel()
+    Pętle godzinowa/live są tworzone przez ``entry.async_create_background_task`` —
+    HA anuluje je automatycznie przy unload. WriteManager tworzy własny task przez
+    ``hass.async_create_background_task`` więc go zatrzymujemy ręcznie.
+    """
+    coordinator_data = hass.data[DOMAIN].get(entry.entry_id, {})
 
-    # Zatrzymaj worker'a write_managera
+    # Zatrzymaj worker'a write_managera (osobny task niezwiązany z entry)
     if write_manager := coordinator_data.get("write_manager"):
         write_manager.stop()
 

custom_components/solaraccelerator/const.py

@@ -75,7 +75,14 @@
 
 DEFAULT_VERIFY_SETTLING = 5.0    # sekund od ostatniego write do pierwszego verify
 MIN_VERIFY_SETTLING = 1.0
-MAX_VERIFY_SETTLING = 60.0
+MAX_VERIFY_SETTLING = 120.0
+
+# Verify retry — gdy verify pokaże że falownik nie przyjął write (np. Modbus
+# odrzucił pakiet), ponawiamy execute+verify do MAX prób. Tylko dla komend
+# które wykonały się bez wyjątku — encja unavailable nie jest retry'owana.
+DEFAULT_VERIFY_RETRIES = 3       # liczba dodatkowych prób po pierwszym fail
+MIN_VERIFY_RETRIES = 0           # 0 = brak retry, klasyczne zachowanie
+MAX_VERIFY_RETRIES = 10
 
 # Lista wszystkich pól które integracja może wysyłać do backendu.
 # Format: (key, description, unit, category)

custom_components/solaraccelerator/number.py

@@ -28,11 +28,14 @@
 
 from .const import (
     DEFAULT_COMMAND_DELAY,
+    DEFAULT_VERIFY_RETRIES,
     DEFAULT_VERIFY_SETTLING,
     DOMAIN,
     MAX_COMMAND_DELAY,
+    MAX_VERIFY_RETRIES,
     MAX_VERIFY_SETTLING,
     MIN_COMMAND_DELAY,
+    MIN_VERIFY_RETRIES,
     MIN_VERIFY_SETTLING,
 )
 
@@ -50,6 +53,7 @@ async def async_setup_entry(
     async_add_entities([
         SolarAcceleratorCommandDelayNumber(hass, entry, coordinator_data),
         SolarAcceleratorVerifySettlingNumber(hass, entry, coordinator_data),
+        SolarAcceleratorVerifyRetriesNumber(hass, entry, coordinator_data),
     ])
 
 
@@ -156,3 +160,25 @@ def __init__(
         """Zainicjalizuj encję verify_settling."""
         super().__init__(hass, entry, coordinator_data, "verify_settling")
         self._attr_name = "Opóźnienie przed verify"
+
+
+class SolarAcceleratorVerifyRetriesNumber(_ConfigNumberBase):
+    """Liczba dodatkowych prób execute+verify gdy pierwszy verify się nie powiódł."""
+
+    # Liczba prób — bez jednostki "s"
+    _attr_native_unit_of_measurement = None
+    _attr_icon = "mdi:reload"
+    _attr_translation_key = "verify_retries"
+    _attr_native_min_value = MIN_VERIFY_RETRIES
+    _attr_native_max_value = MAX_VERIFY_RETRIES
+    _attr_native_step = 1
+
+    _data_key = "verify_retries"
+    _default_value = DEFAULT_VERIFY_RETRIES
+
+    def __init__(
+        self, hass: HomeAssistant, entry: ConfigEntry, coordinator_data: dict[str, Any]
+    ) -> None:
+        """Zainicjalizuj encję verify_retries."""
+        super().__init__(hass, entry, coordinator_data, "verify_retries")
+        self._attr_name = "Liczba prób verify"

custom_components/solaraccelerator/sensor.py

@@ -42,6 +42,7 @@
     SolarAcceleratorNextScheduledSensor,
     SolarAcceleratorPriceProviderSensor,
     SolarAcceleratorStatusSensor,
+    SolarAcceleratorWriteStatsSensor,
 )
 
 _LOGGER = logging.getLogger(__name__)
@@ -84,21 +85,30 @@ async def async_setup_entry(
         SolarAcceleratorLiveStatusSensor(hass, entry, coordinator_data),
         SolarAcceleratorLiveLastPushSensor(hass, entry, coordinator_data),
         SolarAcceleratorLiveIntervalSensor(hass, entry, coordinator_data),
+        # Diagnostyka write_managera — retry/status per sterowana encja
+        SolarAcceleratorWriteStatsSensor(hass, entry, coordinator_data),
     ])
 
     # Pobierz ceny i zysk od razu na starcie — żeby sensory nie świeciły "unknown"
-    # przed pierwszą pełną godziną
-    hass.async_create_task(async_fetch_prices(hass, coordinator_data))
-    hass.async_create_task(async_fetch_profit(hass, coordinator_data))
+    # przed pierwszą pełną godziną. Background — żeby wolny serwer nie blokował bootstrap.
+    entry.async_create_background_task(
+        hass, async_fetch_prices(hass, coordinator_data), "sa_fetch_prices_init"
+    )
+    entry.async_create_background_task(
+        hass, async_fetch_profit(hass, coordinator_data), "sa_fetch_profit_init"
+    )
 
-    # Pętla godzinowa — pełna paczka danych co pełną godzinę
-    task = hass.async_create_task(
-        async_send_data_hourly(hass, entry, coordinator_data)
+    # Pętla godzinowa — pełna paczka danych co pełną godzinę.
+    # background_task = HA nie czeka na nią podczas bootstrap (to nieskończony while True).
+    entry.async_create_background_task(
+        hass,
+        async_send_data_hourly(hass, entry, coordinator_data),
+        "sa_send_data_hourly",
     )
-    coordinator_data["_task"] = task
 
     # Pętla live — szybki push stanu i odbiór komend co kilkanaście sekund
-    live_task = hass.async_create_task(
-        async_send_live_data_loop(hass, entry, coordinator_data)
+    entry.async_create_background_task(
+        hass,
+        async_send_live_data_loop(hass, entry, coordinator_data),
+        "sa_send_live_data_loop",
     )
-    coordinator_data["_live_task"] = live_task

custom_components/solaraccelerator/sensors/__init__.py

@@ -14,6 +14,7 @@
     SolarAcceleratorLastSentSensor,
     SolarAcceleratorNextScheduledSensor,
     SolarAcceleratorStatusSensor,
+    SolarAcceleratorWriteStatsSensor,
 )
 from .live import (
     SolarAcceleratorLiveIntervalSensor,
@@ -45,6 +46,7 @@
     "SolarAcceleratorLastSentSensor",
     "SolarAcceleratorNextScheduledSensor",
     "SolarAcceleratorEntitiesCountSensor",
+    "SolarAcceleratorWriteStatsSensor",
     # ceny
     "SolarAcceleratorCurrentBuyPriceSensor",
     "SolarAcceleratorMinBuyPriceSensor",

custom_components/solaraccelerator/sensors/diagnostic.py

@@ -27,6 +27,16 @@
 )
 from ._base import SolarAcceleratorSensorBase
 
+# Pusta diagnostyka — gdy write_manager jeszcze nie miał żadnego batcha
+_EMPTY_WRITE_STATS: dict[str, Any] = {
+    "entities": {},
+    "last_batch_at": None,
+    "last_batch_size": 0,
+    "last_batch_acked": 0,
+    "last_batch_failed": 0,
+    "last_batch_retried": 0,
+}
+
 
 class SolarAcceleratorStatusSensor(SolarAcceleratorSensorBase):
     """Status połączenia z backendem (``connected``/``auth_error``/``error``/``disconnected``)."""
@@ -187,3 +197,59 @@ def extra_state_attributes(self) -> dict[str, Any]:
             attrs["ev_enabled"] = False
 
         return attrs
+
+
+class SolarAcceleratorWriteStatsSensor(SolarAcceleratorSensorBase):
+    """Diagnostyka write_managera — retry i finalny status per sterowana encja.
+
+    Main state = liczba komend z ostatniego batcha które wymagały retry (0 = OK).
+    Atrybuty zawierają meta ostatniego batcha + kumulatywne statystyki per entity_id
+    od startu integracji: ile razy komenda dla danej encji się powiodła, ile razy
+    musieliśmy retry'ować, jaka była ostatnia żądana wartość i finalny status.
+
+    Sensor odświeża się natychmiast po każdym batchu — WriteManager woła
+    ``coordinator_data['write_stats_notify']`` zaraz po ACK'owaniu komend.
+    """
+
+    _attr_icon = "mdi:reload-alert"
+    _attr_state_class = SensorStateClass.MEASUREMENT
+    _attr_translation_key = "write_stats"
+    _attr_entity_category = EntityCategory.DIAGNOSTIC
+
+    def __init__(
+        self, hass: HomeAssistant, entry: ConfigEntry, coordinator_data: dict[str, Any]
+    ) -> None:
+        """Zainicjalizuj sensor diagnostyki write_managera."""
+        super().__init__(hass, entry, coordinator_data, "write_stats")
+        self._attr_name = "Diagnostyka komend"
+
+    async def async_added_to_hass(self) -> None:
+        """Po dodaniu do HA zarejestruj notifier — write_manager woła go po każdym batchu."""
+        await super().async_added_to_hass()
+        # Schedule_update_ha_state można wołać synchronicznie z dowolnego kontekstu
+        self.coordinator_data["write_stats_notify"] = self.async_schedule_update_ha_state
+
+    async def async_will_remove_from_hass(self) -> None:
+        """Wyczyść notifier — uniknij wołania callbacka po unmount."""
+        if self.coordinator_data.get("write_stats_notify") == self.async_schedule_update_ha_state:
+            self.coordinator_data.pop("write_stats_notify", None)
+        await super().async_will_remove_from_hass()
+
+    @property
+    def native_value(self) -> int:
+        """Liczba komend z ostatniego batcha które wymagały co najmniej 1 retry."""
+        stats = self.coordinator_data.get("write_stats") or _EMPTY_WRITE_STATS
+        return int(stats.get("last_batch_retried", 0))
+
+    @property
+    def extra_state_attributes(self) -> dict[str, Any]:
+        """Pełna diagnostyka batcha + kumulatywne statystyki per entity."""
+        stats = self.coordinator_data.get("write_stats") or _EMPTY_WRITE_STATS
+        return {
+            "last_batch_at": stats.get("last_batch_at"),
+            "last_batch_size": stats.get("last_batch_size", 0),
+            "last_batch_acked": stats.get("last_batch_acked", 0),
+            "last_batch_failed": stats.get("last_batch_failed", 0),
+            "last_batch_retried": stats.get("last_batch_retried", 0),
+            "entities": stats.get("entities", {}),
+        }

custom_components/solaraccelerator/strings.json

@@ -190,6 +190,9 @@
       "entities_sent": {
         "name": "Wysłane encje"
       },
+      "write_stats": {
+        "name": "Diagnostyka komend"
+      },
       "current_buy_price": {
         "name": "Cena zakupu energii"
       },
@@ -261,6 +264,9 @@
       },
       "verify_settling": {
         "name": "Opóźnienie przed verify"
+      },
+      "verify_retries": {
+        "name": "Liczba prób verify"
       }
     }
   }

custom_components/solaraccelerator/translations/en.json

@@ -190,6 +190,9 @@
       "entities_sent": {
         "name": "Entities Sent"
       },
+      "write_stats": {
+        "name": "Command diagnostics"
+      },
       "current_buy_price": {
         "name": "Buy Energy Price"
       },
@@ -261,6 +264,9 @@
       },
       "verify_settling": {
         "name": "Settling delay before verify"
+      },
+      "verify_retries": {
+        "name": "Verify retries"
       }
     }
   }

custom_components/solaraccelerator/translations/pl.json

@@ -190,6 +190,9 @@
       "entities_sent": {
         "name": "Wysłane encje"
       },
+      "write_stats": {
+        "name": "Diagnostyka komend"
+      },
       "current_buy_price": {
         "name": "Cena zakupu energii"
       },
@@ -261,6 +264,9 @@
       },
       "verify_settling": {
         "name": "Opóźnienie przed verify"
+      },
+      "verify_retries": {
+        "name": "Liczba prób verify"
       }
     }
   }