aboutsummaryrefslogtreecommitdiffstats
path: root/packages/meshbay-node/src/meshbay_node/ui
diff options
context:
space:
mode:
Diffstat (limited to 'packages/meshbay-node/src/meshbay_node/ui')
-rw-r--r--packages/meshbay-node/src/meshbay_node/ui/app.py38
1 files changed, 38 insertions, 0 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/ui/app.py b/packages/meshbay-node/src/meshbay_node/ui/app.py
index a068a8d..b505f25 100644
--- a/packages/meshbay-node/src/meshbay_node/ui/app.py
+++ b/packages/meshbay-node/src/meshbay_node/ui/app.py
@@ -295,6 +295,44 @@ def create_ui_app(state: dict) -> FastAPI:
async def init_gek(group_id: str, rotate: bool = False):
return await _op(lambda: ops.set_gek(state, group_id, rotate=rotate))
+ # ── Roots management (operator only, localhost) ────────────────────────
+
+ @app.post("/api/groups/{group_id}/roots")
+ async def add_root(group_id: str, payload: dict):
+ result = await _op(lambda: ops.add_root(
+ state, group_id,
+ (payload.get("path") or "").strip(),
+ name=(payload.get("name") or "").strip(),
+ kind=(payload.get("kind") or "generic").strip(),
+ upload=bool(payload.get("upload", False)),
+ ))
+ reload_fn = state.get("reload_fn")
+ if reload_fn:
+ asyncio.ensure_future(reload_fn())
+ return result
+
+ @app.delete("/api/groups/{group_id}/roots/{root_name}")
+ async def remove_root(group_id: str, root_name: str):
+ result = await _op(lambda: ops.remove_root(state, group_id, root_name))
+ reload_fn = state.get("reload_fn")
+ if reload_fn:
+ asyncio.ensure_future(reload_fn())
+ return result
+
+ # ── Upload toggle (operator only, localhost) ─────────────────────────
+
+ @app.put("/api/groups/{group_id}/member-upload")
+ async def set_member_upload(group_id: str, payload: dict):
+ return await _op(lambda: ops.set_member_upload(
+ state, group_id, bool(payload.get("allowed", False)),
+ ))
+
+ # ── Reload config ────────────────────────────────────────────────────
+
+ @app.post("/api/reload")
+ async def reload_config():
+ return await _op(lambda: ops.reload_config(state))
+
# ── Chat endpoints ───────────────────────────────────────────────────────
_chat_subscribers: list[WebSocket] = []