Compare commits
5 Commits
0.9.1
...
room_comma
| Author | SHA1 | Date | |
|---|---|---|---|
|
d39bcfce26
|
|||
|
1fd275186a
|
|||
|
da370c9050
|
|||
|
08294ca294
|
|||
|
e5eb368dca
|
@@ -8,9 +8,9 @@ ENV PYTHONDONTWRITEBYTECODE=1 \
|
||||
PYTHONUNBUFFERED=1 \
|
||||
MQTT_BROKER=172.16.2.16 \
|
||||
MQTT_PORT=1883 \
|
||||
REDIS_HOST=localhost \
|
||||
REDIS_HOST=172.23.1.116 \
|
||||
REDIS_PORT=6379 \
|
||||
REDIS_DB=0 \
|
||||
REDIS_DB=8 \
|
||||
REDIS_CHANNEL=ui:updates
|
||||
|
||||
# Create non-root user
|
||||
|
||||
@@ -121,7 +121,10 @@ async def get_device_layout(device_id: str):
|
||||
async def startup_event():
|
||||
"""Include routers after app is initialized to avoid circular imports."""
|
||||
from apps.api.routes.groups_scenes import router as groups_scenes_router
|
||||
from apps.api.routes.rooms import router as rooms_router
|
||||
|
||||
app.include_router(groups_scenes_router, prefix="")
|
||||
app.include_router(rooms_router, prefix="")
|
||||
|
||||
|
||||
@app.get("/health")
|
||||
|
||||
219
apps/api/routes/rooms.py
Normal file
219
apps/api/routes/rooms.py
Normal file
@@ -0,0 +1,219 @@
|
||||
"""
|
||||
Room-based device control endpoints.
|
||||
|
||||
Provides bulk control operations for devices within rooms:
|
||||
- /rooms/{room_name}/lights - Control all lights in a room
|
||||
- /rooms/{room_name}/heating - Control all thermostats in a room
|
||||
"""
|
||||
|
||||
import logging
|
||||
from typing import Any
|
||||
|
||||
from fastapi import APIRouter, HTTPException, status
|
||||
from pydantic import BaseModel
|
||||
|
||||
from packages.home_capabilities import load_layout
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
router = APIRouter(tags=["Rooms"])
|
||||
|
||||
|
||||
@router.get("/rooms")
|
||||
async def get_rooms() -> list[dict[str, str]]:
|
||||
"""Get list of all room IDs and names.
|
||||
|
||||
Returns:
|
||||
List of dicts with room id and name
|
||||
"""
|
||||
layout = load_layout()
|
||||
|
||||
return [
|
||||
{
|
||||
"id": room.id,
|
||||
"name": room.name
|
||||
}
|
||||
for room in layout.rooms
|
||||
]
|
||||
|
||||
|
||||
class LightsControlRequest(BaseModel):
|
||||
"""Request model for controlling lights in a room."""
|
||||
power: str # "on" or "off"
|
||||
brightness: int | None = None # Optional brightness 0-100
|
||||
|
||||
|
||||
class HeatingControlRequest(BaseModel):
|
||||
"""Request model for controlling heating in a room."""
|
||||
target: float # Target temperature
|
||||
|
||||
|
||||
def get_room_devices(room_id: str) -> list[dict[str, Any]]:
|
||||
"""Get all devices in a specific room from layout.
|
||||
|
||||
Args:
|
||||
room_id: ID of the room
|
||||
|
||||
Returns:
|
||||
List of device dicts with device_id, title, icon, rank, excluded
|
||||
|
||||
Raises:
|
||||
HTTPException: If room not found
|
||||
"""
|
||||
layout = load_layout()
|
||||
|
||||
for room in layout.rooms:
|
||||
if room.id == room_id:
|
||||
return [
|
||||
{
|
||||
"device_id": device.device_id,
|
||||
"title": device.title,
|
||||
"icon": device.icon,
|
||||
"rank": device.rank,
|
||||
"excluded": device.excluded
|
||||
}
|
||||
for device in room.devices
|
||||
]
|
||||
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_404_NOT_FOUND,
|
||||
detail=f"Room '{room_id}' not found"
|
||||
)
|
||||
|
||||
|
||||
@router.post("/rooms/{room_id}/lights", status_code=status.HTTP_202_ACCEPTED)
|
||||
async def control_room_lights(room_id: str, request: LightsControlRequest) -> dict[str, Any]:
|
||||
"""Control all lights (light and relay devices) in a room.
|
||||
|
||||
Args:
|
||||
room_id: ID of the room
|
||||
request: Light control parameters
|
||||
|
||||
Returns:
|
||||
dict with affected device_ids and command summary
|
||||
"""
|
||||
from apps.api.main import load_devices, publish_abstract_set
|
||||
|
||||
# Get all devices in room
|
||||
room_devices = get_room_devices(room_id)
|
||||
|
||||
# Filter out excluded devices
|
||||
room_device_ids = {d["device_id"] for d in room_devices if not d.get("excluded", False)}
|
||||
|
||||
# Load all devices to filter by type
|
||||
all_devices = load_devices()
|
||||
|
||||
# Filter for light/relay devices in this room
|
||||
light_devices = [
|
||||
d for d in all_devices
|
||||
if d["device_id"] in room_device_ids and d["type"] in ("light", "relay")
|
||||
]
|
||||
|
||||
if not light_devices:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_404_NOT_FOUND,
|
||||
detail=f"No light devices found in room '{room_id}'"
|
||||
)
|
||||
|
||||
# Build payload
|
||||
payload = {"power": request.power}
|
||||
if request.brightness is not None and request.power == "on":
|
||||
payload["brightness"] = request.brightness
|
||||
|
||||
# Send commands to all light devices
|
||||
affected_ids = []
|
||||
errors = []
|
||||
|
||||
for device in light_devices:
|
||||
try:
|
||||
await publish_abstract_set(
|
||||
device_type=device["type"],
|
||||
device_id=device["device_id"],
|
||||
payload=payload
|
||||
)
|
||||
affected_ids.append(device["device_id"])
|
||||
logger.info(f"Sent command to {device['device_id']}: {payload}")
|
||||
except Exception as e:
|
||||
logger.error(f"Failed to control {device['device_id']}: {e}")
|
||||
errors.append({
|
||||
"device_id": device["device_id"],
|
||||
"error": str(e)
|
||||
})
|
||||
|
||||
return {
|
||||
"room": room_id,
|
||||
"command": "lights",
|
||||
"payload": payload,
|
||||
"affected_devices": affected_ids,
|
||||
"success_count": len(affected_ids),
|
||||
"error_count": len(errors),
|
||||
"errors": errors if errors else None
|
||||
}
|
||||
|
||||
|
||||
@router.post("/rooms/{room_id}/heating", status_code=status.HTTP_202_ACCEPTED)
|
||||
async def control_room_heating(room_id: str, request: HeatingControlRequest) -> dict[str, Any]:
|
||||
"""Control all thermostats in a room.
|
||||
|
||||
Args:
|
||||
room_id: ID of the room
|
||||
request: Heating control parameters
|
||||
|
||||
Returns:
|
||||
dict with affected device_ids and command summary
|
||||
"""
|
||||
from apps.api.main import load_devices, publish_abstract_set
|
||||
|
||||
# Get all devices in room
|
||||
room_devices = get_room_devices(room_id)
|
||||
|
||||
# Filter out excluded devices
|
||||
room_device_ids = {d["device_id"] for d in room_devices if not d.get("excluded", False)}
|
||||
|
||||
# Load all devices to filter by type
|
||||
all_devices = load_devices()
|
||||
|
||||
# Filter for thermostat devices in this room
|
||||
thermostat_devices = [
|
||||
d for d in all_devices
|
||||
if d["device_id"] in room_device_ids and d["type"] == "thermostat"
|
||||
]
|
||||
|
||||
if not thermostat_devices:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_404_NOT_FOUND,
|
||||
detail=f"No thermostat devices found in room '{room_name}'"
|
||||
)
|
||||
|
||||
# Build payload
|
||||
payload = {"target": request.target}
|
||||
|
||||
# Send commands to all thermostat devices
|
||||
affected_ids = []
|
||||
errors = []
|
||||
|
||||
for device in thermostat_devices:
|
||||
try:
|
||||
await publish_abstract_set(
|
||||
device_type="thermostat",
|
||||
device_id=device["device_id"],
|
||||
payload=payload
|
||||
)
|
||||
affected_ids.append(device["device_id"])
|
||||
logger.info(f"Sent heating command to {device['device_id']}: {payload}")
|
||||
except Exception as e:
|
||||
logger.error(f"Failed to control {device['device_id']}: {e}")
|
||||
errors.append({
|
||||
"device_id": device["device_id"],
|
||||
"error": str(e)
|
||||
})
|
||||
|
||||
return {
|
||||
"room": room_id,
|
||||
"command": "heating",
|
||||
"payload": payload,
|
||||
"affected_devices": affected_ids,
|
||||
"success_count": len(affected_ids),
|
||||
"error_count": len(errors),
|
||||
"errors": errors if errors else None
|
||||
}
|
||||
@@ -416,6 +416,7 @@
|
||||
if (feedbackDevice) {
|
||||
const feedbackSection = document.createElement('div');
|
||||
feedbackSection.className = 'device-section';
|
||||
feedbackSection.dataset.deviceId = feedbackDevice.device_id;
|
||||
renderFeedbackDisplay(feedbackSection, feedbackDevice);
|
||||
container.appendChild(feedbackSection);
|
||||
}
|
||||
@@ -465,19 +466,10 @@
|
||||
|
||||
console.log(`Rendering feedback for ${device.device_id}:`, state);
|
||||
|
||||
const values = Object.values(state || {});
|
||||
const isActive = values.some(v =>
|
||||
v === true ||
|
||||
v === 'on' ||
|
||||
v === 1
|
||||
);
|
||||
|
||||
if (values.length === 0) {
|
||||
label.textContent = 'Kein Status verfügbar';
|
||||
if (state.contact === 'closed') {
|
||||
label.textContent = 'Schütz ✅ eingeschaltet';
|
||||
} else {
|
||||
label.textContent = isActive
|
||||
? 'Fahrzeug verbunden'
|
||||
: 'Kein Fahrzeug verbunden';
|
||||
label.textContent = 'Schütz 🅾️ ausgeschaltet';
|
||||
}
|
||||
|
||||
controlGroup.appendChild(label);
|
||||
@@ -616,12 +608,14 @@
|
||||
const state = deviceStates[deviceId];
|
||||
console.log(`Updating UI for ${deviceId}:`, state);
|
||||
|
||||
switch (device.type) {
|
||||
case 'relay':
|
||||
case 'outlet':
|
||||
switch (deviceId) {
|
||||
case 'power_relay_caroutlet':
|
||||
updateOutletUI(deviceId, state);
|
||||
break;
|
||||
case 'three_phase_powermeter':
|
||||
case 'sensor_caroutlet':
|
||||
updateFeedbackDisplay(deviceId, state);
|
||||
break;
|
||||
case 'powermeter_caroutlet':
|
||||
updateThreePhasePowerUI(deviceId, state);
|
||||
break;
|
||||
}
|
||||
@@ -652,6 +646,29 @@
|
||||
}
|
||||
}
|
||||
|
||||
function updateFeedbackDisplay(deviceId, state) {
|
||||
const section = document.querySelector(`[data-device-id="${deviceId}"]`);
|
||||
if (!section) return;
|
||||
|
||||
const label = section.querySelector('.toggle-label');
|
||||
|
||||
if (label) {
|
||||
const isOn = state.contact === 'closed';
|
||||
label.textContent = isOn ? 'Schütz ✅ eingeschaltet' : 'Schütz 🅾️ ausgeschaltet';
|
||||
|
||||
// Update state display in separate card
|
||||
const cards = section.querySelectorAll('.card');
|
||||
if (cards.length >= 3) { // Header, Control, State
|
||||
const stateCard = cards[2];
|
||||
stateCard.innerHTML = `
|
||||
<div style="font-size: 18px; font-weight: 600; color: ${isOn ? '#34c759' : '#666'};">
|
||||
Status: ${isOn ? 'Eingeschaltet' : 'Ausgeschaltet'}
|
||||
</div>
|
||||
`;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function updateThreePhasePowerUI(deviceId, state) {
|
||||
// Update overview
|
||||
const totalPower = document.getElementById(`total-power-${deviceId}`);
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
rooms:
|
||||
- name: Schlafzimmer
|
||||
- id: schlafzimmer
|
||||
name: Schlafzimmer
|
||||
devices:
|
||||
- device_id: bettlicht_patty
|
||||
title: Bettlicht Patty
|
||||
@@ -33,7 +34,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 47
|
||||
- name: Esszimmer
|
||||
- id: esszimmer
|
||||
name: Esszimmer
|
||||
devices:
|
||||
- device_id: deckenlampe_esszimmer
|
||||
title: Deckenlampe Esszimmer
|
||||
@@ -79,7 +81,8 @@ rooms:
|
||||
title: Kontakt Straße links
|
||||
icon: 🪟
|
||||
rank: 97
|
||||
- name: Wohnzimmer
|
||||
- id: wohnzimmer
|
||||
name: Wohnzimmer
|
||||
devices:
|
||||
- device_id: lampe_naehtischchen_wohnzimmer
|
||||
title: Lampe Naehtischchen Wohnzimmer
|
||||
@@ -121,7 +124,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 138
|
||||
- name: Küche
|
||||
- id: kueche
|
||||
name: Küche
|
||||
devices:
|
||||
- device_id: kueche_deckenlampe
|
||||
title: Küche Deckenlampe
|
||||
@@ -135,6 +139,7 @@ rooms:
|
||||
title: Küche Putzlicht
|
||||
icon: 💡
|
||||
rank: 143
|
||||
excluded: true
|
||||
- device_id: kueche_fensterbank_licht
|
||||
title: Küche Fensterbank
|
||||
icon: 💡
|
||||
@@ -163,7 +168,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 155
|
||||
- name: Arbeitszimmer Patty
|
||||
- id: arbeitszimmer_patty
|
||||
name: Arbeitszimmer Patty
|
||||
devices:
|
||||
- device_id: leselampe_patty
|
||||
title: Leselampe Patty
|
||||
@@ -205,7 +211,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 189
|
||||
- name: Arbeitszimmer Wolfgang
|
||||
- id: arbeitszimmer_wolfgang
|
||||
name: Arbeitszimmer Wolfgang
|
||||
devices:
|
||||
- device_id: thermostat_wolfgang
|
||||
title: Wolfgang
|
||||
@@ -223,7 +230,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 202
|
||||
- name: Flur
|
||||
- id: flur
|
||||
name: Flur
|
||||
devices:
|
||||
- device_id: deckenlampe_flur_oben
|
||||
title: Deckenlampe Flur oben
|
||||
@@ -249,7 +257,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 235
|
||||
- name: Sportzimmer
|
||||
- id: sportzimmer
|
||||
name: Sportzimmer
|
||||
devices:
|
||||
- device_id: sportlicht_regal
|
||||
title: Sportlicht Regal
|
||||
@@ -267,7 +276,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 265
|
||||
- name: Bad Oben
|
||||
- id: bad_oben
|
||||
name: Bad Oben
|
||||
devices:
|
||||
- device_id: thermostat_bad_oben
|
||||
title: Thermostat Bad Oben
|
||||
@@ -281,7 +291,8 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 272
|
||||
- name: Bad Unten
|
||||
- id: bad_unten
|
||||
name: Bad Unten
|
||||
devices:
|
||||
- device_id: thermostat_bad_unten
|
||||
title: Thermostat Bad Unten
|
||||
@@ -295,13 +306,15 @@ rooms:
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 282
|
||||
- name: Waschküche
|
||||
- id: waschkueche
|
||||
name: Waschküche
|
||||
devices:
|
||||
- device_id: sensor_waschkueche
|
||||
title: Temperatur & Luftfeuchte
|
||||
icon: 🌡️
|
||||
rank: 290
|
||||
- name: Outdoor
|
||||
- id: outdoor
|
||||
name: Outdoor
|
||||
devices:
|
||||
- device_id: licht_terasse
|
||||
title: Licht Terasse
|
||||
@@ -311,14 +324,15 @@ rooms:
|
||||
title: Gartenlicht vorne
|
||||
icon: 💡
|
||||
rank: 291
|
||||
- name: Garage
|
||||
- id: garage
|
||||
name: Garage
|
||||
devices:
|
||||
- device_id: power_relay_caroutlet
|
||||
title: Ladestrom
|
||||
icon: ⚡
|
||||
rank: 310
|
||||
- device_id: sensor_caroutlet
|
||||
title: Kabelstatus
|
||||
title: Schützzustand
|
||||
icon: 🔌
|
||||
rank: 315
|
||||
- device_id: powermeter_caroutlet
|
||||
|
||||
@@ -18,6 +18,7 @@ class DeviceTile(BaseModel):
|
||||
title: Display title for the device
|
||||
icon: Icon name or emoji for the device
|
||||
rank: Sort order within the room (lower = first)
|
||||
excluded: Optional flag to exclude device from certain operations
|
||||
"""
|
||||
|
||||
device_id: str = Field(
|
||||
@@ -41,15 +42,26 @@ class DeviceTile(BaseModel):
|
||||
description="Sort order (lower values appear first)"
|
||||
)
|
||||
|
||||
excluded: bool = Field(
|
||||
default=False,
|
||||
description="Exclude device from bulk operations"
|
||||
)
|
||||
|
||||
|
||||
class Room(BaseModel):
|
||||
"""Represents a room containing devices.
|
||||
|
||||
Attributes:
|
||||
id: Unique room identifier (used for API endpoints)
|
||||
name: Room name (e.g., "Wohnzimmer", "Küche")
|
||||
devices: List of device tiles in this room
|
||||
"""
|
||||
|
||||
id: str = Field(
|
||||
...,
|
||||
description="Unique room identifier"
|
||||
)
|
||||
|
||||
name: str = Field(
|
||||
...,
|
||||
description="Room name"
|
||||
|
||||
Reference in New Issue
Block a user