Hotfix: reliable speedtest cache population

Author: Dennis Braun

app/main.py

@@ -126,13 +126,15 @@ def polling_loop(config_mgr, storage, stop_event):
                 # Delta fetch: cache new results in storage
                 try:
                     last_id = storage.get_latest_speedtest_id()
-                    if last_id == 0:
+                    cached_count = storage.get_speedtest_count()
+                    if cached_count < 50:
+                        # Initial or incomplete cache: full fetch (descending)
                         new_results = stt_client.get_results(per_page=2000)
                     else:
                         new_results = stt_client.get_newer_than(last_id)
                     if new_results:
                         storage.save_speedtest_results(new_results)
-                        log.info("Cached %d new speedtest results", len(new_results))
+                        log.info("Cached %d new speedtest results (total: %d)", len(new_results), cached_count + len(new_results))
                 except Exception as e:
                     log.warning("Speedtest delta cache failed: %s", e)
 

app/storage.py

@@ -248,6 +248,12 @@ def get_speedtest_results(self, limit=2000):
             ).fetchall()
         return [dict(r) for r in rows]
 
+    def get_speedtest_count(self):
+        """Return number of cached speedtest results."""
+        with sqlite3.connect(self.db_path) as conn:
+            row = conn.execute("SELECT COUNT(*) FROM speedtest_results").fetchone()
+        return row[0] if row else 0
+
     def get_latest_speedtest_id(self):
         """Return the highest speedtest result id, or 0 if none."""
         with sqlite3.connect(self.db_path) as conn:

app/web.py

@@ -600,11 +600,12 @@ def api_speedtest():
                 _config_manager.get("speedtest_tracker_url"),
                 _config_manager.get("speedtest_tracker_token"),
             )
-            last_id = _storage.get_latest_speedtest_id()
-            if last_id == 0:
-                # First fetch: get newest results directly (descending)
-                new_results = client.get_results(per_page=count)
+            cached_count = _storage.get_speedtest_count()
+            if cached_count < 50:
+                # Initial or incomplete cache: full fetch (descending)
+                new_results = client.get_results(per_page=2000)
             else:
+                last_id = _storage.get_latest_speedtest_id()
                 new_results = client.get_newer_than(last_id)
             if new_results:
                 _storage.save_speedtest_results(new_results)