Release v0.1.53

Author: Maksym Shtembuliak

CHANGELOG.md

@@ -23,6 +23,25 @@ the GitHub release body should be rendered from the matching version section her
 
 - Nothing yet.
 
+## [0.1.53] - 2026-04-25
+
+### Added
+
+- Collector diagnostics now track connection churn, dropped pending requests, disconnect reasons, and discovery restarts to make local write-path contention easier to diagnose.
+
+### Changed
+
+- Declarative SMG runtime gates now surface advisory warnings instead of locally hiding or hard-blocking controls; the inverter response and immediate readback confirmation are now the final authority for non-action writes.
+
+### Fixed
+
+- Non-action writes no longer report silent success when the refreshed value stays unchanged; EyeBond Local now raises an explicit `write_not_confirmed` error after readback.
+- Temperature sensors backed by the affected PI18 and Anenji schemas now report `°C` instead of plain `C`.
+
+### Docs
+
+- Updated the English and Ukrainian READMEs plus the SMG support matrix to describe advisory runtime warnings, explicit readback confirmation, and the new collector contention diagnostics.
+
 ## [0.1.52] - 2026-04-23
 
 ### Added

README.md

@@ -25,6 +25,7 @@ If your inverter's stock monitoring already works through the SmartESS app, that
 - **Guided setup wizard** with auto-discovery and a manual fallback.
 - **Safe by default** — controls stay read-only until detection is confident.
 - **Optional SmartESS cloud assist** — collects reusable cloud evidence for diagnostics and metadata hints without bypassing local safety gates.
+- **Explicit write confirmation** — non-action writes must confirm by immediate readback instead of reporting silent success when the value did not stick.
 - **Configurable polling interval** — from `2` to `3600` seconds, so updates can be much more frequent than the stock SmartESS refresh.
 - **Energy dashboard ready** — derived totals for PV, load, battery, and, on supported models, grid import/export.
 - **Open architecture** — JSON-first profiles and register schemas.
@@ -155,8 +156,8 @@ After setup, the integration adds a single device with:
 - **Polling control** — the sensor refresh interval is configurable from `2` to `3600` seconds in the integration options.
 - **Energy totals** — derived `kWh` totals for PV production, load consumption, and battery charge/discharge, plus grid import/export on models that expose grid power. Drop them straight into the **Energy dashboard**.
 - **Binary sensors** — operating mode, faults, alarms, charging state.
-- **Controls** — `number`, `select`, `switch`, and `button` entities for supported settings (charge limits, output mode, beep, etc.). On variants that ship model-specific tooling, this can also include dedicated actions such as **Sync Inverter Clock**. Control exposure is still gated by detection confidence and validation state.
-- **Diagnostics** — connection state, driver match, support level, optional SmartESS cloud evidence export, explicit read-only fallback markers where applicable, and a one-click **Support Archive** export.
+- **Controls** — `number`, `select`, `switch`, and `button` entities for supported settings (charge limits, output mode, beep, etc.). On variants that ship model-specific tooling, this can also include dedicated actions such as **Sync Inverter Clock**. Control exposure is still gated by detection confidence and validation state, but runtime-only SMG conditions now surface as warnings instead of hiding or locally hard-blocking the control.
+- **Diagnostics** — connection state, driver match, support level, collector connection-churn and discovery-restart markers, optional SmartESS cloud evidence export, explicit read-only fallback markers where applicable, and a one-click **Support Archive** export.
 
 <p align="center"><img src="docs/images/sensors.png" alt="Live sensors after setup" width="320"></p>
 
@@ -204,6 +205,7 @@ The Support Archive contains an anonymized snapshot of your inverter's state, re
 | Device stays on **EyeBond Setup Pending** | A Pending Device is a saved intermediate state, not a hard failure. Wait briefly, retry scan or manual probe, and then create a Support Archive if the collector callback or local match still does not complete. |
 | Stuck on "Collector only" | The collector responded, but the integration still can't confidently identify the protocol, profile, or exact inverter model. Submit a Support Archive. |
 | Sensors stay unavailable | Check that the collector is on the same subnet as Home Assistant, and that nothing is blocking TCP `8899` / UDP `58899`. |
