1 files changed, 25 insertions, 0 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
index f7ffdca..eea5b4f 100644
--- a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
+++ b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
@@ -314,6 +314,14 @@ class DirectoryIndexer:
         # stay up for exactly as long as the slow part (hashing) is running.
         self._burst_inflight = 0
         self._burst_sizes: dict[str, int] = {}
+        # Ids whose entry this indexer threw away and rebuilt from disk, since
+        # the last time a consumer drained this. A rebuilt entry carries only
+        # what `_hash_or_cached` fills in — every enrichment field the Videos,
+        # Music and Photos apps put there is gone — but its id is the file's
+        # content hash, so a diff against the last broadcast sees no addition
+        # and no deletion and nothing downstream can tell the fields were
+        # wiped. See `_drop_root_entries`.
+        self.rescanned_ids: set[str] = set()
 
     @property
     def index(self) -> GroupIndex:
@@ -704,9 +712,26 @@ class DirectoryIndexer:
                 if fold(e.path).split("/", 1)[0] == prefix]
 
     def _drop_root_entries(self, root: Root) -> None:
+        """
+        Throw away a root's entries, always in order to rescan it.
+
+        Both callers — `reconcile` when a root reappears, `plug_root` when the
+        operator plugs one back in — rebuild immediately, so nothing outside
+        ever observes the gap: no deletion is broadcast, and the entries that
+        come back have the same content-hash ids they had before. What they do
+        not have is anything enrichment put on them, which is why the ids are
+        recorded for `daemon._broadcast_index_change` to re-enrich rather than
+        simply forgotten.
+        """
         for entry in self._entries_under(root):
+            self.rescanned_ids.add(entry.id)
             self._index.remove_entry(entry.id)
 
+    def drain_rescanned_ids(self) -> set[str]:
+        """Take the ids rebuilt since the last call; leave the set empty."""
+        drained, self.rescanned_ids = self.rescanned_ids, set()
+        return drained
+
     @staticmethod
     def _entry_path(root: Root, entry: IndexEntry) -> Path | None:
         _, _, tail = entry.path.partition("/")