### Changed

- take care of device time drift of up to 30 minutes, e. g. device is set to wake up at 6am but wakes at 5:47 (seems to be a firmware bug) - do not set the time to 6am again but to the next time slot (e. g. 18:00 when wake_up_hours is "6,18").
- translated all comments to English

Author: fwmone

CHANGELOG.md

@@ -5,6 +5,13 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/).
 
+## [0.1.10] - 2026-01-30
+
+### Changed
+
+- take care of device time drift of up to 30 minutes, e. g. device is set to wake up at 6am but wakes at 5:47 (seems to be a firmware bug) - do not set the time to 6am again but to the next time slot (e. g. 18:00 when wake_up_hours is "6,18").
+- translated all comments to English
+
 ## [0.1.9] - 2026-01-29
 
 ### Added - BREAKING CHANGE

README.md

@@ -84,10 +84,9 @@ bloomin8_pull:
 |*image_dir*|This is where all the images on the Home Assistant server are stored, from which the pull endpoint selects one for the picture frame.|
 |*publish_dir*|The directory that can be accessed via a web browser. This is usually /config/www, which contains a directory for the picture frame, e.g. bloomin8. The pull endpoint copies the selected image here and replaces it with a new one the next time it is retrieved.|
 |*publish_webpath*|The web path to “publish_dir”. For “/config/www/bloomin8,” this is usually “/local/bloomin8.” Only the path is configured here, not the server address. You specify the server address via the configuration of *upstream_url* below the image frame. For the image frame, the complete URL would therefore be http://<IP-AND-PORT-OF-HOME-ASSISTANT>/local/bloomin8|
-|*wake_up_hours*|At which time should the picture frame retrieve a new image? Specify in comma-separated hours, e.g., "6,18" for 6:00 and 18:00.|
+|*wake_up_hours*|At which time should the picture frame retrieve a new image? Specify in comma-separated hours, e.g., "6,18" for 6:00 and 18:00. The component takes care of the device's firmware bug of waking up too early (e. g. 5:47 instead of 6:00) for up to 30 minutes and then skips to the next time slot (-> do not send 6:00 again, but 18:00).|
 |*orientation*|The orientation of the picture frame - P = portrait format, L = landscape format.|
 
