rescrobbled 0.3.3

MPRIS music scrobbler daemon
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

// Copyright (C) 2021 Koen Bolhuis
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program.  If not, see <https://www.gnu.org/licenses/>.

use std::thread;
use std::time::Duration;

use mpris::{PlaybackStatus, Player, PlayerFinder};

use crate::config::Config;

const INIT_WAIT_TIME: Duration = Duration::from_secs(1);

const BUS_NAME_PREFIX: &str = "org.mpris.MediaPlayer2.";

/// Determine if a player is running and actually playing music.
pub fn is_active(player: &Player) -> bool {
    if !player.is_running() {
        return false;
    }

    match player.get_playback_status() {
        Ok(PlaybackStatus::Playing) => true,
        _ => false,
    }
}

/// Get the unique part of the DBUS bus name, ie. the part after `org.mpris.MediaPlayer2.`.
fn bus_name<'p>(player: &'p Player) -> &'p str {
    player
        .bus_name()
        .as_cstr()
        .to_str()
        .unwrap_or("")
        .trim_start_matches(BUS_NAME_PREFIX)
        .split('.') // Remove the instance part of the unique name
        .next()
        .unwrap() // Unwrap is fine; split returns the whole string if no '.' present
}

fn is_whitelisted(config: &Config, player: &Player) -> bool {
    if let Some(ref whitelist) = config.player_whitelist {
        if !whitelist.is_empty() {
            return whitelist.contains(player.identity()) || whitelist.contains(bus_name(player));
        }
    }
    true
}

/// Wait for any (whitelisted) player to become active again.
pub fn wait_for_player<'f>(config: &Config, finder: &'f PlayerFinder) -> Player<'f> {
    loop {
        let players = match finder.find_all() {
            Ok(players) => players,
            _ => {
                thread::sleep(INIT_WAIT_TIME);
                continue;
            }
        };

        for player in players {
            if is_active(&player) && is_whitelisted(config, &player) {
                return player;
            }
        }

        thread::sleep(INIT_WAIT_TIME);
    }
}