Compare commits
8 Commits
0.14.0-con
...
0.15.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
4f5bcd7dbf
|
|||
|
3bcaa93570
|
|||
|
331945f789
|
|||
|
52235be637
|
|||
|
94589f52d7
|
|||
|
474b41ffce
|
|||
|
79081e7480
|
|||
|
424f1d6743
|
@@ -1,5 +1,8 @@
|
|||||||
when:
|
when:
|
||||||
event: [tag]
|
event: [tag]
|
||||||
|
ref:
|
||||||
|
exclude:
|
||||||
|
- refs/tags/*-configchange
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
create_namespace:
|
create_namespace:
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ import uuid
|
|||||||
from aiomqtt import Client
|
from aiomqtt import Client
|
||||||
from pydantic import ValidationError
|
from pydantic import ValidationError
|
||||||
|
|
||||||
from packages.home_capabilities import LightState, ThermostatState, ContactState, TempHumidityState, RelayState, ThreePhasePowerState, SwitchState
|
from packages.home_capabilities import LightState, ThermostatState, ContactState, TempHumidityState, RelayState, ThreePhasePowerState
|
||||||
from apps.abstraction.transformation import (
|
from apps.abstraction.transformation import (
|
||||||
transform_abstract_to_vendor,
|
transform_abstract_to_vendor,
|
||||||
transform_vendor_to_abstract
|
transform_vendor_to_abstract
|
||||||
@@ -174,10 +174,6 @@ async def handle_abstract_set(
|
|||||||
# Contact sensors are read-only - SET commands should not occur
|
# Contact sensors are read-only - SET commands should not occur
|
||||||
logger.warning(f"Contact sensor {device_id} received SET command - ignoring (read-only device)")
|
logger.warning(f"Contact sensor {device_id} received SET command - ignoring (read-only device)")
|
||||||
return
|
return
|
||||||
elif device_type == "switch":
|
|
||||||
# Switches are read-only - SET commands should not occur
|
|
||||||
logger.warning(f"Switch {device_id} received SET command - ignoring (read-only device)")
|
|
||||||
return
|
|
||||||
except ValidationError as e:
|
except ValidationError as e:
|
||||||
logger.error(f"Validation failed for {device_type} SET {device_id}: {e}")
|
logger.error(f"Validation failed for {device_type} SET {device_id}: {e}")
|
||||||
return
|
return
|
||||||
@@ -231,9 +227,6 @@ async def handle_vendor_state(
|
|||||||
elif device_type == "three_phase_powermeter":
|
elif device_type == "three_phase_powermeter":
|
||||||
# Validate three-phase powermeter state
|
# Validate three-phase powermeter state
|
||||||
ThreePhasePowerState.model_validate(abstract_payload)
|
ThreePhasePowerState.model_validate(abstract_payload)
|
||||||
elif device_type == "switch":
|
|
||||||
# Validate switch state
|
|
||||||
SwitchState.model_validate(abstract_payload)
|
|
||||||
except ValidationError as e:
|
except ValidationError as e:
|
||||||
logger.error(f"Validation failed for {device_type} STATE {device_id}: {e}")
|
logger.error(f"Validation failed for {device_type} STATE {device_id}: {e}")
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -15,6 +15,7 @@ from apps.abstraction.vendors import (
|
|||||||
simulator,
|
simulator,
|
||||||
zigbee2mqtt,
|
zigbee2mqtt,
|
||||||
max,
|
max,
|
||||||
|
test,
|
||||||
shelly,
|
shelly,
|
||||||
tasmota,
|
tasmota,
|
||||||
hottis_pv_modbus,
|
hottis_pv_modbus,
|
||||||
@@ -40,6 +41,7 @@ for vendor_name, vendor_module in [
|
|||||||
("simulator", simulator),
|
("simulator", simulator),
|
||||||
("zigbee2mqtt", zigbee2mqtt),
|
("zigbee2mqtt", zigbee2mqtt),
|
||||||
("max", max),
|
("max", max),
|
||||||
|
("test", test),
|
||||||
("shelly", shelly),
|
("shelly", shelly),
|
||||||
("tasmota", tasmota),
|
("tasmota", tasmota),
|
||||||
("hottis_pv_modbus", hottis_pv_modbus),
|
("hottis_pv_modbus", hottis_pv_modbus),
|
||||||
|
|||||||
62
apps/abstraction/vendors/test.py
vendored
Normal file
62
apps/abstraction/vendors/test.py
vendored
Normal file
@@ -0,0 +1,62 @@
|
|||||||
|
"""test vendor transformations."""
|
||||||
|
|
||||||
|
import json
|
||||||
|
import logging
|
||||||
|
from typing import Any
|
||||||
|
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
def transform_contact_sensor_to_vendor(payload: dict[str, Any]) -> str:
|
||||||
|
"""Transform abstract contact sensor payload to MAX! format.
|
||||||
|
|
||||||
|
Contact sensors are read-only.
|
||||||
|
"""
|
||||||
|
logger.warning("Contact sensors are read-only - SET commands should not be used")
|
||||||
|
return json.dumps(payload)
|
||||||
|
|
||||||
|
|
||||||
|
def transform_contact_sensor_to_abstract(payload: str) -> dict[str, Any]:
|
||||||
|
try:
|
||||||
|
contact_value = payload.strip().lower()
|
||||||
|
return {
|
||||||
|
"contact": "open" if (contact_value == "open") else "closed"
|
||||||
|
}
|
||||||
|
except (ValueError, TypeError) as e:
|
||||||
|
logger.error(f"contact sensor failed to parse: {payload}, error: {e}")
|
||||||
|
return {"contact": "closed"}
|
||||||
|
|
||||||
|
|
||||||
|
def transform_thermostat_to_vendor(payload: dict[str, Any]) -> str:
|
||||||
|
if "target" not in payload:
|
||||||
|
logger.warning(f"thermostat payload missing 'target': {payload}")
|
||||||
|
return "21"
|
||||||
|
|
||||||
|
target_temp = payload["target"]
|
||||||
|
|
||||||
|
if isinstance(target_temp, (int, float)):
|
||||||
|
int_temp = int(round(target_temp))
|
||||||
|
return str(int_temp)
|
||||||
|
|
||||||
|
logger.warning(f"invalid target temperature type: {type(target_temp)}")
|
||||||
|
return "21"
|
||||||
|
|
||||||
|
|
||||||
|
def transform_thermostat_to_abstract(payload: str) -> dict[str, Any]:
|
||||||
|
target_temp = float(payload.strip())
|
||||||
|
|
||||||
|
return {
|
||||||
|
"target": target_temp,
|
||||||
|
"mode": "heat"
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
# Registry of handlers for this vendor
|
||||||
|
HANDLERS = {
|
||||||
|
("contact_sensor", "to_vendor"): transform_contact_sensor_to_vendor,
|
||||||
|
("contact_sensor", "to_abstract"): transform_contact_sensor_to_abstract,
|
||||||
|
("contact", "to_vendor"): transform_contact_sensor_to_vendor,
|
||||||
|
("contact", "to_abstract"): transform_contact_sensor_to_abstract,
|
||||||
|
("thermostat", "to_vendor"): transform_thermostat_to_vendor,
|
||||||
|
("thermostat", "to_abstract"): transform_thermostat_to_abstract,
|
||||||
|
}
|
||||||
20
apps/abstraction/vendors/zigbee2mqtt.py
vendored
20
apps/abstraction/vendors/zigbee2mqtt.py
vendored
@@ -161,24 +161,6 @@ def transform_temp_humidity_sensor_to_abstract(payload: str) -> dict[str, Any]:
|
|||||||
return payload
|
return payload
|
||||||
|
|
||||||
|
|
||||||
def transform_switch_to_vendor(payload: dict[str, Any]) -> str:
|
|
||||||
"""Transform abstract switch payload to zigbee2mqtt format.
|
|
||||||
|
|
||||||
Switches are read-only, so this should not be called for SET commands.
|
|
||||||
"""
|
|
||||||
logger.warning("Switches are read-only - SET commands should not be used")
|
|
||||||
return json.dumps(payload)
|
|
||||||
|
|
||||||
|
|
||||||
def transform_switch_to_abstract(payload: str) -> dict[str, Any]:
|
|
||||||
"""Transform zigbee2mqtt switch payload to abstract format.
|
|
||||||
|
|
||||||
Passthrough - zigbee2mqtt provides action, battery, linkquality directly.
|
|
||||||
"""
|
|
||||||
payload = json.loads(payload)
|
|
||||||
return payload
|
|
||||||
|
|
||||||
|
|
||||||
def transform_relay_to_vendor(payload: dict[str, Any]) -> str:
|
def transform_relay_to_vendor(payload: dict[str, Any]) -> str:
|
||||||
"""Transform abstract relay payload to zigbee2mqtt format.
|
"""Transform abstract relay payload to zigbee2mqtt format.
|
||||||
|
|
||||||
@@ -222,8 +204,6 @@ HANDLERS = {
|
|||||||
("temp_humidity_sensor", "to_abstract"): transform_temp_humidity_sensor_to_abstract,
|
("temp_humidity_sensor", "to_abstract"): transform_temp_humidity_sensor_to_abstract,
|
||||||
("temp_humidity", "to_vendor"): transform_temp_humidity_sensor_to_vendor,
|
("temp_humidity", "to_vendor"): transform_temp_humidity_sensor_to_vendor,
|
||||||
("temp_humidity", "to_abstract"): transform_temp_humidity_sensor_to_abstract,
|
("temp_humidity", "to_abstract"): transform_temp_humidity_sensor_to_abstract,
|
||||||
("switch", "to_vendor"): transform_switch_to_vendor,
|
|
||||||
("switch", "to_abstract"): transform_switch_to_abstract,
|
|
||||||
("relay", "to_vendor"): transform_relay_to_vendor,
|
("relay", "to_vendor"): transform_relay_to_vendor,
|
||||||
("relay", "to_abstract"): transform_relay_to_abstract,
|
("relay", "to_abstract"): transform_relay_to_abstract,
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -471,21 +471,16 @@ devices:
|
|||||||
name: Heizung
|
name: Heizung
|
||||||
type: thermostat
|
type: thermostat
|
||||||
cap_version: "thermostat@1.0.0"
|
cap_version: "thermostat@1.0.0"
|
||||||
technology: max
|
technology: zigbee2mqtt
|
||||||
features:
|
features:
|
||||||
mode: true
|
heating: true
|
||||||
target: true
|
temperature_range:
|
||||||
current: false
|
- 5
|
||||||
|
- 30
|
||||||
|
temperature_step: 0.5
|
||||||
topics:
|
topics:
|
||||||
set: "homegear/instance1/set/48/1/SET_TEMPERATURE"
|
state: "zigbee2mqtt/0x003c84fffebdcc28"
|
||||||
state: "homegear/instance1/plain/48/1/SET_TEMPERATURE"
|
set: "zigbee2mqtt/0x003c84fffebdcc28/set"
|
||||||
metadata:
|
|
||||||
friendly_name: "Thermostat Bad Unten"
|
|
||||||
location: "Bad Unten"
|
|
||||||
vendor: "eQ-3"
|
|
||||||
model: "MAX! Thermostat"
|
|
||||||
peer_id: "48"
|
|
||||||
channel: "1"
|
|
||||||
- device_id: sterne_wohnzimmer
|
- device_id: sterne_wohnzimmer
|
||||||
homekit_aid: 32
|
homekit_aid: 32
|
||||||
name: Sterne
|
name: Sterne
|
||||||
@@ -1157,3 +1152,38 @@ devices:
|
|||||||
topics:
|
topics:
|
||||||
state: "zigbee2mqtt/0x842e14fffefe4ba4"
|
state: "zigbee2mqtt/0x842e14fffefe4ba4"
|
||||||
set: "zigbee2mqtt/0x842e14fffefe4ba4/set"
|
set: "zigbee2mqtt/0x842e14fffefe4ba4/set"
|
||||||
|
|
||||||
|
- device_id: kontakt_test_1
|
||||||
|
homekit_aid: 97
|
||||||
|
name: Kontakt Test 1
|
||||||
|
type: contact
|
||||||
|
cap_version: contact_sensor@1.0.0
|
||||||
|
technology: test
|
||||||
|
topics:
|
||||||
|
state: test/kontakt1/state
|
||||||
|
features: {}
|
||||||
|
- device_id: kontakt_test_2
|
||||||
|
homekit_aid: 98
|
||||||
|
name: Kontakt Test 2
|
||||||
|
type: contact
|
||||||
|
cap_version: contact_sensor@1.0.0
|
||||||
|
technology: test
|
||||||
|
topics:
|
||||||
|
state: test/kontakt2/state
|
||||||
|
features: {}
|
||||||
|
- device_id: thermostat_test
|
||||||
|
homekit_aid: 99
|
||||||
|
name: Thermostat Test
|
||||||
|
type: thermostat
|
||||||
|
cap_version: "thermostat@1.0.0"
|
||||||
|
technology: test
|
||||||
|
features:
|
||||||
|
heating: true
|
||||||
|
temperature_range:
|
||||||
|
- 5
|
||||||
|
- 30
|
||||||
|
temperature_step: 0.5
|
||||||
|
topics:
|
||||||
|
state: "test/thermostat1/state"
|
||||||
|
set: "test/thermostat1/set"
|
||||||
|
|
||||||
@@ -115,3 +115,17 @@ rules:
|
|||||||
eco_target: 5.0
|
eco_target: 5.0
|
||||||
open_min_secs: 20
|
open_min_secs: 20
|
||||||
close_min_secs: 20
|
close_min_secs: 20
|
||||||
|
- id: window_setback_test
|
||||||
|
enabled: true
|
||||||
|
name: Fensterabsenkung Test
|
||||||
|
type: window_setback@1.0
|
||||||
|
objects:
|
||||||
|
contacts:
|
||||||
|
- kontakt_test_1
|
||||||
|
- kontakt_test_2
|
||||||
|
thermostats:
|
||||||
|
- thermostat_test
|
||||||
|
params:
|
||||||
|
eco_target: 7.0
|
||||||
|
open_min_secs: 20
|
||||||
|
close_min_secs: 20
|
||||||
|
|||||||
@@ -8,8 +8,6 @@ from packages.home_capabilities.contact_sensor import CAP_VERSION as CONTACT_SEN
|
|||||||
from packages.home_capabilities.contact_sensor import ContactState
|
from packages.home_capabilities.contact_sensor import ContactState
|
||||||
from packages.home_capabilities.temp_humidity_sensor import CAP_VERSION as TEMP_HUMIDITY_SENSOR_VERSION
|
from packages.home_capabilities.temp_humidity_sensor import CAP_VERSION as TEMP_HUMIDITY_SENSOR_VERSION
|
||||||
from packages.home_capabilities.temp_humidity_sensor import TempHumidityState
|
from packages.home_capabilities.temp_humidity_sensor import TempHumidityState
|
||||||
from packages.home_capabilities.switch import CAP_VERSION as SWITCH_VERSION
|
|
||||||
from packages.home_capabilities.switch import SwitchState
|
|
||||||
from packages.home_capabilities.relay import CAP_VERSION as RELAY_VERSION
|
from packages.home_capabilities.relay import CAP_VERSION as RELAY_VERSION
|
||||||
from packages.home_capabilities.relay import RelayState
|
from packages.home_capabilities.relay import RelayState
|
||||||
from packages.home_capabilities.three_phase_powermeter import CAP_VERSION as THREE_PHASE_POWERMETER_VERSION
|
from packages.home_capabilities.three_phase_powermeter import CAP_VERSION as THREE_PHASE_POWERMETER_VERSION
|
||||||
@@ -44,8 +42,6 @@ __all__ = [
|
|||||||
"CONTACT_SENSOR_VERSION",
|
"CONTACT_SENSOR_VERSION",
|
||||||
"TempHumidityState",
|
"TempHumidityState",
|
||||||
"TEMP_HUMIDITY_SENSOR_VERSION",
|
"TEMP_HUMIDITY_SENSOR_VERSION",
|
||||||
"SwitchState",
|
|
||||||
"SWITCH_VERSION",
|
|
||||||
"RelayState",
|
"RelayState",
|
||||||
"RELAY_VERSION",
|
"RELAY_VERSION",
|
||||||
"DeviceTile",
|
"DeviceTile",
|
||||||
|
|||||||
@@ -1,69 +0,0 @@
|
|||||||
"""Switch Capability - Wireless Button/Switch (read-only).
|
|
||||||
|
|
||||||
This module defines the SwitchState model for wireless switches/buttons.
|
|
||||||
These devices report action events (e.g., button presses) and are read-only devices.
|
|
||||||
|
|
||||||
Capability Version: switch@1.0.0
|
|
||||||
"""
|
|
||||||
|
|
||||||
from datetime import datetime
|
|
||||||
from typing import Annotated
|
|
||||||
|
|
||||||
from pydantic import BaseModel, Field
|
|
||||||
|
|
||||||
|
|
||||||
# Capability metadata
|
|
||||||
CAP_VERSION = "switch@1.0.0"
|
|
||||||
DISPLAY_NAME = "Switch"
|
|
||||||
|
|
||||||
|
|
||||||
class SwitchState(BaseModel):
|
|
||||||
"""State model for wireless switches/buttons.
|
|
||||||
|
|
||||||
Wireless switches are read-only devices that report button actions such as
|
|
||||||
single press, double press, long press, etc. They typically also report
|
|
||||||
battery level and signal quality.
|
|
||||||
|
|
||||||
Attributes:
|
|
||||||
action: Action type (e.g., "single", "double", "long", "hold", etc.)
|
|
||||||
battery: Battery level percentage (0-100), optional
|
|
||||||
linkquality: MQTT link quality indicator, optional
|
|
||||||
voltage: Battery voltage in mV, optional
|
|
||||||
ts: Timestamp of the action event, optional
|
|
||||||
|
|
||||||
Examples:
|
|
||||||
>>> SwitchState(action="single")
|
|
||||||
SwitchState(action='single', battery=None, ...)
|
|
||||||
|
|
||||||
>>> SwitchState(action="double", battery=95, linkquality=87)
|
|
||||||
SwitchState(action='double', battery=95, linkquality=87, ...)
|
|
||||||
"""
|
|
||||||
|
|
||||||
action: str = Field(
|
|
||||||
...,
|
|
||||||
description="Action type: 'single', 'double', 'long', 'hold', etc."
|
|
||||||
)
|
|
||||||
|
|
||||||
battery: Annotated[int, Field(ge=0, le=100)] | None = Field(
|
|
||||||
None,
|
|
||||||
description="Battery level in percent (0-100)"
|
|
||||||
)
|
|
||||||
|
|
||||||
linkquality: int | None = Field(
|
|
||||||
None,
|
|
||||||
description="Link quality indicator (typically 0-255)"
|
|
||||||
)
|
|
||||||
|
|
||||||
voltage: int | None = Field(
|
|
||||||
None,
|
|
||||||
description="Battery voltage in millivolts"
|
|
||||||
)
|
|
||||||
|
|
||||||
ts: datetime | None = Field(
|
|
||||||
None,
|
|
||||||
description="Timestamp of the action event"
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
# Public API
|
|
||||||
__all__ = ["SwitchState", "CAP_VERSION", "DISPLAY_NAME"]
|
|
||||||
15
tools/deploy-configuration.sh
Executable file
15
tools/deploy-configuration.sh
Executable file
@@ -0,0 +1,15 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
NAMESPACE=homea2
|
||||||
|
|
||||||
|
kubectl create configmap home-automation-config \
|
||||||
|
--from-file=devices.yaml=config/devices.yaml \
|
||||||
|
--from-file=groups.yaml=config/groups.yaml \
|
||||||
|
--from-file=layout.yaml=config/layout.yaml \
|
||||||
|
--from-file=rules.yaml=config/rules.yaml \
|
||||||
|
--from-file=scenes.yaml=config/scenes.yaml \
|
||||||
|
--namespace=$NAMESPACE \
|
||||||
|
--dry-run=client -o yaml | kubectl apply -f -
|
||||||
|
|
||||||
|
kubectl apply -f deployment/configmap.yaml -n $NAMESPACE
|
||||||
|
|
||||||
Reference in New Issue
Block a user