aboutsummaryrefslogtreecommitdiff
path: root/src/app.rs
blob: 1e0e8e237a01fbccc52bc905b882da5efa8b41aa (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
use crate::connection::Connection;
use crate::list::ContentList;
use mpd::Client;
use std::collections::VecDeque;

// Application result type
pub type AppResult<T> = std::result::Result<T, Box<dyn std::error::Error>>;

/// Application
#[derive(Debug)]
pub struct App {
    /// check if app is running
    pub running: bool,
    pub conn: Connection,
    pub play_deque: ContentList<String>,
    pub song_list: ContentList<String>,
    pub queue_list: ContentList<String>,
    pub pl_list: ContentList<String>,
}

impl App {
    pub fn builder(addrs: &str) -> AppResult<Self> {
        let mut conn = Connection::new(addrs).unwrap();
        let mut queue = ContentList::new();
        let mut pl_list = ContentList::new();
        pl_list.list = Self::get_playlist(&mut conn.conn)?;

        Self::get_queue(&mut conn, &mut queue.list);

        let mut song_list = ContentList::new();
        song_list.list = conn.songs_filenames.clone();

        Ok(Self {
            running: true,
            conn,
            play_deque: ContentList::new(),
            song_list,
            queue_list: ContentList::new(),
            pl_list,
        })
    }

    pub fn tick(&self) {}

    pub fn quit(&mut self) {
        self.running = false;
    }

    pub fn get_queue(conn: &mut Connection, vec: &mut Vec<String>) {
        conn.conn.queue().unwrap().into_iter().for_each(|x| {
            if let Some(title) = x.title {
                if let Some(artist) = x.artist {
                    vec.push(format!("{} - {}", artist, title));
                } else {
                    vec.push(title)
                }
            } else {
                vec.push(x.file)
            }
        });
    }

    pub fn update_queue(&mut self) {
        self.queue_list.list.clear();
        Self::get_queue(&mut self.conn, &mut self.queue_list.list);
    }

    pub fn get_playlist(conn: &mut Client) -> AppResult<Vec<String>> {
        let list: Vec<String> = conn.playlists()?.iter().map(|p| p.clone().name).collect();

        Ok(list)
    }

    pub fn update_playlist(&mut self) -> AppResult<()> {
        Self::get_playlist(&mut self.conn.conn)?;
        Ok(())
    }
}