randpaper 0.2.3

A customizable wallpaper daemon for per-monitor cycling, one-shot application, and optional theme synchronization for Waybar and terminals.
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
103
104

use crate::cli::Config;
use crate::wallpaper::WallpaperCache;
use anyhow::Context;
use std::time::Duration;
use tokio::process::Command;
use tokio::time::sleep;

/// Attempts to find a compatible binary for `awww`.
///
/// Checks for `awww` first, then `swww` (a common wrapper/alternative).
/// Defaults to "swww" if neither are found.
pub async fn detect_awww_binary() -> String {
    if Command::new("awww").arg("--help").output().await.is_ok() {
        return "awww".to_string();
    }
    if Command::new("swww").arg("--help").output().await.is_ok() {
        return "swww".to_string();
    }
    log::warn!("Neither 'awww' nor 'swww' found. Defaulting to 'awww'.");
    "awww".to_string()
}

/// Checks if the `awww-daemon` is currently intitialized and responding to queries.
async fn awww_ready(awww_bin: &str) -> bool {
    (Command::new(awww_bin).arg("query").status().await).is_ok_and(|st| st.success())
}

/// Ensures the `awww-daemon` is running.
///
/// If the daemon is not responsive, it checks for an existing process via `pgrep`.
/// If no process is found, it spawns a new daemon and waits briefly for it to initialize.
pub async fn ensure_awww_daemon(awww_bin: &str) -> anyhow::Result<()> {
    if awww_ready(awww_bin).await {
        return Ok(());
    }

    let daemon_name = format!("{awww_bin}-daemon");
    let status = Command::new("pgrep")
        .arg("-x")
        .arg(&daemon_name)
        .status()
        .await;

    match status {
        Ok(es) if es.success() => log::info!("{daemon_name} is already running"),
        _ => {
            log::info!("Starting {daemon_name}...");
            Command::new(&daemon_name)
                .stdout(std::process::Stdio::null())
                .stderr(std::process::Stdio::null())
                .spawn()
                .with_context(|| format!("failed to spawn {daemon_name}"))?;

            sleep(Duration::from_millis(500)).await;
        }
    }

    Ok(())
}

/// Sends commands to the `awww` daemon to update wallpapers with transitions.
///
/// This loops through each monitor and calls the `img` command.
/// It uses transition settings (type, step, fps) provided in the `Cli` config.
///
/// # Errors
/// Returns an error if the binary cannot be executed or if `awww` returns a non-zero exit code.
pub async fn apply(
    config: &Config,
    cache: &WallpaperCache,
    monitors: &[String],
    awww_bin: &str,
) -> anyhow::Result<()> {
    let step = config.transition_step.to_string();
    let fps = config.transition_fps.to_string();

    for monitor in monitors {
        let img = cache.pick_random();

        let out = Command::new(awww_bin)
            .arg("img")
            .arg(img)
            .arg("-o")
            .arg(monitor)
            .arg("--transition-type")
            .arg(&config.transition_type)
            .arg("--transition-step")
            .arg(&step)
            .arg("--transition-fps")
            .arg(&fps)
            .output()
            .await
            .with_context(|| format!("failed to run {awww_bin}"))?;

        if !out.status.success() {
            anyhow::bail!(
                "{awww_bin} failed: {}",
                String::from_utf8_lossy(&out.stderr)
            );
        }
    }

    Ok(())
}