Sync all assets on startup if last market sync is older than 3 days

Wires the existing startup_refresh() into startup (it was defined but
never called). Adds a STARTUP_FORCE_REFRESH_AFTER_DAYS=3 guard: when the
last DSE snapshot (StockProfile.updated_at) is older than 3 days, force a
full refresh of stocks + funds + bonds regardless of per-dataset
staleness or weekend. Enriched the startup-refresh log line with
last_sync_age and force_refresh_all.

App/scheduler.py

@@ -32,6 +32,10 @@ STOCK_PRICE_REFRESH_END_HOUR = 17  # exclusive — last run starts at 16:00
 STOCK_STALE_AFTER_DAYS = 2
 FUND_STALE_AFTER_DAYS = 2
 BOND_STALE_AFTER_DAYS = 14
+# If the last market sync (StockProfile.updated_at — the DSE snapshot scrape
+# timestamp) is older than this on startup, force a full refresh of every
+# asset class regardless of per-dataset staleness.
+STARTUP_FORCE_REFRESH_AFTER_DAYS = 3
 NEWS_ARTICLE_STALE_HOURS = 12
 NEWS_ARTICLES_PER_QUERY = 4
 ECONOMY_RUN_GUARD_SECONDS = 60 * 60
@@ -666,15 +670,26 @@ async def startup_refresh() -> None:
         await _stock_history_backfill_needed()
     )
 
+    # Force a full refresh of every asset class if the last market sync
+    # (StockProfile.updated_at, the DSE snapshot timestamp) is older than
+    # STARTUP_FORCE_REFRESH_AFTER_DAYS — e.g. the server was down over a
+    # long weekend / multiple days.
+    last_sync_age = _age_days(
+        latest_stock_profile.updated_at if latest_stock_profile else None,
+        today,
+    )
+    force_refresh_all = last_sync_age is not None and last_sync_age > STARTUP_FORCE_REFRESH_AFTER_DAYS
+
     needs_stocks = (
-        stock_age is None
+        force_refresh_all
+        or stock_age is None
         or stock_age > STOCK_STALE_AFTER_DAYS
         or stock_history_backfill_needed
     )
-    needs_funds = fund_age is None or fund_age > FUND_STALE_AFTER_DAYS
-    needs_bonds = bond_age is None or bond_age > BOND_STALE_AFTER_DAYS
+    needs_funds = force_refresh_all or fund_age is None or fund_age > FUND_STALE_AFTER_DAYS
+    needs_bonds = force_refresh_all or bond_age is None or bond_age > BOND_STALE_AFTER_DAYS
 
-    if _is_weekend(now):
+    if _is_weekend(now) and not force_refresh_all:
         weekend_needs_stocks = stock_age is None
         weekend_needs_funds = fund_age is None
         weekend_needs_bonds = bond_age is None
@@ -697,8 +712,11 @@ async def startup_refresh() -> None:
             needs_stocks = True
 
     logger.info(
-        "[startup-refresh] dataset status: weekend=%s stocks_age_days=%s stale_after=%s history_backfill_needed=%s history_backfill_info=%s needs=%s, funds_age_days=%s stale_after=%s needs=%s, bonds_age_days=%s stale_after=%s needs=%s",
+        "[startup-refresh] dataset status: weekend=%s last_sync_age_days=%s force_refresh_all=%s (threshold=%s), stocks_age_days=%s stale_after=%s history_backfill_needed=%s history_backfill_info=%s needs=%s, funds_age_days=%s stale_after=%s needs=%s, bonds_age_days=%s stale_after=%s needs=%s",
         _is_weekend(now),
+        last_sync_age,
+        force_refresh_all,
+        STARTUP_FORCE_REFRESH_AFTER_DAYS,
         stock_age,
         STOCK_STALE_AFTER_DAYS,
         stock_history_backfill_needed,

main.py

@@ -21,6 +21,7 @@ from App.scheduler import (
     scheduled_market_loop,
     scheduled_news_loop,
     scheduled_stock_price_loop,
+    startup_refresh,
 )
 
 from db import init_db, close_db, clear_db
@@ -118,6 +119,8 @@ async def startup_event():
     logger.info("[startup] economy pipeline loop registered")
     asyncio.create_task(scheduled_stock_price_loop())
     logger.info("[startup] intraday stock-price loop started (hourly during DSE trading hours)")
+    asyncio.create_task(startup_refresh())
+    logger.info("[startup] startup refresh registered (syncs all assets if last market sync > 3 days)")
 
 
 @app.on_event("shutdown")