.

Author: marq24

custom_components/goecharger_api2/__init__.py

@@ -214,6 +214,9 @@ async def check_device_registry(hass: HomeAssistant):
 
 
 class GoeChargerDataUpdateCoordinator(DataUpdateCoordinator):
+
+    _debounced_update_task: asyncio.Task | None = None
+
     def __init__(self, hass: HomeAssistant, config_entry):
         lang = hass.config.language.lower()
         self._hass = hass
@@ -259,6 +262,7 @@ def __init__(self, hass: HomeAssistant, config_entry):
         self._CLIENT_COMMUNICATION_ERROR_TS = 0
         self._CLIENT_COMMUNICATION_ERROR_COUNT = 0
         self._RESTART_TRIGGERED = False
+        self._debounced_update_task = None
         super().__init__(hass, _LOGGER, name=DOMAIN, update_interval=SCAN_INTERVAL)
 
     # Callable[[Event], Any]
@@ -272,6 +276,7 @@ def clear_data(self):
         self._CLIENT_COMMUNICATION_ERROR_TS = 0
         self._CLIENT_COMMUNICATION_ERROR_COUNT = 0
         self._RESTART_TRIGGERED = False
+        self._debounced_update_task = None
 
     async def trigger_restart_delayed(self) -> None:
         # Generate a random sleep time between 5 and 10 minutes (300 and 600 seconds)
@@ -333,6 +338,15 @@ async def _async_update_data(self) -> dict:
     #    ret = await self.bridge.async_write_values(kv_pairs)
     #    return ret
 
+    def _request_update_in_5_sec(self):
+        if self._debounced_update_task is not None and not self._debounced_update_task.done():
+            self._debounced_update_task.cancel()
+        self._debounced_update_task = asyncio.create_task(self._debounce_coordinator_update())
+
+    async def _debounce_coordinator_update(self):
+        await asyncio.sleep(5)
+        await self.async_refresh()
+
     async def async_write_key(self, key: str, value, entity: Entity = None) -> dict:
         """Update single data"""
         result = await self.bridge.write_value_to_key(key, value)
@@ -352,6 +366,7 @@ async def async_write_key(self, key: str, value, entity: Entity = None) -> dict:
                 self.data = self.bridge._versions | self.bridge._states | self.bridge._config
                 self.async_update_listeners()
 
+        self._request_update_in_5_sec()
         return result
 
     async def async_write_multiple_keys(self, attr:dict, key: str, value, entity: Entity = None) -> dict:
@@ -373,6 +388,8 @@ async def async_write_multiple_keys(self, attr:dict, key: str, value, entity: En
                 self.data = self.bridge._versions | self.bridge._states | self.bridge._config
                 self.async_update_listeners()
 
+
+        self._request_update_in_5_sec()
         return result
 
     async def read_versions(self):