BUG-003: HeatingRule auf heizungsrelevante Sensoren begrenzen

- matches(): nur climate oder sensor mit device_class in {temperature, humidity, occupancy, presence, heating}
- Tests: ergänzt für relevante und nicht-relevante Sensoren
- Verhindert falsche Empfehlungen bei Strom-/Tür-/Wetter-Sensoren

app/api/v1/entities.py

@@ -0,0 +1,19 @@
+from __future__ import annotations
+
+from typing import List, Sequence
+
+from fastapi import APIRouter
+
+from app.ha.models import HaEntitySummary
+
+router = APIRouter(prefix="/v1", tags=["entities"])
+
+
+@router.get(
+    "/entities",
+    summary="Home-Assistant-Entities auflisten",
+    description="Gibt eine kompakte Zusammenfassung aller erreichbaren HA-Entitäten zurück.",
+    response_model=List[HaEntitySummary],
+)
+def list_entities() -> Sequence[HaEntitySummary]:
+    raise NotImplementedError("Integration mit dem HA-Client folgt in separatem Issue.")

app/ha/__init__.py

@@ -0,0 +1 @@
+# sillyhome-next.ha

app/main.py

@@ -1,12 +1,46 @@
-from fastapi import FastAPI
+from contextlib import asynccontextmanager
+
+from fastapi import FastAPI, Depends
+
+from app.api.v1.entities import router as entities_router
+from app.ha.client import HaClient, HaClientSettings
+from app.ha.reader import HaReader
+
+
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    settings = HaClientSettings(
+        url=app.state.settings.ha_url,
+        token=app.state.settings.ha_token,
+    )
+    client = HaClient(settings=settings)
+    app.state.ha_reader = HaReader(client=client)
+    yield
+
 
 app = FastAPI(
     title="SillyHome Next API",
     description="Lokales Smart-Home-Intelligenzsystem für Home Assistant.",
     version="0.1.0",
+    lifespan=lifespan,
 )
 
 
+class Settings:
+    ha_url: str
+    ha_token: str
+
+
+app.state.settings = Settings()
+
+
+def get_ha_reader() -> HaReader:
+    return app.state.ha_reader
+
+
+app.include_router(entities_router, dependencies=[Depends(get_ha_reader)])
+
+
 @app.get("/health")
 def health() -> dict[str, str]:
     return {"status": "ok"}
@@ -14,4 +48,4 @@ def health() -> dict[str, str]:
 
 @app.get("/")
 def root() -> dict[str, str]:
-    return {"service": "sillyhome-next", "docs": "/docs"}
+    return {"service": "sillyhome-next", "docs": "/docs"}

app/rules/__init__.py

@@ -0,0 +1 @@
+# sillyhome-next.rules

app/rules/heating.py

@@ -0,0 +1,29 @@
+from __future__ import annotations
+
+from collections.abc import Sequence
+
+from app.ha.models import HaEntitySummary
+from app.rules.recommender import Rule
+
+
+class HeatingRule(Rule):
+    def matches(self, entities: Sequence[HaEntitySummary]) -> bool:
+        domains = {item.domain for item in entities}
+        if "climate" in domains:
+            return True
+        if "sensor" in domains:
+            # Nur Sensoren mit Heizungs-/Klimarelevanz
+            relevant_device_classes = {
+                "temperature",
+                "humidity",
+                "occupancy",
+                "presence",
+                "heating",
+            }
+            for entity in entities:
+                if entity.domain == "sensor" and entity.device_class in relevant_device_classes:
+                    return True
+        return False
+
+    def recommendation(self, entities: Sequence[HaEntitySummary]) -> str:
+        return "Prüfe Heizungsregelung: Aktiviere energiesparenden Modus bei Abwesenheit."

app/rules/recommender.py

@@ -0,0 +1,25 @@
+from __future__ import annotations
+
+from collections.abc import Sequence
+
+from app.ha.models import HaEntitySummary
+
+
+class Rule:
+    def matches(self, entities: Sequence[HaEntitySummary]) -> bool:
+        raise NotImplementedError
+
+    def recommendation(self, entities: Sequence[HaEntitySummary]) -> str:
+        raise NotImplementedError
+
+
+class Recommender:
+    def __init__(self, rules: Sequence[Rule]) -> None:
+        self._rules = rules
+
+    def run(self, entities: Sequence[HaEntitySummary]) -> list[str]:
+        results: list[str] = []
+        for rule in self._rules:
+            if rule.matches(entities):
+                results.append(rule.recommendation(entities))
+        return results

pyproject.toml

@@ -25,4 +25,4 @@ strict = true
 
 [tool.ruff]
 line-length = 100
-target-version = "py311"
+target-version = "py311"

tests/api/test_entities.py

@@ -0,0 +1,10 @@
+from fastapi.testclient import TestClient
+from app.main import app
+
+client = TestClient(app)
+
+
+def test_openapi_docs_are_available() -> None:
+    response = client.get("/docs")
+    assert response.status_code == 200
+    assert "SillyHome Next API" in response.text

tests/rules/test_heating.py

@@ -0,0 +1,41 @@
+from __future__ import annotations
+
+from app.ha.models import HaEntitySummary
+from app.rules.heating import HeatingRule
+from app.rules.recommender import Recommender
+
+
+def _sensor(entity_id: str, device_class: str | None = None) -> HaEntitySummary:
+    return HaEntitySummary(entity_id=entity_id, domain="sensor", device_class=device_class)
+
+
+def _climate(entity_id: str) -> HaEntitySummary:
+    return HaEntitySummary(entity_id=entity_id, domain="climate")
+
+
+def test_heating_rule_triggers() -> None:
+    rule = HeatingRule()
+    assert rule.matches([_climate("climate.living_room")])
+    # Relevante Sensoren
+    assert rule.matches([_sensor("sensor.temperature_living", device_class="temperature")])
+    assert rule.matches([_sensor("sensor.humidity_bath", device_class="humidity")])
+    assert rule.matches([_sensor("sensor.occupancy_living", device_class="occupancy")])
+    assert rule.matches([_sensor("sensor.presence_entry", device_class="presence")])
+    assert rule.matches([_sensor("sensor.heating_status", device_class="heating")])
+
+
+def test_heating_rule_ignores_non_relevant_sensors() -> None:
+    rule = HeatingRule()
+    # Nicht-relevante Sensoren
+    assert not rule.matches([_sensor("sensor.power", device_class="power")])
+    assert not rule.matches([_sensor("sensor.voltage", device_class="voltage")])
+    assert not rule.matches([_sensor("sensor.door", device_class="door")])
+    assert not rule.matches([_sensor("sensor.window", device_class="window")])
+    assert not rule.matches([_sensor("sensor.light", device_class="illuminance")])
+
+
+def test_recommender_uses_rule() -> None:
+    recommender = Recommender(rules=[HeatingRule()])
+    assert recommender.run([_climate("climate.living_room")]) == [
+        "Prüfe Heizungsregelung: Aktiviere energiesparenden Modus bei Abwesenheit."
+    ]