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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use rocket::{self, routes, local::Client, http::Status};
use std::thread;
use super::*;

#[path="../src/mpd_mock.rs"]
mod mpd_mock;
use mpd_mock::MpdMock;

#[test]
fn test_toggle() {
    let mut mpd_mock = MpdMock::new_v6();
    let addr_and_port = mpd_mock.addr_and_port.clone();
    let config = build_config(&addr_and_port);

    let handle = thread::spawn(move || {
        mpd_mock.start_tcp_server();
        mpd_mock.process_call("status\n", "playlist: 123\nstate: play\nOK\n");
        mpd_mock.process_call("pause\n", "OK\n");
    });
    {
        let parsed_conf = parse_config_and_build_toggle_mpcs(&config);
        let rocket = rocket::ignite()
            .mount("/", routes![toggle_play, switch_playlist])
            .manage(parsed_conf);

        let client = Client::new(rocket).unwrap();
        let mut response = client.post("/mpd/living-room/toggle-play").dispatch();
        assert_eq!(response.body_string(), None);
    }
    handle.join().unwrap();
}

#[test]
fn test_switch() {
    let mut mpd_mock = MpdMock::new_v4();
    let addr_and_port = mpd_mock.addr_and_port.clone();
    let config = build_config(&addr_and_port);

    let handle = thread::spawn(move || {
        mpd_mock.start_tcp_server();
        mpd_mock.process_call("status\n", "playlist: 123\nstate: play\nOK\n");
        mpd_mock.process_call("clear\n", "OK\n");
        mpd_mock.process_call("load hr1\n", "OK\n");
        mpd_mock.process_call("play\n", "OK\n");
        mpd_mock.process_call("status\n", "playlist: 124\nstate: play\nOK\n");
    });
    {
        let parsed_conf = parse_config_and_build_toggle_mpcs(&config);
        let rocket = rocket::ignite()
            .mount("/", routes![toggle_play, switch_playlist])
            .manage(parsed_conf);

        let client = Client::new(rocket).unwrap();
        let mut response = client.post("/mpd/living-room/switch-playlist").dispatch();
        assert_eq!(response.body_string(), None);
    }
    handle.join().unwrap();
}

#[test]
fn test_invalid_mpd() {

    let config = build_config(&"127.0.0.1:6699");
    let parsed_conf = parse_config_and_build_toggle_mpcs(&config);
    let rocket = rocket::ignite()
        .mount("/", routes![toggle_play, switch_playlist])
        .manage(parsed_conf);

    let client = Client::new(rocket).unwrap();
    let response = client.post("/mpd/wrong/toggle-play").dispatch();
    assert_eq!(response.status(), Status::NotFound);
}

#[test]
fn test_mpd_error() {
    let mut mpd_mock = MpdMock::new_v6();
    let addr_and_port = mpd_mock.addr_and_port.clone();
    let config = build_config(&addr_and_port);

    let handle = thread::spawn(move || {
        mpd_mock.start_tcp_server();
        mpd_mock.process_call("status\n", "playlist: 123\nstate: play\nACK something went wrong\n");
    });
    {
        let parsed_conf = parse_config_and_build_toggle_mpcs(&config);
        let rocket = rocket::ignite()
            .mount("/", routes![toggle_play, switch_playlist])
            .manage(parsed_conf);

        let client = Client::new(rocket).unwrap();
        let response = client.post("/mpd/living-room/toggle-play").dispatch();
        assert_eq!(response.status(), Status::InternalServerError);
    }
    handle.join().unwrap();
}

fn build_config(addr_and_port : &str) -> String {
    let pos_separator = addr_and_port.rfind(':').unwrap();
    let prefix = "[[playlist_collections]]\nid = \"default\"\nplaylists = [ \"smoothjazz\", \"hr1\" ]\n\n[[mpds]]\nname = \"living-room\"\n";
    let suffix = "\nplaylist_collection_id = \"default\"\n";
    format!("{}address = \"{}\"\nport = {}{}", prefix, &addr_and_port[0..pos_separator], &addr_and_port[(pos_separator + 1)..], suffix).to_string()
}