diff options
Diffstat (limited to 'packages/meshbay-node/tests/test_rename_reenrichment.py')
| -rw-r--r-- | packages/meshbay-node/tests/test_rename_reenrichment.py | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/packages/meshbay-node/tests/test_rename_reenrichment.py b/packages/meshbay-node/tests/test_rename_reenrichment.py index 87e0d1a..7a77368 100644 --- a/packages/meshbay-node/tests/test_rename_reenrichment.py +++ b/packages/meshbay-node/tests/test_rename_reenrichment.py @@ -22,6 +22,7 @@ from meshbay_common.crypto import generate_gek from meshbay_node.config import Config, HubConfig, NodeConfig, GroupConfig, KeystoreConfig from meshbay_node.daemon import NodeDaemon from meshbay_node.indexer import DirectoryIndexer +from meshbay_node.media_cache import MediaCache from conftest import one_root @@ -115,6 +116,61 @@ async def test_a_renamed_file_gets_re_enriched(tmp_path): "from ever being title-parsed") +async def test_a_rename_drops_the_stale_cached_tmdb_match(tmp_path): + """ + A rename re-derives the title, which can change the correct TMDB match + — but media_cache.file_tmdb is keyed by content hash, unchanged by a + rename, so without an explicit clear the old name's match sticks + forever. (An explicit "Fix match" correction is kept — covered by + test_media_cache.py's clear_file_tmdb tests.) + """ + group_id = "a" * 32 + shared = tmp_path / "shared" + shared.mkdir() + old_path = shared / "old.frontier.3.2001.mkv" + old_path.write_bytes(b"not a real video, just needs to be indexed as one") + + config = Config( + hub=HubConfig(url="http://localhost:9999", username="testuser"), + node=NodeConfig(quic_port=_free_port(), ui_port=_free_port()), + groups=[GroupConfig( + id=group_id, name="test-group", shared_dir=str(shared), + visibility="private", quic_port=29018, + )], + keystore=KeystoreConfig(path=tmp_path / "keystore.enc"), + data_dir=tmp_path / "data", + ) + daemon = NodeDaemon(config) + daemon._broadcast_coalesce_secs = 0.01 + daemon._enricher = _SpyEnricher() + daemon._roster = _StubRoster() + media_cache = MediaCache(db_path=tmp_path / "media_cache.db") + await media_cache.open() + daemon._media_cache = media_cache + + indexer = DirectoryIndexer( + roots=one_root(shared), group_id=group_id, + sk_node=Ed25519PrivateKey.generate(), gek=generate_gek(), + on_change=daemon._on_index_change) + await indexer.initial_scan() + await daemon._on_index_change(indexer) + await asyncio.sleep(0.05) + + file_id = next(iter(indexer.index.entries)).id + await media_cache.set_file_tmdb(file_id, "201", "movie") # the wrong match + + old_path.rename(shared / "old.frontier.iii.2001.mkv") + assert await indexer.reconcile() + for _ in range(30): + if await media_cache.get_file_tmdb(file_id) is None: + break + await asyncio.sleep(0.02) + + assert await media_cache.get_file_tmdb(file_id) is None, ( + "a rename must drop the auto-resolved match so it re-resolves") + await media_cache.close() + + async def test_an_unrelated_update_does_not_re_trigger_enrichment(tmp_path): """ The other half of the same fix: an update whose name/path did *not* |