Reduce boilerplate in API by internalizing &str -> String
[xsetrootd.git] / src / main.rs
1 use dbus::blocking::stdintf::org_freedesktop_dbus::PropertiesPropertiesChanged;
2 use dbus::blocking::Connection;
3 use dbus::message::Message;
4 use std::collections::HashMap;
5 use std::sync::{Arc, Mutex};
6 use std::time::Duration;
7
8 fn update_map(arc_map: Arc<Mutex<HashMap<String, String>>>, key: &str, val: &str) {
9 let clone_arc = arc_map.clone();
10 let mut map = clone_arc.lock().unwrap();
11 map.insert(String::from(key), String::from(val));
12 for (k, v) in &*map {
13 println! {"{}: {}", k.clone(), v.clone()};
14 }
15 }
16
17 fn main() -> Result<(), Box<dyn std::error::Error>> {
18 let arc_locked_xset_map = Arc::new(Mutex::new(HashMap::new()));
19 let conn = Connection::new_session()?;
20
21 let proxy = conn.with_proxy(
22 "org.mpris.MediaPlayer2.spotify",
23 "/org/mpris/MediaPlayer2",
24 Duration::from_millis(5000),
25 );
26
27 let _ = proxy.match_signal(
28 move |pc: PropertiesPropertiesChanged, _: &Connection, _: &Message| {
29 pc.changed_properties["Metadata"]
30 .0
31 .as_iter()
32 .and_then(|mut iter| {
33 // Iterating over a RefArg goes key, value, key, value... Insane honestly.
34 while let Some(key) = iter.next() {
35 let key_str = key.as_str()?;
36 let value = iter.next();
37
38 let arc_locked_xset_map = Arc::clone(&arc_locked_xset_map);
39
40 match key_str {
41 "xesam:artist" => {
42 // Variant holding a variant that should just be a Vec<&str> I
43 // believe. This is _the recommended_ way to do this by the author.
44 let inner_value = value?.as_iter()?.next()?.as_iter()?.next()?;
45 let artist = inner_value.as_str()?;
46 update_map(arc_locked_xset_map, "artist", artist);
47 }
48 "xesam:title" => {
49 let title = value?.as_iter()?.next()?.as_str()?;
50 update_map(arc_locked_xset_map, "title", title);
51 }
52 _ => (),
53 }
54 }
55 Some(())
56 });
57 true
58 },
59 );
60
61 loop {
62 conn.process(Duration::from_millis(1000))?;
63 }
64 }