Merge pull request 'Bump version to 0.3.28 and update schema' (#82) from push-xnlsqxppxsrz into main
All checks were successful
Build and Push Docker Image / build (push) Successful in 9m17s

Reviewed-on: #82
This commit was merged in pull request #82.
This commit is contained in:
2026-03-25 15:12:44 +01:00
5 changed files with 17 additions and 5 deletions

2
Cargo.lock generated
View File

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

View File

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

View File

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

View File

@@ -767,7 +767,7 @@ impl QobuzSource {
&self, &self,
qobuz_playlist_id: &str, qobuz_playlist_id: &str,
) -> Result<Vec<Item>> { ) -> Result<Vec<Item>> {
use tracing::{debug, info}; use tracing::{debug, info, warn};
let pmo_playlist_id = format!("qobuz-playlist-{}", qobuz_playlist_id); let pmo_playlist_id = format!("qobuz-playlist-{}", qobuz_playlist_id);
let playlist_manager = pmoplaylist::PlaylistManager(); let playlist_manager = pmoplaylist::PlaylistManager();
@@ -845,6 +845,18 @@ impl QobuzSource {
} }
let lazy_pks = self.register_tracks_lazy(&tracks).await; 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 writer
.push_lazy_batch(lazy_pks) .push_lazy_batch(lazy_pks)
.await .await

View File

@@ -1 +1 @@
0.3.27 0.3.28