From e76e27868b30a2b00b1ba42dd8e7ee6071e0c0d7 Mon Sep 17 00:00:00 2001
From: Christophe Besson <cbesson@gmail.com>
Date: Sun, 6 Sep 2026 16:05:39 +0200
Subject: feat: groups refactor Phase 1 — root RO/RW model + shared directories
 UI
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Replace the upload boolean with per-root writable/removable/ejected flags.
Backend: new ops (update_root, eject_root, plug_root), MNP 1.1 protocol
messages, live RootSet updates so API always reflects current state, CLI
root subcommand (add/remove/set/list/eject/plug).
Frontend: SharedDirectoriesTable with optimistic toggle switches, eject/plug
in Files and Settings, upload gated on root.writable, ejected-root filtering
in all media apps, updated Create Group wizard, 10-locale i18n.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 .../src/meshbay_node/indexer/indexer.py            | 38 ++++++++++++++++++++++
 1 file changed, 38 insertions(+)

(limited to 'packages/meshbay-node/src/meshbay_node/indexer')

diff --git a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
index b0a8e50..2911278 100644
--- a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
+++ b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
@@ -723,6 +723,44 @@ class DirectoryIndexer:
             self._observer = None
         self._start_observer()
 
+    def eject_root(self, root_name: str) -> None:
+        """Stop watching a root without touching its entries."""
+        from meshbay_common.paths import fold
+        target = fold(root_name)
+        for root in self.roots:
+            if fold(root.name) == target:
+                root.ejected = True
+                root.available = False
+                frozen = len(self._entries_under(root))
+                log.info("Root %r ejected — %d entries frozen", root.name, frozen)
+                break
+        self._restart_observer()
+        self._index.roots = self.roots.describe()
+        self._index.version = int(time.time())
+
+    async def plug_root(self, root_name: str) -> None:
+        """Restart watching a previously ejected root and reconcile."""
+        from meshbay_common.paths import fold
+        target = fold(root_name)
+        root = None
+        for r in self.roots:
+            if fold(r.name) == target:
+                root = r
+                break
+        if root is None:
+            return
+        root.ejected = False
+        root.available = root.is_live()
+        if root.available:
+            log.info("Root %r plugged — rescanning", root.name)
+            self._drop_root_entries(root)
+            await self._scan_root(root)
+        self._restart_observer()
+        self._index.roots = self.roots.describe()
+        self._index.version = int(time.time())
+        if self.on_change:
+            await self.on_change(self)
+
     # ── Internal update ───────────────────────────────────────────────────────
 
     def _schedule_update(self, file_path: Path, deleted: bool = False) -> None:
-- 
cgit v1.2.3