+| A write was accepted but the value immediately reverted | EyeBond Local now treats that as an explicit readback failure instead of silent success. Check the device diagnostics for collector disconnect/restart counters, pause competing SmartESS or vendor-app writes, and retry after the collector is stable. |
 | Remote collector replies but never connects back | Check **Advertised callback IP** and **Advertised callback TCP port** first. They must match the address and forwarded TCP port that the collector can really reach. |
 | Remote setup is flaky over the public internet | Prefer VPN over raw NAT if either side is behind CGNAT or if UDP/TCP forwarding is unreliable. |
 | Controls are missing | In **Auto** mode, controls only appear when detection confidence is high and the relevant capabilities are marked as tested. Some runtime paths are intentionally read-only, such as the SMG family fallback. If monitoring works for a PI30-family inverter but the exact model was not matched, you can open **Runtime settings** and switch to **Full control**. This is a manual safety override that exposes every write command, so use it only at your own risk and preferably after exporting a Support Archive. |

README.uk.md

@@ -25,6 +25,7 @@
 - **Майстер налаштування** з автопошуком і ручним резервним сценарієм.
 - **Безпечно за замовчуванням** — керування лишається тільки для читання, доки система не впевнена в розпізнаванні.
 - **Необов'язкова звірка через SmartESS** — збирає повторно використовувані хмарні дані для діагностики та підказок щодо метаданих, не обходячи локальні запобіжники безпеки.
+- **Явне підтвердження запису** — зміни не-дійових параметрів тепер мають підтвердитися негайним readback, а не завершуються мовчазним успіхом, якщо значення не закріпилося.
 - **Налаштовуваний інтервал опитування** — від `2` до `3600` секунд, тож дані можна оновлювати помітно частіше, ніж у штатному SmartESS.
 - **Готово для панелі енергії Home Assistant** — обчислені лічильники для PV, навантаження, батареї та, на підтримуваних моделях, імпорту/експорту з мережі.
 - **Відкрита архітектура** — описи профілів і регістрів у форматі JSON.
@@ -155,8 +156,8 @@ EyeBond Local працює з інверторами, для яких штатн
 - **Налаштування частоти оновлення** — інтервал опитування можна змінити в межах від `2` до `3600` секунд у параметрах інтеграції.
 - **Лічильники енергії** — обчислені значення в `kWh` для PV, навантаження та заряду/розряду батареї, а також імпорту/експорту з мережі на моделях, де доступний показник потужності мережі. Їх можна одразу додати до **панелі енергії Home Assistant**.
 - **Бінарні сенсори** — режим роботи, помилки, аварії, стан заряджання.
-- **Керування** — `number`, `select`, `switch`, `button` для підтримуваних налаштувань: ліміти заряду, вихідний режим, звуковий сигнал тощо. На деяких моделях це може також включати окремі службові дії, наприклад **Sync Inverter Clock**. Показ керування все одно залежить від упевненості розпізнавання та стану перевірки.
-- **Діагностика** — стан з'єднання, відповідність драйвера, рівень підтримки, окремий експорт хмарних даних SmartESS, явні позначки режиму лише для читання за потреби й кнопка експорту **архіву підтримки**.
+- **Керування** — `number`, `select`, `switch`, `button` для підтримуваних налаштувань: ліміти заряду, вихідний режим, звуковий сигнал тощо. На деяких моделях це може також включати окремі службові дії, наприклад **Sync Inverter Clock**. Показ керування все одно залежить від упевненості розпізнавання та стану перевірки, але суто runtime-умови SMG тепер показуються як попередження замість прихованого або локально жорстко заблокованого керування.
+- **Діагностика** — стан з'єднання, відповідність драйвера, рівень підтримки, лічильники перепідключень колектора та перезапусків discovery, окремий експорт хмарних даних SmartESS, явні позначки режиму лише для читання за потреби й кнопка експорту **архіву підтримки**.
 
 <p align="center"><img src="docs/images/sensors.png" alt="Сенсори після налаштування" width="320"></p>
 
