Add error dict detection, raise HTTPException on data provider errors

backend/api/routes/sensors.py

@@ -2,14 +2,16 @@
 
 from __future__ import annotations
 
+import logging
 from enum import Enum
 from typing import Optional
 
-from fastapi import APIRouter, Depends, Query
+from fastapi import APIRouter, Depends, HTTPException, Query
 
 from backend.api.deps import get_datahub
 from src.data.data_providers import DataHub
 
+log = logging.getLogger(__name__)
 router = APIRouter()
 
 
@@ -25,12 +27,22 @@ class AreaType(str, Enum):
     ambient = "ambient"
 
 
+def _check_error(result: dict, context: str = "") -> dict:
+    """If a data provider returned an error dict, raise HTTPException."""
+    if isinstance(result, dict) and "error" in result:
+        msg = result["error"]
+        log.warning("Data provider error%s: %s", f" ({context})" if context else "", msg)
+        raise HTTPException(status_code=502, detail=msg)
+    return result
+
+
 @router.get("/snapshot")
 async def sensors_snapshot(
     light: bool = False,
     hub: DataHub = Depends(get_datahub),
 ):
-    return hub.vine_sensors.get_snapshot(light=light)
+    result = hub.vine_sensors.get_snapshot(light=light)
+    return _check_error(result, "snapshot")
 
 
 @router.get("/history")
@@ -40,8 +52,9 @@ async def sensors_history(
     hours: int = Query(24, ge=1, le=8760, description="Hours of history (1–8760)"),
     hub: DataHub = Depends(get_datahub),
 ):
-    return hub.vine_sensors.get_history(
+    result = hub.vine_sensors.get_history(
         device_type=type.value,
         area=area.value if area else "treatment",
         hours_back=hours,
     )
+    return _check_error(result, "sensor history")