mirror of https://github.com/Nezreka/SoulSync.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
58 lines
2.7 KiB
58 lines
2.7 KiB
"""The REAL playlist sync matcher (PlaylistSyncService._find_track_in_media_server)
|
|
must honor a durable Find & Add / manual match when the volatile sync_match_cache
|
|
has been wiped by a library rescan — otherwise the manual pick is re-matched from
|
|
scratch on the next auto-sync (#895 follow-up). Jellyfin server-type avoids Plex
|
|
fetchItem mocking; the durable block is server-agnostic."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import asyncio
|
|
from types import SimpleNamespace
|
|
from unittest.mock import MagicMock, patch
|
|
|
|
from services.sync_service import PlaylistSyncService
|
|
|
|
|
|
def _service():
|
|
svc = PlaylistSyncService(spotify_client=MagicMock(), download_orchestrator=MagicMock(),
|
|
media_server_engine=MagicMock())
|
|
client = MagicMock(); client.is_connected.return_value = True
|
|
svc._get_active_media_client = lambda: (client, "jellyfin")
|
|
svc._cancelled = False
|
|
return svc
|
|
|
|
|
|
def _run(svc, db):
|
|
cm = MagicMock(); cm.get_active_media_server.return_value = "jellyfin"
|
|
track = SimpleNamespace(name="Valió la Pena - Salsa Version", artists=["Marc Anthony"], id="sp16")
|
|
with patch("database.music_database.MusicDatabase", return_value=db), \
|
|
patch("config.settings.config_manager", cm), \
|
|
patch("core.artists.map.get_current_profile_id", return_value=1):
|
|
return asyncio.run(svc._find_track_in_media_server(track, candidate_pool={}))
|
|
|
|
|
|
def test_durable_match_used_when_volatile_cache_wiped():
|
|
dt = SimpleNamespace(id="t99", title="Valió la Pena (Salsa Version)")
|
|
db = MagicMock()
|
|
db.read_sync_match_cache.return_value = None # rescan wiped the cache
|
|
db.check_track_exists.return_value = (None, 0.0) # fuzzy would FAIL
|
|
db.find_manual_library_match_by_source_track_id.return_value = {
|
|
"library_track_id": "t99", "library_file_path": "/m/x.flac"}
|
|
db.get_track_by_id.side_effect = lambda i: dt if str(i) == "t99" else None
|
|
match, conf = _run(svc=_service(), db=db)
|
|
assert conf == 1.0 and match.id == "t99" # manual pick honored across the rescan
|
|
|
|
|
|
def test_durable_match_self_heals_stale_library_id():
|
|
dt = SimpleNamespace(id="newid", title="X")
|
|
db = MagicMock()
|
|
db.read_sync_match_cache.return_value = None
|
|
db.check_track_exists.return_value = (None, 0.0)
|
|
db.find_manual_library_match_by_source_track_id.return_value = {
|
|
"library_track_id": "staleid", "library_file_path": "/m/x.flac"}
|
|
db.get_track_by_id.side_effect = lambda i: dt if str(i) == "newid" else None # stale id gone
|
|
db.find_track_id_by_file_path.return_value = "newid"
|
|
match, conf = _run(svc=_service(), db=db)
|
|
assert conf == 1.0 and match.id == "newid"
|
|
db.find_track_id_by_file_path.assert_called_once_with("/m/x.flac")
|