Add background IMS refresh scheduler (every 6h)

backend/api/main.py

@@ -74,6 +74,43 @@ def _check_data_paths():
             log.warning("Missing %s — %s", rel_path, msg)
 
 
+async def _ims_refresh_loop(interval_sec: int = 6 * 3600):
+    """Background loop: refresh the IMS weather cache every `interval_sec` seconds.
+
+    Fetches the last 14 days of IMS data, overwrites the local CSV cache,
+    and invalidates the in-memory WeatherService cache so the next request
+    picks up fresh data.
+    """
+    import asyncio
+    await asyncio.sleep(10)  # let the server finish starting
+    while True:
+        try:
+            from datetime import date, timedelta
+            from src.data.ims_client import IMSClient
+            end = date.today()
+            start = end - timedelta(days=14)
+            client = IMSClient()
+            loop = asyncio.get_event_loop()
+            df = await loop.run_in_executor(
+                None,
+                lambda: client.fetch_and_cache(
+                    str(start), str(end), chunk_days=14
+                ),
+            )
+            rows = len(df) if df is not None and not df.empty else 0
+            log.info("IMS cache refreshed: %d rows (%s → %s)", rows, start, end)
+            # Invalidate WeatherService in-memory cache so next request uses fresh data
+            try:
+                from backend.api.deps import get_datahub
+                hub = get_datahub()
+                hub.weather._df_cache._store.clear()
+            except Exception:
+                pass
+        except Exception as exc:
+            log.error("IMS refresh failed: %s", exc)
+        await asyncio.sleep(interval_sec)
+
+
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     global _start_time
@@ -87,7 +124,12 @@ async def lifespan(app: FastAPI):
     if not os.environ.get("ADMIN_PASSWORD"):
         log.warning("ADMIN_PASSWORD not set — login endpoint disabled")
 
+    # Start background IMS data refresh (every 6 hours)
+    import asyncio
+    ims_task = asyncio.create_task(_ims_refresh_loop())
+
     yield
+    ims_task.cancel()
     log.info("SolarWine API shutting down (uptime=%.0fs)", get_uptime())
 
 
@@ -138,7 +180,7 @@ _default_origins = ",".join([
     "http://localhost:3000",
     "http://localhost:5173",
     "https://solarwine-api.hf.space",
-    "https://solarvine-dashboard.vercel.app",
+    "https://solarwine.pages.dev",
 ])
 allowed_origins = os.environ.get("ALLOWED_ORIGINS", _default_origins).split(",")
 app.add_middleware(