cleanup

src/app.rs

@@ -233,13 +233,17 @@ impl App {
     }
 
     fn set_status(&mut self, text: String, level: Level) {
-        self.status = Some(Status { text, level, at: Instant::now() });
+        self.status = Some(Status {
+            text,
+            level,
+            at: Instant::now(),
+        });
     }
 
     pub fn visible_status(&self) -> Option<&Status> {
-        self.status.as_ref().filter(|s| {
+        self.status
-            s.at.elapsed().as_secs() < if s.level == Level::Error { 12 } else { 6 }
+            .as_ref()
-        })
+            .filter(|s| s.at.elapsed().as_secs() < if s.level == Level::Error { 12 } else { 6 })
     }
 
     pub fn on_tick(&mut self) {
@@ -266,11 +270,17 @@ impl App {
 
     pub fn in_playlist(&self) -> bool {
         self.view == View::Playlists
-            && self.open.as_ref().is_some_and(|n| self.store.playlists.contains_key(n))
+            && self
+                .open
+                .as_ref()
+                .is_some_and(|n| self.store.playlists.contains_key(n))
     }
 
     pub fn open_len(&self) -> usize {
-        self.open.as_ref().and_then(|n| self.store.playlists.get(n)).map_or(0, |t| t.len())
+        self.open
+            .as_ref()
+            .and_then(|n| self.store.playlists.get(n))
+            .map_or(0, |t| t.len())
     }
 
     fn cur_len(&self) -> usize {
@@ -419,8 +429,12 @@ impl App {
             KeyCode::Char(' ') => self.toggle_pause(),
             KeyCode::Char('n') | KeyCode::Char('>') => self.next(),
             KeyCode::Char('N') | KeyCode::Char('<') => self.prev(),
-            KeyCode::Char('h') | KeyCode::Left => self.seek(Amount::Delta(-self.seek_step * times as f64)),
+            KeyCode::Char('h') | KeyCode::Left => {
-            KeyCode::Char('l') | KeyCode::Right => self.seek(Amount::Delta(self.seek_step * times as f64)),
+                self.seek(Amount::Delta(-self.seek_step * times as f64))
+            }
+            KeyCode::Char('l') | KeyCode::Right => {
+                self.seek(Amount::Delta(self.seek_step * times as f64))
+            }
             KeyCode::Char('+') | KeyCode::Char('=') => {
                 self.set_volume(Amount::Delta(self.volume_step * times as f64))
             }
@@ -678,7 +692,9 @@ impl App {
         }
         match key.code {
             KeyCode::Esc | KeyCode::Char('q') => self.close_artist_pick(),
-            KeyCode::Char('j') | KeyCode::Down => self.artist_sel = (self.artist_sel + 1).min(len - 1),
+            KeyCode::Char('j') | KeyCode::Down => {
+                self.artist_sel = (self.artist_sel + 1).min(len - 1)
+            }
             KeyCode::Char('k') | KeyCode::Up => self.artist_sel = self.artist_sel.saturating_sub(1),
             KeyCode::Char(c @ '1'..='9') => {
                 let i = c as usize - '1' as usize;
@@ -716,22 +732,28 @@ impl App {
                 .into_iter()
                 .filter(|t| {
                     t.artist.to_lowercase() == wanted
-                        || split_artists(&t.artist).iter().any(|a| a.to_lowercase() == wanted)
+                        || split_artists(&t.artist)
+                            .iter()
+                            .any(|a| a.to_lowercase() == wanted)
                 })
                 .collect())
         });
     }
 
     fn start_search(&mut self, query: String) {
-        self.spawn_loader(format!("Search: {query}"), format!("Searching \u{201c}{query}\u{201d}"), move || {
+        self.spawn_loader(
-            ytmusic::search(&query)
+            format!("Search: {query}"),
-        });
+            format!("Searching \u{201c}{query}\u{201d}"),
+            move || ytmusic::search(&query),
+        );
     }
 
     fn start_import(&mut self, url: String) {
-        self.spawn_loader("Imported playlist".into(), "Importing playlist".into(), move || {
+        self.spawn_loader(
-            ytmusic::import(&url)
+            "Imported playlist".into(),
-        });
+            "Importing playlist".into(),
+            move || ytmusic::import(&url),
+        );
     }
 
     fn spawn_loader<F>(&mut self, title: String, busy: String, work: F)
@@ -843,7 +865,9 @@ impl App {
                         "Playback failed 3 times in a row ({msg}). Update yt-dlp: yt-dlp -U"
                     ));
                 } else {
-                    self.error(format!("Can't play \u{201c}{name}\u{201d} ({msg}) — skipping"));
+                    self.error(format!(
+                        "Can't play \u{201c}{name}\u{201d} ({msg}) — skipping"
+                    ));
                     self.advance(true);
                 }
             }
