anti/DECNET
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(mutator): update_decky payload accepts top-level services list

Browse Source 
apply_update_decky only merged payload.patch into decky_config. Since
services is a separate DB column, there was no way to replace a decky's
services list via a mutation. Add a top-level services key to the op
payload that maps straight onto the services column.

Unblocks the MazeNET editor routing service-add/service-drop actions
through the mutation queue on active topologies.
This commit is contained in:
anti
2026-04-21 19:56:58 -04:00
parent aa848d5260
commit a93cbe76f9
2 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
decnet/mutator/ops.py
View File

@@ -280,6 +280,7 @@ async def apply_update_decky(
``payload`` keys: ``payload`` keys:
``decky`` — decky name. ``decky`` — decky name.
``patch`` — dict merged into existing ``decky_config``. ``patch`` — dict merged into existing ``decky_config``.
``services`` — replacement top-level services list.
``x``,``y`` — layout coords. ``x``,``y`` — layout coords.
""" """
hydrated = await _hydrated(repo, topology_id) hydrated = await _hydrated(repo, topology_id)
@@ -291,6 +292,8 @@ async def apply_update_decky(
merged = dict(decky["decky_config"]) merged = dict(decky["decky_config"])
merged.update(payload["patch"]) merged.update(payload["patch"])
patch["decky_config"] = merged patch["decky_config"] = merged
if "services" in payload:
patch["services"] = list(payload["services"])
for key in ("x", "y"): for key in ("x", "y"):
if key in payload: if key in payload:
patch[key] = payload[key] patch[key] = payload[key]

19
tests/topology/test_mutator.py
View File

@@ -158,6 +158,25 @@ async def test_apply_add_lan_persists(repo):
assert "LAN-MUT" in names assert "LAN-MUT" in names
@pytest.mark.anyio
async def test_apply_update_decky_replaces_services(repo):
"""Top-level ``services`` payload key replaces the decky's services list."""
tid = await _make_active(repo)
decky = (await repo.list_topology_deckies(tid))[0]
await apply_update_decky(
repo, tid,
{
"decky": decky["decky_config"]["name"],
"services": ["ssh", "http"],
},
)
updated = next(
d for d in await repo.list_topology_deckies(tid)
if d["uuid"] == decky["uuid"]
)
assert sorted(updated["services"]) == ["http", "ssh"]
@pytest.mark.anyio @pytest.mark.anyio
async def test_apply_rejected_on_validator_error(repo): async def test_apply_rejected_on_validator_error(repo):
"""Unknown service name must trip the post-apply validator.""" """Unknown service name must trip the post-apply validator."""