@@ -204,6 +205,7 @@ EyeBond Local працює з інверторами, для яких штатн
 | Пристрій зависає в **EyeBond Setup Pending** | Це тимчасовий збережений стан, а не жорстка помилка. Зачекайте трохи, повторіть пошук або ручну перевірку, а якщо підтвердження інвертора чи зворотне підключення колектора так і не завершуються, створіть архів підтримки. |
 | Зависає на статусі **Лише колектор** | Колектор відповів, але інтеграція ще не змогла впевнено визначити протокол, профіль або точну модель інвертора. Надішліть архів підтримки. |
 | Сенсори лишаються недоступними | Переконайтесь, що колектор у тій самій підмережі, що й Home Assistant, і що TCP `8899` / UDP `58899` не заблоковані. |
+| Запис наче прийнявся, але значення одразу повернулося назад | EyeBond Local тепер вважає це явною помилкою readback, а не мовчазним успіхом. Перевірте в діагностиці лічильники перепідключень і restart'ів collector/discovery, тимчасово зупиніть паралельні записи зі SmartESS або штатного застосунку і повторіть спробу після стабілізації колектора. |
 | Віддалений колектор відповідає, але не підключається назад | Насамперед перевірте **Advertised callback IP** і **Advertised callback TCP port**. Вони мають збігатися з реально досяжною для колектора адресою та переадресованим TCP-портом. |
 | Віддалене підключення через NAT працює нестабільно | Якщо можливо, використовуйте VPN замість "чистого" NAT, особливо коли одна зі сторін за CGNAT або маршрутизатори ненадійно перенаправляють UDP чи TCP. |
 | Немає елементів керування | У режимі **Авто** керування з'являється лише за високої впевненості розпізнавання і для перевірених можливостей. Деякі внутрішні профілі роботи навмисно лишаються тільки для читання, наприклад `modbus_smg/family_fallback`. Якщо, наприклад, інвертор працює за протоколом PI30 і моніторинг уже є, але точну модель не розпізнано, можна в параметрах інтеграції відкрити **Параметри роботи** і вибрати режим **Повний контроль**. Це ручний обхід захисту, який відкриває всі команди без додаткової перевірки, тому використовуйте його лише на власний ризик і бажано після створення архіву підтримки. |

custom_components/eybond_local/collector/discovery.py