@@ -862,7 +886,9 @@ impl App {
     }
 
     fn start_track(&mut self, i: usize, keep_resume: bool) {
-        let Some(track) = self.queue.get(i).cloned() else { return };
+        let Some(track) = self.queue.get(i).cloned() else {
+            return;
+        };
         if !keep_resume {
             self.resume = None;
         }
@@ -953,7 +979,9 @@ impl App {
     }
 
     fn play_radio(&mut self, i: usize) {
-        let Some(track) = self.radio.get(i).cloned() else { return };
+        let Some(track) = self.radio.get(i).cloned() else {
+            return;
+        };
         self.on_radio = true;
         self.result_cursor = Some(i);
         self.resume = None;
@@ -978,7 +1006,11 @@ impl App {
         }
         match self.with_player(|p| p.set_pause(pause)) {
             Ok(()) => {
-                self.play_state = if pause { PlayState::Paused } else { PlayState::Playing };
+                self.play_state = if pause {
+                    PlayState::Paused
+                } else {
+                    PlayState::Playing
+                };
             }
             Err(e) => self.error(format!("{e:#}")),
         }
@@ -1142,7 +1174,10 @@ impl App {
         if let Some(c) = self.current {
             self.played.insert(c);
         }
-        self.info(format!("Shuffle: {}", if self.shuffle { "on" } else { "off" }));
+        self.info(format!(
+            "Shuffle: {}",
+            if self.shuffle { "on" } else { "off" }
+        ));
     }
 
     fn cycle_repeat(&mut self) {
@@ -1196,7 +1231,11 @@ impl App {
         if self.results.is_empty() {
             return self.error("No results to play");
         }
-        let start = if self.view == View::Results { self.selected() } else { 0 };
+        let start = if self.view == View::Results {
+            self.selected()
+        } else {
+            0
+        };
         self.queue = self.results.clone();
         self.played.clear();
         self.current = None;
@@ -1239,7 +1278,11 @@ impl App {
         }
         let sel = self.states[View::Queue.idx()].selected().unwrap_or(0);
         let len = self.queue.len();
-        self.states[View::Queue.idx()].select(if len == 0 { None } else { Some(sel.min(len - 1)) });
+        self.states[View::Queue.idx()].select(if len == 0 {
+            None
+        } else {
+            Some(sel.min(len - 1))
+        });
         self.info(format!("Removed: {}", removed.label()));
     }
 
@@ -1274,7 +1317,9 @@ impl App {
                     self.mode = Mode::ConfirmDelete;
                 }
             }
-            View::Results => self.info("Results can't be deleted — they are replaced by the next search"),
+            View::Results => {
+                self.info("Results can't be deleted — they are replaced by the next search")
+            }
         }
     }
 
@@ -1293,9 +1338,13 @@ impl App {
             return self.error("Queue is empty — nothing to save");
         }
         let n = self.queue.len();
-        self.store.playlists.insert(name.to_string(), self.queue.clone());
+        self.store
+            .playlists
+            .insert(name.to_string(), self.queue.clone());
         if self.persist() {
-            self.info(format!("Saved {n} tracks to playlist \u{201c}{name}\u{201d}"));
+            self.info(format!(
+                "Saved {n} tracks to playlist \u{201c}{name}\u{201d}"
+            ));
         }
     }
 
