v1.4.3+v1.4.4: icon centers snap to markup grid (drag + one-time DB snap); CRITICAL: optimistic locking for config (rev/expected_rev/conflict), houseplan_config_updated event with live client resync, per-device layout updates instead of full set

This commit is contained in:
JB
2026-07-04 12:06:09 +03:00
parent 609872b7b8
commit 08cd929b8d
9 changed files with 110 additions and 23 deletions
+1 -1
View File
@@ -8,7 +8,7 @@ FRONTEND_URL = "/houseplan_files/houseplan-card.js"
PLANS_URL = "/houseplan_files/plans"
PLANS_DIR = "houseplan/plans" # относительно каталога конфигурации HA
CONF_ADMIN_ONLY = "admin_only"
VERSION = "1.4.2"
VERSION = "1.4.4"
DEFAULT_CONFIG: dict = {
"spaces": [],
File diff suppressed because one or more lines are too long
+26 -6
View File
@@ -166,23 +166,43 @@ async def ws_layout_update(hass: HomeAssistant, connection, msg: dict[str, Any])
@websocket_api.websocket_command({vol.Required("type"): "houseplan/config/get"})
@websocket_api.async_response
async def ws_config_get(hass: HomeAssistant, connection, msg: dict[str, Any]) -> None:
"""Вернуть конфигурацию (пространства, оверрайды, виртуальные устройства, настройки)."""
"""Вернуть конфигурацию и её ревизию."""
data = await _config_store(hass).async_load() or {}
config = {**DEFAULT_CONFIG, **data.get("config", {})}
connection.send_result(msg["id"], {"config": config})
connection.send_result(msg["id"], {"config": config, "rev": data.get("rev", 0)})
@websocket_api.websocket_command(
{vol.Required("type"): "houseplan/config/set", vol.Required("config"): CONFIG_SCHEMA}
{
vol.Required("type"): "houseplan/config/set",
vol.Required("config"): CONFIG_SCHEMA,
vol.Optional("expected_rev"): int,
}
)
@websocket_api.async_response
async def ws_config_set(hass: HomeAssistant, connection, msg: dict[str, Any]) -> None:
"""Полностью заменить конфигурацию."""
"""Заменить конфигурацию с оптимистичной блокировкой (expected_rev).
Защита от гонки нескольких открытых клиентов: если конфиг менялся с момента
последнего чтения клиентом — возвращается ошибка conflict, клиент обязан
перечитать конфиг и повторить правку поверх свежей версии.
"""
if not _check_write(hass, connection):
connection.send_error(msg["id"], "unauthorized", "Правка конфигурации разрешена только администраторам")
return
await _config_store(hass).async_save({"config": msg["config"]})
connection.send_result(msg["id"], {"ok": True})
store = _config_store(hass)
data = await store.async_load() or {}
current_rev = data.get("rev", 0)
if "expected_rev" in msg and msg["expected_rev"] != current_rev:
connection.send_error(
msg["id"], "conflict",
f"Конфигурация изменена в другом окне (rev {current_rev} != {msg['expected_rev']})",
)
return
new_rev = current_rev + 1
await store.async_save({"config": msg["config"], "rev": new_rev})
hass.bus.async_fire("houseplan_config_updated", {"rev": new_rev})
connection.send_result(msg["id"], {"ok": True, "rev": new_rev})
# ---------------- загрузка планов ----------------