Cargo.lock

@@ -4,7 +4,7 @@ version = 4
 
 [[package]]
 name = "PMOMusic"
-version = "0.3.27"
+version = "0.3.28"
 dependencies = [
  "axum 0.8.7",
  "console-subscriber",

PMOMusic/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "PMOMusic"
-version = "0.3.27"
+version = "0.3.28"
 edition = "2024"
 
 [dependencies]

pmocache/src/db.rs

@@ -18,7 +18,7 @@ use std::sync::{Mutex, MutexGuard};
 /// Incrémenter cette constante à chaque modification incompatible du schéma.
 /// Cela provoquera la suppression de la DB **et de tous les fichiers du cache**
 /// au prochain démarrage.
-pub const SCHEMA_VERSION: u32 = 1;
+pub const SCHEMA_VERSION: u32 = 2;
 use std::time::Instant;
 
 #[cfg(feature = "openapi")]

pmoqobuz/src/source.rs

@@ -767,7 +767,7 @@ impl QobuzSource {
         &self,
         qobuz_playlist_id: &str,
     ) -> Result<Vec<Item>> {
-        use tracing::{debug, info};
+        use tracing::{debug, info, warn};
 
         let pmo_playlist_id = format!("qobuz-playlist-{}", qobuz_playlist_id);
         let playlist_manager = pmoplaylist::PlaylistManager();
@@ -845,6 +845,18 @@ impl QobuzSource {
         }
 
         let lazy_pks = self.register_tracks_lazy(&tracks).await;
+        let all_registered = lazy_pks.len() == tracks.len();
+        if !all_registered {
+            warn!(
+                "Qobuz playlist {}: only {}/{} tracks registered, will not mark cache as complete",
+                qobuz_playlist_id, lazy_pks.len(), tracks.len()
+            );
+            // Invalider la source_version pour forcer un refresh au prochain accès
+            writer
+                .set_source_version(None)
+                .await
+                .map_err(|e| MusicSourceError::PlaylistError(e.to_string()))?;
+        }
         writer
             .push_lazy_batch(lazy_pks)
             .await

version.txt

@@ -1 +1 @@
-0.3.27
+0.3.28