@@ -1314,7 +1363,10 @@ impl App {
         let Some(track) = track else {
             return self.error("Select a track in Results or Queue first");
         };
-        let key = self.store.resolve_exact(name).unwrap_or_else(|| name.to_string());
+        let key = self
+            .store
+            .resolve_exact(name)
+            .unwrap_or_else(|| name.to_string());
         let list = self.store.playlists.entry(key.clone()).or_default();
         if list.iter().any(|t| t.id == track.id) {
             return self.info(format!("Already in \u{201c}{key}\u{201d}"));
@@ -1341,10 +1393,14 @@ impl App {
             self.result_cursor = None;
             self.states[View::Queue.idx()].select(Some(0));
             self.play_index(0);
-            self.info(format!("Playing playlist \u{201c}{name}\u{201d} ({n} tracks)"));
+            self.info(format!(
+                "Playing playlist \u{201c}{name}\u{201d} ({n} tracks)"
+            ));
         } else {
             self.queue.extend(tracks);
-            self.info(format!("Appended \u{201c}{name}\u{201d} ({n} tracks) to the queue"));
+            self.info(format!(
+                "Appended \u{201c}{name}\u{201d} ({n} tracks) to the queue"
+            ));
         }
     }
 
@@ -1378,9 +1434,13 @@ impl App {
     }
 
     fn remove_playlist_track(&mut self, i: usize) {
-        let Some(name) = self.open.clone() else { return };
+        let Some(name) = self.open.clone() else {
+            return;
+        };
         let removed = {
-            let Some(list) = self.store.playlists.get_mut(&name) else { return };
+            let Some(list) = self.store.playlists.get_mut(&name) else {
+                return;
+            };
             if i >= list.len() {
                 None
             } else {
@@ -1391,9 +1451,13 @@ impl App {
         let Some((track, len)) = removed else {
             return self.error("No track selected");
         };
-        self.pl_state.select(if len == 0 { None } else { Some(i.min(len - 1)) });
+        self.pl_state
+            .select(if len == 0 { None } else { Some(i.min(len - 1)) });
         if self.persist() {
-            self.info(format!("Removed from \u{201c}{name}\u{201d}: {}", track.label()));
+            self.info(format!(
+                "Removed from \u{201c}{name}\u{201d}: {}",
+                track.label()
+            ));
         }
     }
 
@@ -1405,7 +1469,9 @@ impl App {
     }
 
     fn move_playlist_track(&mut self, dir: isize) {
-        let Some(name) = self.open.clone() else { return };
+        let Some(name) = self.open.clone() else {
+            return;
+        };
         let i = self.selected();
         let j = i as isize + dir;
         let moved = match self.store.playlists.get_mut(&name) {
@@ -1480,9 +1546,15 @@ mod tests {
         let mut app = App::new(tx);
         app.store.playlists.insert(
             "mix".into(),
-            vec![track("aaaaaaaaaaa", "A"), track("bbbbbbbbbbb", "B"), track("ccccccccccc", "C")],
+            vec![
+                track("aaaaaaaaaaa", "A"),
+                track("bbbbbbbbbbb", "B"),
+                track("ccccccccccc", "C"),
+            ],
         );
-        app.store.playlists.insert("other".into(), vec![track("ddddddddddd", "D")]);
+        app.store
+            .playlists
+            .insert("other".into(), vec![track("ddddddddddd", "D")]);
 
         press(&mut app, KeyCode::Tab);
         press(&mut app, KeyCode::Tab);
@@ -1501,12 +1573,18 @@ mod tests {
         assert_eq!(app.selected(), 2);
 
         press(&mut app, KeyCode::Char('K'));
-        let ids: Vec<&str> = app.store.playlists["mix"].iter().map(|t| t.id.as_str()).collect();
+        let ids: Vec<&str> = app.store.playlists["mix"]
+            .iter()
+            .map(|t| t.id.as_str())
+            .collect();
         assert_eq!(ids, ["aaaaaaaaaaa", "ccccccccccc", "bbbbbbbbbbb"]);
         assert_eq!(app.selected(), 1);
 
         press(&mut app, KeyCode::Char('x'));
-        let ids: Vec<&str> = app.store.playlists["mix"].iter().map(|t| t.id.as_str()).collect();
+        let ids: Vec<&str> = app.store.playlists["mix"]
+            .iter()
+            .map(|t| t.id.as_str())
+            .collect();
         assert_eq!(ids, ["aaaaaaaaaaa", "bbbbbbbbbbb"]);
         assert_eq!(app.selected(), 1);
 

src/config.rs

@@ -99,7 +99,10 @@ volume_step = {vstep:?}
                 return (Config::default(), None);
             }
             Err(e) => {
-                return (Config::default(), Some(format!("cannot read {}: {e}", path.display())))
+                return (
+                    Config::default(),
+                    Some(format!("cannot read {}: {e}", path.display())),
+                )
             }
         };
         match toml::from_str::<Config>(&text) {
@@ -137,12 +140,20 @@ pub fn migrate_legacy() {
     }
 
     let Ok(path) = Config::path() else { return };
-    let Ok(text) = fs::read_to_string(&path) else { return };
+    let Ok(text) = fs::read_to_string(&path) else {
-    let Ok(table) = text.parse::<toml::Table>() else { return };
+        return;
-    if table.contains_key("playback") || !(table.contains_key("queue") || table.contains_key("position")) {
+    };
+    let Ok(table) = text.parse::<toml::Table>() else {
+        return;
+    };
+    if table.contains_key("playback")
+        || !(table.contains_key("queue") || table.contains_key("position"))
+    {
         return;
     }
-    let Ok(old) = toml::from_str::<Legacy>(&text) else { return };
+    let Ok(old) = toml::from_str::<Legacy>(&text) else {
+        return;
+    };
 
     let d = Playback::default();
     let mut p = Playback {
@@ -153,7 +164,11 @@ pub fn migrate_legacy() {
         ..d
     };
     p.sanitize();
-    let session = Session { queue: old.queue, current: old.current, position: old.position };
+    let session = Session {
+        queue: old.queue,
+        current: old.current,
+        position: old.position,
+    };
     if let Ok(s) = session.render() {
         if !Session::exists() {
             let _ = Session::write(&s);
@@ -183,14 +198,22 @@ mod tests {
         assert_eq!(c.playback.volume, 80);
         let c: Config =
             toml::from_str("[playback]\nvolume = 10\nrepeat = \"one\"\nseek_step = 10").unwrap();
-        assert_eq!((c.playback.volume, c.playback.repeat), (10, RepeatMode::One));
+        assert_eq!(
+            (c.playback.volume, c.playback.repeat),
+            (10, RepeatMode::One)
+        );
         assert_eq!(c.playback.seek_step, 10.0);
         assert!(toml::from_str::<Config>("[playback]\nrepeat = \"sometimes\"").is_err());
     }
 
     #[test]
     fn sanitize_bad_values() {
-        let mut p = Playback { volume: 250, seek_step: -3.0, volume_step: 900.0, ..Playback::default() };
+        let mut p = Playback {
+            volume: 250,
+            seek_step: -3.0,
+            volume_step: 900.0,
+            ..Playback::default()
+        };
         p.sanitize();
         assert_eq!((p.volume, p.seek_step, p.volume_step), (100, 5.0, 100.0));
     }

src/model.rs

@@ -24,7 +24,9 @@ impl Track {
 pub fn split_artists(credit: &str) -> Vec<String> {
     const MARK: char = '\u{1}';
     let mut s = credit.to_string();
-    for sep in [" & ", ", ", " feat. ", " Feat. ", " feat ", " ft. ", " Ft. ", " × "] {
+    for sep in [
+        " & ", ", ", " feat. ", " Feat. ", " feat ", " ft. ", " Ft. ", " × ",
+    ] {
         s = s.replace(sep, &MARK.to_string());
     }
     let mut out: Vec<String> = Vec::new();
@@ -61,7 +63,11 @@ pub fn parse_clock(s: &str) -> Option<f64> {
 }
 
 pub fn fmt_time(secs: f64) -> String {
-    let s = if secs.is_finite() { secs.max(0.0) as u64 } else { 0 };
+    let s = if secs.is_finite() {
+        secs.max(0.0) as u64
+    } else {
+        0
+    };
     let (h, m, s) = (s / 3600, (s % 3600) / 60, s % 60);
     if h > 0 {
         format!("{h}:{m:02}:{s:02}")

src/player.rs

@@ -26,10 +26,7 @@ pub struct Player {
 }
 
 impl Player {
-    pub fn spawn(
+    pub fn spawn(volume: u8, on_event: impl Fn(PlayerEvent) + Send + 'static) -> Result<Player> {
-        volume: u8,
-        on_event: impl Fn(PlayerEvent) + Send + 'static,
-    ) -> Result<Player> {
         let sock_dir = dirs::runtime_dir().unwrap_or_else(std::env::temp_dir);
         let sock_path = sock_dir.join(format!("drift-{}.sock", std::process::id()));
         let _ = std::fs::remove_file(&sock_path);
@@ -51,10 +48,14 @@ impl Player {
         .arg(format!("--volume={volume}"))
         .arg(format!("--input-ipc-server={}", sock_path.display()));
 
-        if let Ok(extra) = std::env::var("DRIFT_MPV_ARGS").or_else(|_| std::env::var("YTM_MPV_ARGS")) {
+        if let Ok(extra) =
+            std::env::var("DRIFT_MPV_ARGS").or_else(|_| std::env::var("YTM_MPV_ARGS"))
+        {
             cmd.args(extra.split_whitespace());
         }
-        cmd.stdin(Stdio::null()).stdout(Stdio::null()).stderr(Stdio::null());
+        cmd.stdin(Stdio::null())
+            .stdout(Stdio::null())
+            .stderr(Stdio::null());
 
         #[cfg(target_os = "linux")]
         unsafe {
@@ -98,14 +99,21 @@ impl Player {
             sock_path,
         };
 
-        for (id, prop) in [(1, "time-pos"), (2, "duration"), (3, "pause"), (4, "volume")] {
+        for (id, prop) in [
+            (1, "time-pos"),
+            (2, "duration"),
+            (3, "pause"),
+            (4, "volume"),
+        ] {
             player.send(json!(["observe_property", id, prop]))?;
         }
 
         std::thread::spawn(move || {
             for line in BufReader::new(reader).lines() {
                 let Ok(line) = line else { break };
-                let Ok(v) = serde_json::from_str::<Value>(&line) else { continue };
+                let Ok(v) = serde_json::from_str::<Value>(&line) else {
+                    continue;
+                };
                 if let Some(ev) = parse_event(&v) {
                     on_event(ev);
                 }
@@ -208,7 +216,9 @@ mod tests {
     fn mpv_roundtrip() {
         use std::sync::mpsc;
         let wav = std::env::temp_dir().join("drift-test.wav");
-        let samples: Vec<u8> = (0..16_000u32).map(|i| if (i / 20) % 2 == 0 { 140 } else { 116 }).collect();
+        let samples: Vec<u8> = (0..16_000u32)
+            .map(|i| if (i / 20) % 2 == 0 { 140 } else { 116 })
+            .collect();
         let mut data = Vec::new();
         data.extend_from_slice(b"RIFF");
         data.extend_from_slice(&(36 + samples.len() as u32).to_le_bytes());

src/session.rs

@@ -28,8 +28,12 @@ impl Session {
     }
 
     pub fn load() -> Session {
-        let Ok(path) = Self::path() else { return Session::default() };
+        let Ok(path) = Self::path() else {
-        let Ok(text) = fs::read_to_string(&path) else { return Session::default() };
+            return Session::default();
+        };
+        let Ok(text) = fs::read_to_string(&path) else {
+            return Session::default();
+        };
         match serde_json::from_str::<Session>(&text) {
             Ok(mut s) => {
                 s.sanitize();
@@ -68,7 +72,13 @@ mod tests {
     use super::*;
 
     fn track(id: &str) -> Track {
-        Track { id: id.into(), title: "T".into(), artist: "A".into(), album: None, duration: Some(200) }
+        Track {
+            id: id.into(),
+            title: "T".into(),
+            artist: "A".into(),
+            album: None,
+            duration: Some(200),
+        }
     }
 
     #[test]
@@ -84,8 +94,15 @@ mod tests {
 
     #[test]
     fn roundtrip() {
-        let ok = Session { queue: vec![track("aaaaaaaaaaa")], current: Some(0), position: 42.5 };
+        let ok = Session {
+            queue: vec![track("aaaaaaaaaaa")],
+            current: Some(0),
+            position: 42.5,
+        };
         let again: Session = serde_json::from_str(&ok.render().unwrap()).unwrap();
-        assert_eq!((again.current, again.position, again.queue), (Some(0), 42.5, ok.queue));
+        assert_eq!(
+            (again.current, again.position, again.queue),
+            (Some(0), 42.5, ok.queue)
+        );
     }
 }

src/store.rs

@@ -87,7 +87,10 @@ impl Store {
     pub fn resolve(&self, name: &str) -> Option<String> {
         self.resolve_exact(name).or_else(|| {
             let lower = name.to_lowercase();
-            let mut found = self.playlists.keys().filter(|k| k.to_lowercase().starts_with(&lower));
+            let mut found = self
+                .playlists
+                .keys()
+                .filter(|k| k.to_lowercase().starts_with(&lower));
             match (found.next(), found.next()) {
                 (Some(k), None) => Some(k.clone()),
                 _ => None,

src/ui.rs

@@ -11,7 +11,10 @@ const ACCENT: Color = Color::Cyan;
 const SPINNER: [&str; 10] = ["⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧", "⠇", "⠏"];
 
 fn selected_style() -> Style {
-    Style::new().fg(Color::Black).bg(ACCENT).add_modifier(Modifier::BOLD)
+    Style::new()
+        .fg(Color::Black)
+        .bg(ACCENT)
+        .add_modifier(Modifier::BOLD)
 }
 
 fn header_style() -> Style {
@@ -56,7 +59,10 @@ fn draw_tabs(f: &mut Frame, app: &App, area: Rect) {
     ])
     .areas(area);
 
-    f.render_widget(Paragraph::new(" ♪ Drift").style(Style::new().fg(ACCENT).bold()), name);
+    f.render_widget(
+        Paragraph::new(" ♪ Drift").style(Style::new().fg(ACCENT).bold()),
+        name,
+    );
 
     let titles = [
         format!(" Results {} ", app.results.len()),
@@ -107,7 +113,11 @@ fn track_rows<'a>(
         .enumerate()
         .map(|(i, t)| {
             let is_playing = playing.is_some_and(|(id, _)| id == t.id);
-            let marker = if is_playing { playing.map_or("", |p| p.1) } else { "" };
+            let marker = if is_playing {
+                playing.map_or("", |p| p.1)
+            } else {
+                ""
+            };
             let mut cells = vec![
                 Cell::from(marker),
                 Cell::from(format!("{:>3}", i + 1)).style(dim()),
@@ -118,8 +128,7 @@ fn track_rows<'a>(
                 cells.push(Cell::from(t.album.as_deref().unwrap_or("")));
             }
             cells.push(
-                Cell::from(t.duration.map_or(String::new(), |d| fmt_time(d as f64)))
+                Cell::from(t.duration.map_or(String::new(), |d| fmt_time(d as f64))).style(dim()),
-                    .style(dim()),
             );
             let row = Row::new(cells);
             if is_playing {
@@ -156,7 +165,9 @@ fn track_table<'a>(rows: Vec<Row<'a>>, show_album: bool, block: Block<'a>) -> Ta
 fn empty_hint(f: &mut Frame, block: Block, area: Rect, lines: &[&str]) {
     let text: Vec<Line> = lines.iter().map(|l| Line::from(*l).style(dim())).collect();
     f.render_widget(
-        Paragraph::new(text).alignment(Alignment::Center).block(block),
+        Paragraph::new(text)
+            .alignment(Alignment::Center)
+            .block(block),
         area,
     );
 }
@@ -176,9 +187,17 @@ fn draw_tracks(f: &mut Frame, app: &mut App, area: Rect, view: View) {
 
     if tracks.is_empty() {
         let hint: &[&str] = if view == View::Queue {
-            &["", "The queue is empty.", "Press `a` on a search result to queue it."]
+            &[
+                "",
+                "The queue is empty.",
+                "Press `a` on a search result to queue it.",
+            ]
         } else {
-            &["", "No results yet.", "Press / and type a query, or use  :search \"daft punk\""]
+            &[
+                "",
+                "No results yet.",
+                "Press / and type a query, or use  :search \"daft punk\"",
+            ]
         };
         return empty_hint(f, block, area, hint);
     }
@@ -192,7 +211,9 @@ fn draw_open_playlist(f: &mut Frame, app: &mut App, area: Rect, name: &str) {
     let now = playing_marker(app);
     let playing = now.as_ref().map(|(id, marker)| (id.as_str(), *marker));
 
-    let Some(tracks) = app.store.playlists.get(name) else { return };
+    let Some(tracks) = app.store.playlists.get(name) else {
+        return;
+    };
     let block = Block::bordered()
         .title(format!(" {name} ({}) ", tracks.len()))
         .border_style(Style::new().fg(ACCENT));
@@ -201,7 +222,11 @@ fn draw_open_playlist(f: &mut Frame, app: &mut App, area: Rect, name: &str) {
             f,
             block,
             area,
-            &["", "This playlist is empty.", "Add songs with  :addto \"name\"  from Results or Queue."],
+            &[
+                "",
+                "This playlist is empty.",
+                "Add songs with  :addto \"name\"  from Results or Queue.",
+            ],
         );
     }
     let show_album = area.width >= 76;
@@ -228,7 +253,12 @@ fn draw_playlists(f: &mut Frame, app: &mut App, area: Rect) {
             f,
             block,
             left,
-            &["", "No playlists yet.", "Queue some songs, then", ":save \"name\""],
+            &[
+                "",
+                "No playlists yet.",
+                "Queue some songs, then",
+                ":save \"name\"",
+            ],
         );
         let b = Block::bordered().title(" Preview ").border_style(dim());
         f.render_widget(b, right);
@@ -250,7 +280,11 @@ fn draw_playlists(f: &mut Frame, app: &mut App, area: Rect) {
         .collect();
     let table = Table::new(
         rows,
-        [Constraint::Length(3), Constraint::Fill(1), Constraint::Length(5)],
+        [
+            Constraint::Length(3),
+            Constraint::Fill(1),
+            Constraint::Length(5),
+        ],
     )
     .header(Row::new(vec!["", "Name", "Songs"]).style(header_style()))
     .block(block)
@@ -259,7 +293,10 @@ fn draw_playlists(f: &mut Frame, app: &mut App, area: Rect) {
 
     let sel = app.selected();
     let preview_block = Block::bordered().title(" Preview ").border_style(dim());
-    match app.playlist_name(sel).and_then(|n| app.store.playlists.get(&n)) {
+    match app
+        .playlist_name(sel)
+        .and_then(|n| app.store.playlists.get(&n))
+    {
         Some(tracks) if !tracks.is_empty() => {
             let show_album = right.width >= 70;
             let rows = track_rows(tracks, None, show_album);
@@ -288,7 +325,12 @@ fn draw_now_playing(f: &mut Frame, app: &App, area: Rect) {
     let flags_w = flags.chars().count() as u16 + 1;
     let [title_area, flags_area] =
         Layout::horizontal([Constraint::Min(1), Constraint::Length(flags_w)]).areas(l1);
-    f.render_widget(Paragraph::new(flags).style(dim()).alignment(Alignment::Right), flags_area);
+    f.render_widget(
+        Paragraph::new(flags)
+            .style(dim())
+            .alignment(Alignment::Right),
+        flags_area,
+    );
 
     let icon = match app.play_state {
         PlayState::Playing => "▶".to_string(),
@@ -314,7 +356,14 @@ fn draw_now_playing(f: &mut Frame, app: &App, area: Rect) {
     f.render_widget(Paragraph::new(line), title_area);
 
     let left = format!(" {} ", fmt_time(app.position));
-    let right = format!(" {} ", if app.duration > 0.0 { fmt_time(app.duration) } else { "--:--".into() });
+    let right = format!(
+        " {} ",
+        if app.duration > 0.0 {
+            fmt_time(app.duration)
+        } else {
+            "--:--".into()
+        }
+    );
     let bar_w = (l2.width as usize).saturating_sub(left.chars().count() + right.chars().count());
     let ratio = if app.duration > 0.0 {
         (app.position / app.duration).clamp(0.0, 1.0)
@@ -344,7 +393,10 @@ fn draw_cmdline(f: &mut Frame, app: &App, area: Rect) {
 
     if app.mode == Mode::Command {
         let text = format!(":{}", app.cmd_buf);
-        let col = text.chars().count().min(area.width.saturating_sub(1) as usize) as u16;
+        let col = text
+            .chars()
+            .count()
+            .min(area.width.saturating_sub(1) as usize) as u16;
         f.render_widget(Paragraph::new(text), area);
         f.set_cursor_position((area.x + col, area.y));
         return;
@@ -371,7 +423,9 @@ fn draw_cmdline(f: &mut Frame, app: &App, area: Rect) {
     }
     if !pending.is_empty() {
         f.render_widget(
-            Paragraph::new(format!("{pending} ")).alignment(Alignment::Right).style(Style::new().fg(Color::Yellow)),
+            Paragraph::new(format!("{pending} "))
+                .alignment(Alignment::Right)
+                .style(Style::new().fg(Color::Yellow)),
             area,
         );
     }
@@ -388,16 +442,25 @@ const HELP: &[(&str, &str)] = &[
     ("Tab  S-Tab", "cycle Results / Queue / Playlists"),
     ("gr  gq  gp", "jump to Results / Queue / Playlists"),
     ("PLAYBACK", "#"),
-    ("Enter", "play selected (on a playlist: load it; inside one: play from there)"),
+    (
+        "Enter",
+        "play selected (on a playlist: load it; inside one: play from there)",
+    ),
     ("Space", "pause / resume"),
     ("n  N  (or > <)", "next / previous track"),
     ("h l  / ← →", "seek -5s / +5s (counts: 6l)"),
     ("+  -", "volume up / down"),
     ("s  r", "toggle shuffle / cycle repeat"),
-    ("ga  or  :artist", "songs by the artist of the selected song; a popup asks which one when there are several"),
+    (
+        "ga  or  :artist",
+        "songs by the artist of the selected song; a popup asks which one when there are several",
+    ),
     ("QUEUE", "#"),
     ("a  A  P", "add selected / add all / play all results"),
-    ("dd  x", "remove from queue / delete playlist / delete track in a playlist"),
+    (
+        "dd  x",
+        "remove from queue / delete playlist / delete track in a playlist",
+    ),
     ("J K", "move queue or playlist item down / up"),
     ("PLAYLISTS", "#"),
     ("→ or l", "open the highlighted playlist"),
@@ -411,10 +474,19 @@ const HELP: &[(&str, &str)] = &[
     (":vol 50 | +5", "set or change the volume"),
     (":shuffle  :repeat [m]", "modes: off, all or one"),
     (":add [N]  :addall", "queue a result / all results"),
-    (":playall  :remove [N]", "play all results / remove from queue"),
+    (
+        ":playall  :remove [N]",
+        "play all results / remove from queue",
+    ),
     (":clear", "empty the queue"),
-    (":save n  :load n", "save the queue as a playlist / load one"),
+    (
-    (":append n  :delpl n", "append a playlist to the queue / delete it"),
+        ":save n  :load n",
+        "save the queue as a playlist / load one",
+    ),
+    (
+        ":append n  :delpl n",
+        "append a playlist to the queue / delete it",
+    ),
     (":addto n", "add the selected track to playlist n"),
     (":import URL", "load a YouTube / YT Music playlist"),
     (":artist", "same as ga"),
@@ -470,7 +542,10 @@ fn help_lines(inner_w: usize) -> Vec<Line<'static>> {
             }
         }
         for rest in desc {
-            lines.push(Line::from(vec![Span::raw(" ".repeat(key_w)), Span::raw(rest)]));
+            lines.push(Line::from(vec![
+                Span::raw(" ".repeat(key_w)),
+                Span::raw(rest),
+            ]));
         }
     }
     lines
@@ -478,7 +553,12 @@ fn help_lines(inner_w: usize) -> Vec<Line<'static>> {
 
 fn draw_artist_picker(f: &mut Frame, app: &App, area: Rect) {
     let n = app.artist_opts.len() as u16;
-    let widest = app.artist_opts.iter().map(|a| a.chars().count()).max().unwrap_or(0) as u16;
+    let widest = app
+        .artist_opts
+        .iter()
+        .map(|a| a.chars().count())
+        .max()
+        .unwrap_or(0) as u16;
     let w = (widest + 10).max(34).min(area.width);
     let h = (n + 3).min(area.height);
     let popup = Rect {
@@ -533,7 +613,12 @@ fn draw_help(f: &mut Frame, app: &mut App, area: Rect) {
         .border_style(Style::new().fg(Color::Yellow));
     if max_scroll > 0 {
         let end = (scroll + visible).min(lines.len());
-        block = block.title_bottom(format!(" j/k scroll · {}-{} of {} ", scroll + 1, end, lines.len()));
+        block = block.title_bottom(format!(
+            " j/k scroll · {}-{} of {} ",
+            scroll + 1,
+            end,
+            lines.len()
+        ));
     }
 
     let shown: Vec<Line> = lines.into_iter().skip(scroll).take(visible).collect();
@@ -551,7 +636,12 @@ mod tests {
     use std::sync::mpsc;
 
     fn text(term: &Terminal<TestBackend>) -> String {
-        term.backend().buffer().content().iter().map(|c| c.symbol()).collect()
+        term.backend()
+            .buffer()
+            .content()
+            .iter()
+            .map(|c| c.symbol())
+            .collect()
     }
 
     #[test]
@@ -571,7 +661,13 @@ mod tests {
             duration: Some(90),
         };
         app.store.playlists.insert("empty".into(), vec![]);
-        app.store.playlists.insert("mix".into(), vec![t("aaaaaaaaaaa", "First Song"), t("bbbbbbbbbbb", "Second Song")]);
+        app.store.playlists.insert(
+            "mix".into(),
+            vec![
+                t("aaaaaaaaaaa", "First Song"),
+                t("bbbbbbbbbbb", "Second Song"),
+            ],
+        );
         let key = |app: &mut App, c| app.on_key(KeyEvent::new(c, KeyModifiers::NONE));
 
         let mut term = Terminal::new(TestBackend::new(100, 24)).unwrap();

src/ytmusic.rs

@@ -16,7 +16,9 @@ pub fn search(query: &str) -> Result<Vec<Track>, String> {
         Ok(tracks) if !tracks.is_empty() => Ok(tracks),
         Ok(_) => ytdlp_search(query).map_err(|e| format!("{e:#}")),
         Err(primary) => ytdlp_search(query).map_err(|fallback| {
-            format!("YouTube Music search failed ({primary:#}); yt-dlp fallback failed ({fallback:#})")
+            format!(
+                "YouTube Music search failed ({primary:#}); yt-dlp fallback failed ({fallback:#})"
+            )
         }),
     }
 }
@@ -73,7 +75,9 @@ fn search_innertube(query: &str) -> Result<Vec<Track>> {
         .set("Cookie", "SOCS=CAI")
         .send_json(body)
         .map_err(|e| anyhow!("request failed: {e}"))?;
-    let v: Value = resp.into_json().context("invalid JSON from YouTube Music")?;
+    let v: Value = resp
+        .into_json()
+        .context("invalid JSON from YouTube Music")?;
     Ok(parse_search_response(&v))
 }
 
@@ -115,7 +119,9 @@ fn column_segments(item: &Value, col: usize) -> Vec<String> {
     let mut segments = Vec::new();
     let mut cur = String::new();
     for run in runs.into_iter().flatten() {
-        let Some(text) = run.get("text").and_then(Value::as_str) else { continue };
+        let Some(text) = run.get("text").and_then(Value::as_str) else {
+            continue;
+        };
         if text.trim() == "•" {
             segments.push(std::mem::take(&mut cur));
         } else {
@@ -142,7 +148,10 @@ fn parse_item(item: &Value) -> Option<Track> {
     let title = column_segments(item, 0).into_iter().next()?;
 
     let mut meta = column_segments(item, 1);
-    if matches!(meta.first().map(String::as_str), Some("Song" | "Video" | "Episode")) {
+    if matches!(
+        meta.first().map(String::as_str),
+        Some("Song" | "Video" | "Episode")
+    ) {
         meta.remove(0);
     }
     let duration = match meta.last() {
@@ -153,7 +162,10 @@ fn parse_item(item: &Value) -> Option<Track> {
         }
         _ => None,
     };
-    let artist = meta.first().cloned().unwrap_or_else(|| "Unknown artist".into());
+    let artist = meta
+        .first()
+        .cloned()
+        .unwrap_or_else(|| "Unknown artist".into());
     let album = meta
         .get(1)
         .filter(|a| !a.contains(" views") && !a.contains(" plays"))