diff options
Diffstat (limited to 'packages/meshbay-node/tests/test_audio_root_gates_enrichment.py')
| -rw-r--r-- | packages/meshbay-node/tests/test_audio_root_gates_enrichment.py | 156 |
1 files changed, 156 insertions, 0 deletions
diff --git a/packages/meshbay-node/tests/test_audio_root_gates_enrichment.py b/packages/meshbay-node/tests/test_audio_root_gates_enrichment.py new file mode 100644 index 0000000..f088f5e --- /dev/null +++ b/packages/meshbay-node/tests/test_audio_root_gates_enrichment.py @@ -0,0 +1,156 @@ +""" +Music-app enrichment (tag/cover extraction, docs/musicbay.md §2.1/§6) only +ever runs for a group that has an audio_root configured, and only for files +under it — see daemon.py's _enrich_new_audio_entries. Same reasoning as +Videos' video_root gate (test_video_root_gates_enrichment.py), added later: +musicbay.md's original "no root, whole shared tree" call turned out wrong +against a real messy library, where everything under every shared folder +got mixed together with no way to scope Music down to just the actual +music library. + +Setting or changing the root (ops.set_audio_root) fires a one-off sweep +(_enrich_audio_root_now) of whatever it already contains — same shape as +_enrich_video_root_now. +""" + +import asyncio +import os + +import pytest +from cryptography.hazmat.primitives.asymmetric.ed25519 import Ed25519PrivateKey + +from meshbay_common.crypto import generate_gek +from meshbay_node import ops +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.indexer.enrich_audio import AudioEnricher +from meshbay_node.media_cache import MediaCache +from meshbay_node.roster import Roster + +from conftest import one_root + +pytestmark = pytest.mark.asyncio + +# Above indexer.py's MIN_AUDIO_SIZE_BYTES gate — otherwise these fixture +# files would never even be indexed at all, regardless of audio_root. +_AUDIO_BYTES = os.urandom(60 * 1024) + + +def _free_port() -> int: + import socket + with socket.socket() as s: + s.bind(("127.0.0.1", 0)) + return s.getsockname()[1] + + +async def _make_daemon(tmp_path, shared, group_id): + 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=29015, + )], + keystore=KeystoreConfig(path=tmp_path / "keystore.enc"), + data_dir=tmp_path / "data", + ) + daemon = NodeDaemon(config) + daemon._broadcast_coalesce_secs = 0.01 + daemon._media_cache = MediaCache(db_path=tmp_path / "media_cache.db") + await daemon._media_cache.open() + daemon._audio_enricher = AudioEnricher(daemon._media_cache) + daemon._roster = Roster(db_path=tmp_path / "roster.db") + await daemon._roster.open() + return daemon + + +async def _teardown(daemon): + await daemon._media_cache.close() + await daemon._roster.close() + + +async def test_no_audio_root_means_no_enrichment_at_all(tmp_path): + group_id = "a" * 32 + shared = tmp_path / "shared" + shared.mkdir() + (shared / "track.mp3").write_bytes(_AUDIO_BYTES) + + daemon = await _make_daemon(tmp_path, shared, group_id) + try: + indexer = DirectoryIndexer( + roots=one_root(shared), group_id=group_id, + sk_node=Ed25519PrivateKey.generate(), gek=generate_gek()) + await indexer.initial_scan() + await daemon._on_index_change(indexer) + await asyncio.sleep(0.05) + + assert not daemon._enriched_attempted, ( + "a group with no audio_root configured must not enrich anything, " + "not even fall back to the whole index") + finally: + await _teardown(daemon) + + +async def test_only_entries_under_the_configured_root_are_enriched(tmp_path): + group_id = "a" * 32 + shared = tmp_path / "shared" + shared.mkdir() + (shared / "Music").mkdir() + (shared / "Music" / "in-root.mp3").write_bytes(_AUDIO_BYTES) + (shared / "outside.mp3").write_bytes(os.urandom(60 * 1024)) + + daemon = await _make_daemon(tmp_path, shared, group_id) + try: + await daemon._roster.set_audio_root(group_id, "shared/Music", set_by="op") + indexer = DirectoryIndexer( + roots=one_root(shared), group_id=group_id, + sk_node=Ed25519PrivateKey.generate(), gek=generate_gek()) + await indexer.initial_scan() + await daemon._on_index_change(indexer) + await asyncio.sleep(0.05) + + by_name = {e.name: e for e in indexer.index.entries} + assert by_name["in-root.mp3"].id in daemon._enriched_attempted + assert by_name["outside.mp3"].id not in daemon._enriched_attempted, ( + "a file outside the configured audio_root must never be enriched") + finally: + await _teardown(daemon) + + +async def test_setting_the_audio_root_sweeps_what_it_already_contains(tmp_path): + group_id = "a" * 32 + shared = tmp_path / "shared" + shared.mkdir() + (shared / "Music").mkdir() + (shared / "Music" / "already-there.mp3").write_bytes(_AUDIO_BYTES) + + daemon = await _make_daemon(tmp_path, shared, group_id) + try: + indexer = DirectoryIndexer( + roots=one_root(shared), group_id=group_id, + sk_node=Ed25519PrivateKey.generate(), gek=generate_gek()) + await indexer.initial_scan() + daemon._state["indexers"][group_id] = indexer + + # Broadcast once with nothing configured — nothing should be scheduled. + await daemon._on_index_change(indexer) + await asyncio.sleep(0.05) + assert not daemon._enriched_attempted + + # Now the operator points audio_root at the folder that already held + # this file all along. + state = { + "roster": daemon._roster, + "groups_ctx": {group_id: {}}, + "enrich_audio_root_fn": daemon._enrich_audio_root_now, + } + await ops.set_audio_root(state, group_id, "shared/Music") + await asyncio.sleep(0.05) # let the fire-and-forget sweep actually run + + entry = next(iter(indexer.index.entries)) + assert entry.id in daemon._enriched_attempted, ( + "a file already sitting in the newly-chosen root must be picked " + "up by the sweep, not wait for some unrelated future change") + finally: + await _teardown(daemon) |