From 217b61ff34390fd24d0a2ad338f6094183debbe3 Mon Sep 17 00:00:00 2001 From: Christophe Besson Date: Sun, 9 Aug 2026 22:56:18 +0200 Subject: fix: 4 corrections — streaming hash, watchdog bug, cipher doc, deps MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. indexer.py: streaming blake3 (8MB chunks) instead of read_bytes(). Large files (initrd.img, ISOs, VM images) no longer load into RAM. 2. QE/demo-v1/run_node.py: call indexer.start() not initial_scan(). initial_scan() alone never starts the watchdog observer — files added after startup were silently ignored. Added indexer.stop() on shutdown. 3. USERGUIDE.md §8: clarify symmetric vs asymmetric. Ed25519/X25519 = asymmetric (key pairs). ChaCha20-Poly1305 and AES-256-GCM = symmetric AEAD 256-bit (content encryption). ChaCha20 is PRIMARY; AES-GCM is optional browser-compat variant only. 4. pyproject.toml: aioquic, websockets, aiosqlite, slowapi added to proper package deps (were installed manually, now declared). Co-Authored-By: Claude Sonnet 4.6 (1M context) --- packages/meshbay-node/src/meshbay_node/indexer/indexer.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) (limited to 'packages/meshbay-node/src') diff --git a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py index 5cd7205..4bb1527 100644 --- a/packages/meshbay-node/src/meshbay_node/indexer/indexer.py +++ b/packages/meshbay-node/src/meshbay_node/indexer/indexer.py @@ -56,14 +56,22 @@ def _is_indexable(path: Path) -> bool: ) +_HASH_CHUNK = 8 * 1024 * 1024 # 8 MB streaming hash chunks + + def _scan_file(root: Path, file_path: Path) -> IndexEntry | None: - """Compute IndexEntry for a file. Blocking — run in executor.""" + """Compute IndexEntry for a file. Blocking — run in executor. + Uses streaming blake3 so arbitrarily large files (ISOs, VM images, etc.) + don't require loading the whole file into memory.""" if not _is_indexable(file_path): return None try: stat = file_path.stat() - data = file_path.read_bytes() - file_id = blake3.blake3(data).hexdigest() + hasher = blake3.blake3() + with open(file_path, "rb") as f: + while chunk := f.read(_HASH_CHUNK): + hasher.update(chunk) + file_id = hasher.hexdigest() rel_path = str(file_path.parent.relative_to(root)) if rel_path == ".": rel_path = "" -- cgit v1.2.3