@@ -118,10 +118,16 @@ def __init__(
         self.last_reply: str = ""
         self.last_reply_from: str = ""
 
+    @property
+    def running(self) -> bool:
+        """Return whether the background discovery loop is active."""
+
+        return self._task is not None and not self._task.done()
+
     async def start(self) -> None:
         """Start the background broadcast loop if it is not running yet."""
 
-        if self._task and not self._task.done():
+        if self.running:
             return
         self._task = asyncio.create_task(self._run(), name="eybond_discovery")
 

custom_components/eybond_local/collector/server.py

@@ -70,6 +70,13 @@ def collector_info(self) -> CollectorInfo:
         return apply_collector_profile(CollectorInfo(
             remote_ip=self._collector.remote_ip,
             remote_port=self._collector.remote_port,
+            connection_count=self._collector.connection_count,
+            connection_replace_count=self._collector.connection_replace_count,
+            disconnect_count=self._collector.disconnect_count,
+            pending_request_drop_count=self._collector.pending_request_drop_count,
+            last_disconnect_reason=self._collector.last_disconnect_reason,
+            discovery_restart_count=self._collector.discovery_restart_count,
+            last_discovery_reason=self._collector.last_discovery_reason,
             collector_pn=self._collector.collector_pn,
             last_devcode=self._collector.last_devcode,
             heartbeat_devcode=self._collector.heartbeat_devcode,

custom_components/eybond_local/collector/transport.py

@@ -56,11 +56,28 @@ def _is_default_broadcast_alias_candidate(expected_ip: str, remote_ip: str) -> b
     return expected == ipaddress.IPv4Address(int(remote) | 0xFF)
 
 
+def _disconnect_reason_from_exception(exc: BaseException) -> str:
+    if isinstance(exc, ConnectionResetError):
+        return "collector_connection_reset"
+    if isinstance(exc, BrokenPipeError):
+        return "collector_broken_pipe"
+    if isinstance(exc, OSError):
+        return "collector_os_error"
+    return "collector_disconnected"
+
+
 def _copy_collector_info(collector: CollectorInfo) -> CollectorInfo:
     return apply_collector_profile(
         CollectorInfo(
             remote_ip=collector.remote_ip,
             remote_port=collector.remote_port,
+            connection_count=collector.connection_count,
+            connection_replace_count=collector.connection_replace_count,
+            disconnect_count=collector.disconnect_count,
+            pending_request_drop_count=collector.pending_request_drop_count,
+            last_disconnect_reason=collector.last_disconnect_reason,
+            discovery_restart_count=collector.discovery_restart_count,
+            last_discovery_reason=collector.last_discovery_reason,
             collector_pn=collector.collector_pn,
             last_devcode=collector.last_devcode,
             heartbeat_devcode=collector.heartbeat_devcode,
@@ -275,12 +292,15 @@ async def run(
         writer: asyncio.StreamWriter,
     ) -> None:
         if self.connected:
+            self._collector.connection_replace_count += 1
             logger.warning("Replacing active collector connection for %s", self._collector.remote_ip)
-            await self._disconnect()
+            await self._disconnect(reason="replaced_active_connection")
 
         peer = writer.get_extra_info("peername") or ("", None)
         self._collector.remote_ip = peer[0] or self._collector.remote_ip
         self._collector.remote_port = peer[1]
+        self._collector.connection_count += 1
+        self._collector.last_disconnect_reason = ""
         self._last_heartbeat_monotonic = None
         self._reader = reader
         self._writer = writer
@@ -363,16 +383,40 @@ async def _read_loop(self, reader: asyncio.StreamReader) -> None:
                     payload.hex(),
                 )
         except asyncio.IncompleteReadError:
+            self._collector.last_disconnect_reason = "collector_eof"
             logger.info("Collector disconnected: %s", self._collector.remote_ip)
         except (ConnectionResetError, BrokenPipeError, OSError) as exc:
+            self._collector.last_disconnect_reason = _disconnect_reason_from_exception(exc)
             logger.info("Collector disconnected %s: %s", self._collector.remote_ip, exc)
         except asyncio.CancelledError:
             raise
 
     async def disconnect(self) -> None:
-        await self._disconnect()
+        await self._disconnect(reason="manual_disconnect")
+
+    async def _disconnect(
+        self,
+        skip_task: asyncio.Task[Any] | None = None,
+        *,
+        reason: str = "",
+    ) -> None:
+        pending_drop_count = sum(1 for future in self._pending.values() if not future.done())
+        had_session = (
+            self._reader is not None
+            or self._writer is not None
+            or self._connected.is_set()
+            or pending_drop_count > 0
+        )
+        if pending_drop_count:
+            self._collector.pending_request_drop_count += pending_drop_count
+        if had_session:
+            self._collector.disconnect_count += 1
+            self._collector.last_disconnect_reason = (
+                reason
+                or self._collector.last_disconnect_reason
+                or "collector_disconnected"
+            )
 
-    async def _disconnect(self, skip_task: asyncio.Task[Any] | None = None) -> None:
         heartbeat_task = self._heartbeat_task
         self._heartbeat_task = None
 

custom_components/eybond_local/manifest.json

@@ -10,5 +10,5 @@
   "iot_class": "local_polling",
   "issue_tracker": "https://github.com/groove-max/ha-eybond-local/issues",
   "requirements": [],
-  "version": "0.1.52"
+  "version": "0.1.53"
 }