connor/drift
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Removed mpd re-sync

Browse Source
This commit is contained in:
Connor Johnstone
2026-03-03 00:05:08 -05:00
parent 09d562fabb
commit ba094a5dc5
1 changed files with 25 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/mpd.rs
View File

@@ -84,28 +84,43 @@ impl MpdClient {
}
pub fn queue_playlist(&mut self, tracks: &[String], music_dir: &str) {
if let Err(e) = self.update_and_wait() {
eprintln!("MPD update: {e}");
}
if let Err(e) = self.send_command("clear") {
eprintln!("MPD clear: {e}");
return;
}
let mut failed: Vec<String> = Vec::new();
for track in tracks {
let uri = track
.strip_prefix(music_dir)
.map(|p| p.trim_start_matches('/'))
.unwrap_or(track);
let uri = Self::track_to_uri(track, music_dir);
let escaped = uri.replace('\\', "\\\\").replace('"', "\\\"");
if self.send_command(&format!("add \"{escaped}\"")).is_err() {
failed.push(uri.to_string());
}
}
// If some tracks failed, update MPD's DB and retry them
if !failed.is_empty() {
eprintln!("MPD: {} tracks not found, updating database...", failed.len());
if self.update_and_wait().is_ok() {
for uri in &failed {
let escaped = uri.replace('\\', "\\\\").replace('"', "\\\"");
if let Err(e) = self.send_command(&format!("add \"{escaped}\"")) {
eprintln!("MPD add {uri}: {e}");
}
}
}
}
if let Err(e) = self.send_command("play") {
eprintln!("MPD play: {e}");
}
}
fn track_to_uri<'a>(track: &'a str, music_dir: &str) -> &'a str {
track
.strip_prefix(music_dir)
.map(|p| p.trim_start_matches('/'))
.unwrap_or(track)
}
}