fix: Auto-fetch prices from yfinance if DB is empty on startup

dashboard/app.py

@@ -309,6 +309,50 @@ def _inject_css():
 def _ensure_schema():
     init_schema()
 
+@st.cache_resource
+def _ensure_prices():
+    """Fetch 2 years of price history from yfinance if the DB is empty.
+    Runs once per process — makes the app self-healing on fresh containers."""
+    conn = get_conn()
+    count = conn.execute("SELECT COUNT(*) FROM prices").fetchone()[0]
+    conn.close()
+    if count > 100:
+        return
+    try:
+        import yfinance as yf
+        from data.db import get_conn as _gc
+        symbols = list(SYMBOL_NAMES.keys())
+        ticker_data = yf.download(symbols, period="5y", auto_adjust=True, progress=False)
+        if ticker_data.empty:
+            return
+        conn2 = _gc()
+        for sym in symbols:
+            try:
+                if len(symbols) == 1:
+                    df = ticker_data.copy()
+                else:
+                    df = ticker_data.xs(sym, axis=1, level=1) if sym in ticker_data.columns.get_level_values(1) else None
+                if df is None or (hasattr(df, 'empty') and df.empty):
+                    continue
+                df = df.reset_index()
+                df.columns = [c.lower() for c in df.columns]
+                for _, row in df.iterrows():
+                    try:
+                        conn2.execute(
+                            "INSERT OR REPLACE INTO prices (date,symbol,open,high,low,close,volume,adj_close) VALUES (?,?,?,?,?,?,?,?)",
+                            [str(row["date"])[:10], sym,
+                             float(row.get("open", 0) or 0), float(row.get("high", 0) or 0),
+                             float(row.get("low", 0) or 0), float(row.get("close", 0) or 0),
+                             float(row.get("volume", 0) or 0), float(row.get("close", 0) or 0)]
+                        )
+                    except Exception:
+                        pass
+            except Exception:
+                pass
+        conn2.close()
+    except Exception:
+        pass
+
 @st.cache_data(ttl=3600)
 def _load_forecast(symbol: str) -> dict:
     return predict(symbol)
@@ -1036,6 +1080,7 @@ def _render_sidebar() -> tuple[str, int]:
 
 def main():
     _ensure_schema()
+    _ensure_prices()
     _inject_css()
     _render_header()