Merge feat/unified-group-management: wizard, public groups, activity sidebar

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] = []