togglempc 0.1.0

Togglempc is a small REST server that accepts HTTP post requests to toggle MPD on and off and switch playlist. (It is a client to MPD.) MPD is Music Play Daemon, see https://www.musicpd.org/. Togglempc can be used for home automation or smart switches can use it to control MPD instances.
Documentation 
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
79
80
81
82
83
84
85
86
87

use std::collections::{VecDeque};
use std::io;
use crate::{MpdConn, ToggleMpc};

struct MpdConnMock<'a> {
    responses : VecDeque<(&'a str, &'a str)>,
}

impl MpdConn for MpdConnMock<'_> {
    fn call(&mut self, request: &str) -> io::Result<String> {
        match self.responses.pop_front() {
            Some((req, resp)) => if req == request {
                    println!("requested: {}, delivered: {}", request, resp);
                    Ok(resp.to_string())
                } else {
                    panic!("unhandled request: {}, expected: {}", request, req)
                }
            _ => panic!("unhandled request: {}", request)
        }
    }
}

impl <'a> MpdConnMock<'a> {
    fn new(responses : Vec<(&'a str, &'a str)>) -> Self {
        MpdConnMock {responses: VecDeque::from(responses)}
    }
    fn communcation_perfomed(&self) -> bool {
        self.responses.is_empty()
    }
}

#[test]
fn test_toggle_from_pause_to_play() {
    let mut conn_mock = MpdConnMock::new(vec![("status\n", "volume: 67\nstate: pause\nOK\n"), ("play\n", "OK\n")]);
    let mut toggle_mpc = ToggleMpc::new("".to_string(), vec!("deutschlandfunk"));
    toggle_mpc.toggle_play(&mut conn_mock).unwrap();
    assert!(conn_mock.communcation_perfomed());
}

#[test]
fn test_toggle_from_play_to_pause() {
    let mut conn_mock = MpdConnMock::new(vec![("status\n", "volume: 67\nstate: play\nOK\n"), ("pause\n", "OK\n")]);
    let mut toggle_mpc = ToggleMpc::new("".to_string(), vec!("deutschlandfunk"));
    toggle_mpc.toggle_play(&mut conn_mock).unwrap();
    assert!(conn_mock.communcation_perfomed());
}

#[test]
fn test_switch_list() {
    let responses = vec!
    [("status\n", "playlist: 123\nstate: play\nOK\n"),
    ("clear\n", "OK\n"),
    ("load hr3\n", "OK\n"),
    ("play\n", "OK\n"),
    ("status\n", "playlist: 124\nstate: play\nOK\n")];
    let mut conn_mock = MpdConnMock::new(responses);
    let mut toggle_mpc = ToggleMpc::new("".to_string(), vec!("hr1", "hr3"));
    toggle_mpc.switch_list(&mut conn_mock).unwrap();
    assert!(conn_mock.communcation_perfomed());
}

#[test]
fn test_switch_list_keeps_pos() {
    let responses = vec!
        [("status\n", "playlist: 123\nstate: play\nOK\n"),
        ("clear\n", "OK\n"),
        ("load Badesalz - Diwodaso\n", "OK\n"),
        ("play\n", "OK\n"),
        ("status\n", "playlist: 124\nstate: play\nOK\n"),
        ("status\n", "playlist: 124\nstate: play\nsong: 24\nelapsed: 84.102\nOK\n"),
        ("clear\n", "OK\n"),
        ("load Dire Straits - Brothers In Arms\n", "OK\n"),
        ("play\n", "OK\n"),
        ("status\n", "playlist: 125\nstate: play\nOK\n"),
        ("status\n", "playlist: 125\nstate: play\nOK\n"),
        ("clear\n", "OK\n"),
        ("load Badesalz - Diwodaso\n", "OK\n"),
        ("play\n", "OK\n"),
        ("seek 24 84\n", "OK\n"),
        ("status\n", "playlist: 126\nstate: play\nOK\n")];
    let mut conn_mock = MpdConnMock::new(responses);
    let mut toggle_mpc = ToggleMpc::new("".to_string(), vec!("Dire Straits - Brothers In Arms", "Badesalz - Diwodaso"));
    toggle_mpc.switch_list(&mut conn_mock).unwrap();
    toggle_mpc.switch_list(&mut conn_mock).unwrap();
    toggle_mpc.switch_list(&mut conn_mock).unwrap();
    assert!(conn_mock.communcation_perfomed());
}