summaryrefslogtreecommitdiffstats
path: root/packages/meshbay-node
diff options
context:
space:
mode:
Diffstat (limited to 'packages/meshbay-node')
-rw-r--r--packages/meshbay-node/src/meshbay_node/indexer/indexer.py12
1 files changed, 9 insertions, 3 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
index 8376c23..b0a8e50 100644
--- a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
+++ b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py
@@ -805,9 +805,15 @@ class DirectoryIndexer:
if not deleted:
entry = await self._hash_or_cached(root, file_path)
if entry:
- self._index.add_entry(entry)
- log.debug("Indexed: %s (%s, %d bytes)",
- file_path.name, entry.id[:8], entry.size)
+ existing = self._index.get_entry(entry.id)
+ if existing is not None:
+ log.debug("Watchdog: %s duplicates content already "
+ "indexed as %s/%s — leaving the index alone",
+ file_path.name, existing.path, existing.name)
+ else:
+ self._index.add_entry(entry)
+ log.debug("Indexed: %s (%s, %d bytes)",
+ file_path.name, entry.id[:8], entry.size)
self._index.version = int(time.time())
if self.on_change: