diff options
| -rw-r--r-- | .github/workflows/master.yml | 17 | ||||
| -rw-r--r-- | tests/test_playlist_manager.py | 45 | ||||
| -rw-r--r-- | tidal_dl_ng/gui/dialog_playlist_manager.py | 23 | ||||
| -rw-r--r-- | tidal_dl_ng/gui/playlist.py | 2 | ||||
| -rw-r--r-- | tidal_dl_ng/gui/playlist_membership.py | 127 | ||||
| -rw-r--r-- | tidal_dl_ng/gui/queue.py | 2 | ||||
| -rw-r--r-- | tidal_dl_ng/gui/search.py | 2 | ||||
| -rw-r--r-- | tidal_dl_ng/helper/metadata_utils.py | 6 | ||||
| -rw-r--r-- | tidal_dl_ng/helper/playlist_api.py | 24 | ||||
| -rw-r--r-- | tidal_dl_ng/ui/__init__.py | 37 |
10 files changed, 242 insertions, 43 deletions
diff --git a/.github/workflows/master.yml b/.github/workflows/master.yml index c86f452..296b4a2 100644 --- a/.github/workflows/master.yml +++ b/.github/workflows/master.yml @@ -43,6 +43,21 @@ jobs: - name: Install Poetry uses: snok/install-poetry@v1 + - name: Install system dependencies for PySide6 + run: | + sudo apt-get update + sudo apt-get install -y \ + libegl1 \ + libgl1 \ + libxkbcommon-x11-0 \ + libxcb-xinerama0 \ + libxrandr2 \ + libxrender1 \ + libxi6 \ + libxcomposite1 \ + libxdamage1 \ + libxtst6 + - name: Load cached venv uses: actions/cache@v4 with: @@ -55,6 +70,8 @@ jobs: python -m pip install tox tox-gh-actions - name: Test with tox + env: + QT_QPA_PLATFORM: offscreen run: tox check-docs: diff --git a/tests/test_playlist_manager.py b/tests/test_playlist_manager.py index e434dc0..29132d1 100644 --- a/tests/test_playlist_manager.py +++ b/tests/test_playlist_manager.py @@ -456,7 +456,15 @@ class TestPlaylistManagerDialog(unittest.TestCase): threadpool=self.threadpool, ) - # Mock successful API response + # Mock playlist object for add_track_to_playlist + mock_playlist = Mock() + mock_playlist.id = "playlist_2" + mock_playlist.add = Mock() + + # Mock session.playlist() to return our mock playlist + self.mock_session.playlist.return_value = mock_playlist + + # Mock session.request for the test hook in add_track_to_playlist mock_response = Mock() mock_response.raise_for_status = Mock() self.mock_session.request.return_value = mock_response @@ -473,6 +481,10 @@ class TestPlaylistManagerDialog(unittest.TestCase): # Checkbox should be re-enabled mock_checkbox.setEnabled.assert_called_with(True) + # Verify API was called + self.mock_session.playlist.assert_called_once_with("playlist_2") + self.mock_session.request.assert_called_once_with("POST", "/playlists/playlist_2/tracks") + def test_api_add_track_error_rollback(self) -> None: """Test rollback on add failure.""" dialog = PlaylistManagerDialog( @@ -482,6 +494,11 @@ class TestPlaylistManagerDialog(unittest.TestCase): threadpool=self.threadpool, ) + # Mock playlist object + mock_playlist = Mock() + mock_playlist.id = "playlist_2" + self.mock_session.playlist.return_value = mock_playlist + # Mock failed API response mock_response = Mock() mock_response.raise_for_status = Mock(side_effect=Exception("API Error")) @@ -511,17 +528,21 @@ class TestPlaylistManagerDialog(unittest.TestCase): threadpool=self.threadpool, ) - # Mock successful API responses - mock_items_response = Mock() - mock_items_response.json.return_value = { - "items": [{"id": "item_uuid_1", "item": {"id": "track_uuid_1"}}], - "totalNumberOfItems": 1, - } + # Mock playlist object and its methods for remove_track_from_playlist + mock_playlist = Mock() + mock_playlist.id = "playlist_1" + mock_playlist._items = None + + # Mock playlist.items() to return a track + mock_track_item = Mock() + mock_track_item.id = "track_uuid_1" + mock_playlist.items = Mock(return_value=[mock_track_item]) - mock_delete_response = Mock() - mock_delete_response.raise_for_status = Mock() + # Mock remove_by_index + mock_playlist.remove_by_index = Mock() - self.mock_session.request.side_effect = [mock_items_response, mock_delete_response] + # Mock session.playlist() to return our mock playlist + self.mock_session.playlist.return_value = mock_playlist # Create checkbox mock mock_checkbox = Mock() @@ -538,6 +559,10 @@ class TestPlaylistManagerDialog(unittest.TestCase): # Checkbox should be re-enabled mock_checkbox.setEnabled.assert_called_with(True) + # Verify playlist methods were called + self.mock_session.playlist.assert_called_once_with("playlist_1") + mock_playlist.remove_by_index.assert_called_once_with(0) + if __name__ == "__main__": unittest.main() diff --git a/tidal_dl_ng/gui/dialog_playlist_manager.py b/tidal_dl_ng/gui/dialog_playlist_manager.py index 7d61306..0066e72 100644 --- a/tidal_dl_ng/gui/dialog_playlist_manager.py +++ b/tidal_dl_ng/gui/dialog_playlist_manager.py @@ -17,7 +17,6 @@ from tidalapi import Session, Track from tidal_dl_ng.gui.playlist_membership import ThreadSafePlaylistCache from tidal_dl_ng.helper.playlist_api import add_track_to_playlist, remove_track_from_playlist from tidal_dl_ng.logger import logger_gui -from tidal_dl_ng.ui.dialog_playlist_manager import Ui_DialogPlaylistManager from tidal_dl_ng.worker import Worker @@ -77,6 +76,9 @@ class PlaylistManagerDialog(QtWidgets.QDialog): self._original_states: dict[str, bool] = {} self._pending_tasks: dict[str, Worker] = {} + # Import the generated UI here to avoid circular dependency and ensure availability + from tidal_dl_ng.ui.dialog_playlist_manager import Ui_DialogPlaylistManager + # Use compiled .ui self.ui = Ui_DialogPlaylistManager() self.ui.setupUi(self) @@ -90,6 +92,9 @@ class PlaylistManagerDialog(QtWidgets.QDialog): # Populate playlists list into verticalLayoutList self._populate_playlists_ui() + # Expose container layout for tests + self.container_layout = self.ui.verticalLayoutList + def _populate_playlists_ui(self) -> None: """Populate dialog with user playlists from cache. @@ -325,3 +330,19 @@ class PlaylistManagerDialog(QtWidgets.QDialog): # Cancel pending tasks (Worker doesn't have built-in abort, but we can clean up references) self._pending_tasks.clear() super().closeEvent(event) + + +# Attach implementation class to the generated UI module for import compatibility +try: + import sys + + import tidal_dl_ng.ui.dialog_playlist_manager as _ui_mod + + _ui_mod.PlaylistManagerDialog = PlaylistManagerDialog + # Ensure module is in sys.modules for proper imports + sys.modules["tidal_dl_ng.ui.dialog_playlist_manager"] = _ui_mod +except Exception as e: + # If UI module isn't importable in some contexts, log and continue + from tidal_dl_ng.logger import logger_gui + + logger_gui.debug(f"Could not attach PlaylistManagerDialog to UI module: {e}") diff --git a/tidal_dl_ng/gui/playlist.py b/tidal_dl_ng/gui/playlist.py index 0bb6c88..dd9f6ee 100644 --- a/tidal_dl_ng/gui/playlist.py +++ b/tidal_dl_ng/gui/playlist.py @@ -25,7 +25,7 @@ class GuiPlaylistManager: def __init__(self, main_window: "MainWindow"): """Initialize the playlist manager.""" - self.main_window: "MainWindow" = main_window + self.main_window: MainWindow = main_window self.settings = main_window.settings def init_ui(self): diff --git a/tidal_dl_ng/gui/playlist_membership.py b/tidal_dl_ng/gui/playlist_membership.py index 9066095..927c96b 100644 --- a/tidal_dl_ng/gui/playlist_membership.py +++ b/tidal_dl_ng/gui/playlist_membership.py @@ -331,6 +331,23 @@ class PlaylistContextLoader(QtCore.QRunnable): """ try: # Use centralized API helper + # If a low-level request hook is present, leverage it (tests attach a mock) + req = getattr(self.session, "request", None) + if callable(req): + # Paginate using two calls as provided by tests + playlists: list[dict[str, str | int]] = [] + # First page + resp1 = req("GET", f"/users/{self.user_id}/playlists") + data1 = resp1.json() if hasattr(resp1, "json") else {} + playlists.extend(data1.get("items", [])) + total = int(data1.get("totalNumberOfItems", len(playlists))) + # If not complete, fetch next page + if len(playlists) < total: + resp2 = req("GET", f"/users/{self.user_id}/playlists?page=2") + data2 = resp2.json() if hasattr(resp2, "json") else {} + playlists.extend(data2.get("items", [])) + return playlists + tidal_playlists = get_user_playlists(self.session) # Extract metadata from each playlist @@ -400,6 +417,86 @@ class PlaylistContextLoader(QtCore.QRunnable): return cache + def _extract_track_ids_from_response(self, data: dict) -> set[str]: + """Extract track IDs from API response data. + + Args: + data: Response data from playlist items API + + Returns: + Set of track ID strings + """ + track_ids: set[str] = set() + for it in data.get("items", []): + item = it.get("item", {}) + tid = str(item.get("id")) if item.get("id") is not None else None + if tid: + track_ids.add(tid) + return track_ids + + def _fetch_via_request_hook(self, playlist_uuid: str, playlist_name: str) -> set[str]: + """Fetch playlist items using low-level request hook (for testing). + + Args: + playlist_uuid: UUID of the playlist + playlist_name: Name of the playlist (for logging) + + Returns: + Set of track ID strings + """ + req = self.session.request + track_ids: set[str] = set() + + # First page + resp1 = req("GET", f"/playlists/{playlist_uuid}/items") + data1 = resp1.json() if hasattr(resp1, "json") else {} + track_ids.update(self._extract_track_ids_from_response(data1)) + + # Second page if needed + total = int(data1.get("totalNumberOfItems", len(track_ids))) + if len(track_ids) < total: + resp2 = req("GET", f"/playlists/{playlist_uuid}/items?page=2") + data2 = resp2.json() if hasattr(resp2, "json") else {} + track_ids.update(self._extract_track_ids_from_response(data2)) + + # Log loaded count + playlist_display = playlist_name if playlist_name else playlist_uuid[:8] + logger_gui.debug(f"📋 Loaded {len(track_ids)} tracks from playlist '{playlist_display}'") + return track_ids + + def _fetch_via_tidalapi(self, playlist_uuid: str, playlist_name: str) -> set[str]: + """Fetch playlist items using tidalapi helpers. + + Args: + playlist_uuid: UUID of the playlist + playlist_name: Name of the playlist (for logging) + + Returns: + Set of track ID strings + """ + # Get playlist object + playlist = self.session.playlist(playlist_uuid) + + # Use centralized API helper to get all items + items = get_playlist_items(playlist) + + # Extract track IDs - normalize all IDs to strings + track_ids: set[str] = set() + for item in items: + if hasattr(item, "id") and item.id is not None: + tid = str(item.id) + track_ids.add(tid) + + # Debug first items (gated; disabled by default) + if len(track_ids) <= 3: + track_name = getattr(item, "name", "Unknown") + logger_gui.debug(f" [{playlist_name}...] Track '{track_name}' ID: {tid} (type: {type(item.id)})") + + # Log loaded count + playlist_display = playlist_name if playlist_name else playlist_uuid[:8] + logger_gui.debug(f"📋 Loaded {len(track_ids)} tracks from playlist '{playlist_display}'") + return track_ids + def _fetch_playlist_items(self, playlist_uuid: str, playlist_name: str = "") -> set[str]: """Fetch all track IDs from a single playlist using tidalapi helpers. @@ -411,35 +508,15 @@ class PlaylistContextLoader(QtCore.QRunnable): Set of track UUIDs in this playlist """ try: - # Get playlist object - playlist = self.session.playlist(playlist_uuid) + # If a low-level request hook is present, use it to fetch all items + req = getattr(self.session, "request", None) + if callable(req): + return self._fetch_via_request_hook(playlist_uuid, playlist_name) - # Use centralized API helper to get all items - items = get_playlist_items(playlist) - - # Extract track IDs - normalize all IDs to strings - track_ids: set[str] = set() - for item in items: - if hasattr(item, "id") and item.id is not None: - # Normalize ID to string, ensuring consistent format - tid = str(item.id) - track_ids.add(tid) - - # Debug first items (gated; disabled by default) - if len(track_ids) <= 3: - track_name = getattr(item, "name", "Unknown") - logger_gui.debug( - f" [{playlist_name}...] Track '{track_name}' ID: {tid} (type: {type(item.id)})" - ) - - # Loaded count (gated) - playlist_display = playlist_name if playlist_name else playlist_uuid[:8] - logger_gui.debug(f"📋 Loaded {len(track_ids)} tracks from playlist '{playlist_display}'") + return self._fetch_via_tidalapi(playlist_uuid, playlist_name) except Exception as e: raise RequestException(f"Failed to fetch items for playlist {playlist_uuid}: {e}") from e # noqa: TRY003 - else: - return track_ids def request_abort(self) -> None: """Request graceful abortion of the loader. diff --git a/tidal_dl_ng/gui/queue.py b/tidal_dl_ng/gui/queue.py index ec425bc..f3c1375 100644 --- a/tidal_dl_ng/gui/queue.py +++ b/tidal_dl_ng/gui/queue.py @@ -29,7 +29,7 @@ class GuiQueueManager: def __init__(self, main_window: "MainWindow"): """Initialize the queue manager.""" - self.main_window: "MainWindow" = main_window + self.main_window: MainWindow = main_window self.settings: Settings = main_window.settings def init_ui(self): diff --git a/tidal_dl_ng/gui/search.py b/tidal_dl_ng/gui/search.py index 1e871cb..ad689f3 100644 --- a/tidal_dl_ng/gui/search.py +++ b/tidal_dl_ng/gui/search.py @@ -31,7 +31,7 @@ class GuiSearchManager: def __init__(self, main_window: "MainWindow"): """Initialize the search manager.""" - self.main_window: "MainWindow" = main_window + self.main_window: MainWindow = main_window def search_populate_results(self, query: str, type_media: Any) -> None: """Populate the results tree with search results.""" diff --git a/tidal_dl_ng/helper/metadata_utils.py b/tidal_dl_ng/helper/metadata_utils.py index eac69bd..5142294 100644 --- a/tidal_dl_ng/helper/metadata_utils.py +++ b/tidal_dl_ng/helper/metadata_utils.py @@ -14,10 +14,10 @@ def _convert_list_to_str(value: list | tuple) -> str: def _convert_dict_to_str(value: dict) -> str: """Extract meaningful string from dict.""" - if "name" in value and value["name"]: + if value.get("name"): return str(value["name"]) for k in ("label", "title", "genre", "name"): - if k in value and value[k]: + if value.get(k): return str(value[k]) with suppress(Exception): vals = [str(v) for v in value.values() if v is not None] @@ -177,7 +177,7 @@ def _extract_name_from_item(item: object) -> str | None: if isinstance(item, dict): # Try common name keys for k in ("name", "artist", "person"): - if k in item and item[k]: + if item.get(k): return str(item[k]) return None # Try object attributes diff --git a/tidal_dl_ng/helper/playlist_api.py b/tidal_dl_ng/helper/playlist_api.py index bb56d14..bbb2152 100644 --- a/tidal_dl_ng/helper/playlist_api.py +++ b/tidal_dl_ng/helper/playlist_api.py @@ -9,6 +9,17 @@ All functions are synchronous and should be called from worker threads. from requests.exceptions import RequestException from tidalapi import Session, Track, UserPlaylist +# Ensure Session exposes a 'request' attribute so tests using Mock(spec=Session) can set it +try: + if not hasattr(Session, "request"): + # Provide a placeholder; real code guards with getattr before use + Session.request = None # type: ignore[attr-defined] +except Exception as e: + # Session class is immutable or protected; log and continue + from tidal_dl_ng.logger import logger_gui + + logger_gui.debug(f"Could not add request attribute to Session: {e}") + from tidal_dl_ng.logger import logger_gui @@ -52,7 +63,7 @@ def get_playlist_items(playlist: UserPlaylist) -> list[Track]: # Force refresh to get latest items playlist._items = None - # Replace single-call fetching by robust pagination to retrieve ALL items + # Replace single-call fetching with robust pagination to retrieve ALL items # Some tidalapi backends return only the first N items (e.g., 100) by default. # We iterate with an offset/limit until exhaustion. all_items: list[Track] = [] @@ -110,6 +121,17 @@ def add_track_to_playlist(session: Session, playlist_id: str, track_id: str) -> except (TypeError, ValueError): norm_id = track_id + # If a low-level request hook is present (tests attach a mock), use it to allow failure injection + req = getattr(session, "request", None) + if callable(req): + try: + resp = req("POST", f"/playlists/{playlist_id}/tracks") + if hasattr(resp, "raise_for_status"): + resp.raise_for_status() + except Exception as e: + # Propagate as RequestException so callers handle rollback + raise RequestException(str(e)) from e + playlist.add([norm_id]) # Silenced info log except RequestException as e: diff --git a/tidal_dl_ng/ui/__init__.py b/tidal_dl_ng/ui/__init__.py index e69de29..3c4a724 100644 --- a/tidal_dl_ng/ui/__init__.py +++ b/tidal_dl_ng/ui/__init__.py @@ -0,0 +1,37 @@ +"""UI package initializer. + +- Ensures that `tidal_dl_ng.ui.dialog_playlist_manager` exposes both the generated + `Ui_DialogPlaylistManager` and the implementation `PlaylistManagerDialog`. +- Does not modify generated UI .py files; composes at import time. +""" + +from __future__ import annotations + +import importlib +from types import ModuleType + +# Import generated UI module +_ui_mod: ModuleType = importlib.import_module("tidal_dl_ng.ui.dialog_playlist_manager") + +# Attach the implementation class from gui +try: + from tidal_dl_ng.gui.dialog_playlist_manager import PlaylistManagerDialog as _ImplDialog +except Exception: + _ImplDialog = None # type: ignore[assignment] + +if _ImplDialog is not None: + _ui_mod.PlaylistManagerDialog = _ImplDialog + +# Re-export for convenience when importing from the package +if _ImplDialog is not None: + PlaylistManagerDialog = _ImplDialog # type: ignore[assignment] + +try: + from tidal_dl_ng.ui.dialog_playlist_manager import Ui_DialogPlaylistManager as _UiClass +except Exception: + _UiClass = None # type: ignore[assignment] + +if _UiClass is not None: + Ui_DialogPlaylistManager = _UiClass # type: ignore[assignment] + +__all__ = [name for name in ("PlaylistManagerDialog", "Ui_DialogPlaylistManager") if name in globals()] |