-
 And for the access token in <secrets.yaml>:
 
 ```yaml

custom_components/bloomin8_pull/__init__.py

@@ -75,13 +75,13 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
         except Exception:
             pass
 
-    hass.data[DOMAIN]["entities"] = []  # hier registrieren sich die Entities, damit wir pushen können
+    hass.data[DOMAIN]["entities"] = []  # This is where entities register so that we can push
 
     # register the HTTP endpoint
     hass.http.register_view(Bloomin8PullView(hass, cfg))
     hass.http.register_view(Bloomin8SignalView(hass, cfg))
 
-    # Plattformen laden
+    # Load platforms
     for platform in PLATFORMS:
         hass.async_create_task(async_load_platform(hass, platform, DOMAIN, {}, config))
     return True

custom_components/bloomin8_pull/sensor.py

@@ -32,6 +32,6 @@ def extra_state_attributes(self):
         }
 
     async def async_added_to_hass(self):
-        # registrieren, damit der View später pushen kann
+        # register so that the view can push later
         self.hass.data[DOMAIN]["entities"].append(self)
         self.async_write_ha_state()

custom_components/bloomin8_pull/view.py

@@ -21,7 +21,7 @@
 from .const import DOMAIN, STATE_BATTERY, STATE_SUCCESS, STATE_LAST_SEEN, STATE_FILE
 
 def calc_recent_max(n_files: int) -> int:
-    # 50% der Dateien, mindestens 5, maximal 50
+    # 50% of files, minimum 5, maximum 50
     return max(5, min(50, int(round(n_files * 0.5))))
 
 def clear_publish_dir(path: str) -> None:
@@ -82,6 +82,30 @@ def next_wake_time_local(hours: list[int], now_local=None):
     first = dt_util.as_local(datetime(tomorrow.year, tomorrow.month, tomorrow.day, hours[0], 0, 0))
     return first
 
+def next_wake_time_local_windowed(
+    hours: list[int],
+    now_local: datetime | None = None,
+    drift_window: timedelta = timedelta(minutes=30),
+) -> datetime:
+    """Return next scheduled local time.
+    If we're within `drift_window` BEFORE the next slot, skip that slot and return the following one.
+    """
+    if not hours:
+        raise ValueError("No wake_up_hours configured")
+
+    if now_local is None:
+        now_local = dt_util.now()
+
+    first = next_wake_time_local(hours, now_local=now_local)
+
+    # If the device calls shortly before the next slot (drift), don't schedule that same slot again.
+    delta = first - now_local
+    if timedelta(0) < delta <= drift_window:
+        # Next slot after `first`
+        return next_wake_time_local(hours, now_local=first + timedelta(seconds=1))
+
+    return first
+
 async def choose_varied(hass, files: list[str], store_key: str = "recent_images") -> str:
     RECENT_MAX = calc_recent_max(len(files))
 
@@ -90,18 +114,18 @@ async def choose_varied(hass, files: list[str], store_key: str = "recent_images"
     data = await store.async_load() or {}
     recent = deque(data.get("recent", []), maxlen=RECENT_MAX)
 
-    # Entfernte Dateien aus recent rauswerfen (dynamische Bildauswahl)
+    # Remove files from recent (dynamic image selection)
     files_set = set(files)
     recent = deque([f for f in recent if f in files_set], maxlen=RECENT_MAX)
 
-    # Kandidaten: alles, was nicht "recent" ist
+    # Candidates: anything that is not “recent”
     recent_set = set(recent)
     candidates = [f for f in files if f not in recent_set]
 
-    # Fallback: wenn alles in recent ist, nimm wieder aus allen
+    # Fallback: if everything is in recent, take from all again
     chosen = random.choice(candidates or files)
 
-    # recent updaten
+    # update recent
     recent.append(chosen)
     await store.async_save({"recent": list(recent)})
 
@@ -153,12 +177,12 @@ async def get(self, request: web.Request) -> web.Response:
                 STATE_LAST_SEEN: self.hass.data[DOMAIN]["state"][STATE_LAST_SEEN],
             }
 
-            # nicht blocking im event loop
+            # don't block the event loop
             await self.hass.async_add_executor_job(_write_json_sync, STATE_FILE, data)
         except Exception:
             pass
 
-        # Push: alle registrierten Entities neu schreiben
+        # Push: rewrite all registered entities
         for ent in self.hass.data[DOMAIN].get("entities", []):
             ent.async_write_ha_state()
 
@@ -172,7 +196,12 @@ async def get(self, request: web.Request) -> web.Response:
         publish_webpath: str = self.cfg["publish_webpath"]
 
         hours = parse_wake_up_hours(self.cfg["wake_up_hours"])
-        next_local = next_wake_time_local(hours)
+        now_local = dt_util.now()
+        next_local = next_wake_time_local_windowed(
+            hours,
+            now_local=now_local,
+            drift_window=timedelta(minutes=30),
+        )
         next_utc = dt_util.as_utc(next_local)
 
         orientation: str = self.cfg["orientation"]
@@ -278,12 +307,12 @@ async def get(self, request: web.Request) -> web.Response:
                 STATE_LAST_SEEN: self.hass.data[DOMAIN]["state"][STATE_LAST_SEEN],
             }
 
-            # nicht blocking im event loop
+            # don't block the event loop
             await self.hass.async_add_executor_job(_write_json_sync, STATE_FILE, data)
         except Exception:
             pass
 
-        # Push: alle registrierten Entities neu schreiben
+        # Push: rewrite all registered entities
         for ent in self.hass.data[DOMAIN].get("entities", []):
             ent.async_write_ha_state()