Update backend/api/routes/sensors.py

backend/api/routes/sensors.py

@@ -64,3 +64,68 @@ async def sensors_history(
     except Exception as exc:
         log.error("Sensor history failed: %s", exc, exc_info=True)
         raise HTTPException(status_code=502, detail=f"Sensor history unavailable: {exc}")
+
+
+@router.get("/soil-moisture")
+async def soil_moisture_history(
+    hours: int = Query(168, ge=1, le=8760, description="Hours of history"),
+):
+    """Hourly soil moisture time-series from ThingsBoard (treatment Soil1)."""
+    try:
+        from datetime import datetime, timezone, timedelta
+        from src.data.thingsboard_client import ThingsBoardClient
+
+        client = ThingsBoardClient()
+        end = datetime.now(tz=timezone.utc)
+        start = end - timedelta(hours=hours)
+
+        df = client.get_timeseries(
+            "Soil1", ["soilMoisture", "soilMoisture2"],
+            start=start, end=end,
+            interval_ms=3_600_000, agg="AVG", limit=2000,
+        )
+        if df.empty:
+            return []
+        rows = []
+        for ts, row in df.iterrows():
+            r = {"timestamp": ts.isoformat()}
+            for col in df.columns:
+                val = row[col]
+                if val is not None and val == val:  # not NaN
+                    r[col] = round(float(val), 1)
+            rows.append(r)
+        return rows
+    except Exception as exc:
+        log.error("Soil moisture history failed: %s", exc)
+        return []
+
+
+@router.get("/rain")
+async def rain_history(
+    hours: int = Query(168, ge=1, le=8760, description="Hours of history"),
+):
+    """Hourly rain time-series from ThingsBoard ambient station (Air1)."""
+    try:
+        from datetime import datetime, timezone, timedelta
+        from src.data.thingsboard_client import ThingsBoardClient
+
+        client = ThingsBoardClient()
+        end = datetime.now(tz=timezone.utc)
+        start = end - timedelta(hours=hours)
+
+        df = client.get_timeseries(
+            "Air1", ["rain"],
+            start=start, end=end,
+            interval_ms=3_600_000, agg="SUM", limit=2000,
+        )
+        if df.empty:
+            return []
+        rows = []
+        for ts, row in df.iterrows():
+            val = row.get("rain")
+            if val is not None and val == val:
+                rows.append({"timestamp": ts.isoformat(), "rain_mm": round(float(val), 2)})
+        return rows
+    except Exception as exc:
+        log.error("Rain history failed: %s", exc)
+        return []