Async fix (#19)

* Make extra_state_attributes async

* Async notify

* Only read on change

* Remove print

Author: benjamin-dcs

custom_components/file_plusplus/notify.py

@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 
+import asyncio
 from pathlib import Path
 from typing import Any, TextIO
 
@@ -40,8 +41,8 @@ def __init__(self, unique_id: str, config: dict[str, Any]) -> None:
         self._attr_name = config.get(CONF_NAME, DEFAULT_NAME)
         self._attr_unique_id = unique_id
 
-    def send_message(self, message: str, title: str | None = None) -> None:
-        """Send a message to a file."""
+    async def write_file(self, message: str, title: str | None = None) -> None:
+        """Async write a message to a file."""
         file: TextIO
         filepath = self._file_path
         try:
@@ -59,3 +60,7 @@ def send_message(self, message: str, title: str | None = None) -> None:
                 translation_key="write_access_failed",
                 translation_placeholders={"filename": filepath, "exc": f"{exc!r}"},
             ) from exc
+
+    def send_message(self, message: str, title: str | None = None) -> None:
+        """Send a message to a file."""
+        asyncio.run(self.write_file(message, title))

custom_components/file_plusplus/sensor.py

@@ -64,37 +64,46 @@ def __init__(
         self._val_tpl = value_template
         self._attr_unique_id = unique_id
 
-    def update(self) -> None:
-        """Return entity state."""
+        self._file_last_update = None
+        self._file_content = None
+
+    async def async_update(self):
+        """Fetch new state data for the sensor."""
         self._attr_native_value = "Ok"
 
-    @property
-    def extra_state_attributes(self):
-        """Return entity state attributes.
-
-        Get the latest entry from a file and updates the state.
-        """
-
-        try:
-            with Path.open(self._file_path, encoding="utf-8") as f:
-                data = f.read()
-        except (
-            IndexError,
-            FileNotFoundError,
-            IsADirectoryError,
-            UnboundLocalError,
-        ):
-            _LOGGER.warning(
-                "File or data not present at the moment: %s",
-                Path(self._file_path).name,
-            )
-            data = ""
+        file_last_update = Path.stat(self._file_path).st_mtime
+        if self._file_last_update == file_last_update:
+            return
+        self._file_last_update = file_last_update
+
+        def get_content():
+            try:
+                with Path.open(self._file_path, encoding="utf-8") as f:
+                    return f.read()
+            except (
+                IndexError,
+                FileNotFoundError,
+                IsADirectoryError,
+                UnboundLocalError,
+            ):
+                _LOGGER.warning(
+                    "File or data not present at the moment: %s",
+                    Path(self._file_path).name,
+                )
+                return ""
+
+        data = await self.hass.async_add_executor_job(get_content)
 
         if data and self._val_tpl is not None:
             content = self._val_tpl.async_render_with_possible_json_value(data, None)
         else:
             content = data
 
+        self._file_content = content
+
+    @property
+    def extra_state_attributes(self):
+        """Return extra attributes."""
         return {
-            "content": content,
+            "content": self._file_content,
         }