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 spotify_match_map = arc_locked_xset_map.clone();
  28     let _ = proxy.match_signal(
  29         move |pc: PropertiesPropertiesChanged, _: &Connection, _: &Message| {
  30             pc.changed_properties["Metadata"]
  31                 .0
  32                 .as_iter()
  33                 .and_then(|mut iter| {
  34                     // Iterating over a RefArg goes key, value, key, value... Insane honestly.
  35                     while let Some(key) = iter.next() {
  36                         let key_str = key.as_str()?;
  37                         let value = iter.next();
  38
  39                         match key_str {
  40                             "xesam:artist" => {
  41                                 // Variant holding a variant that should just be a Vec<&str> I
  42                                 // believe. This is _the recommended_ way to do this by the author.
  43                                 let inner_value = value?.as_iter()?.next()?.as_iter()?.next()?;
  44                                 let artist = inner_value.as_str()?;
  45                                 update_map(spotify_match_map.clone(), "artist", artist);
  46                             }
  47                             "xesam:title" => {
  48                                 let title = value?.as_iter()?.next()?.as_str()?;
  49                                 update_map(spotify_match_map.clone(), "title", title);
  50                             }
  51                             _ => (),
  52                         }
  53                     }
  54                     Some(())
  55                 });
  56             true
  57         },
  58     );
  59
  60     loop {
  61         conn.process(Duration::from_millis(1000))?;
  62     }
  63 }