randpaper 0.2.3

use crate::traits::Backend;
use anyhow::Context;
use async_trait::async_trait;
use serde::Deserialize;
use tokio::process::Command;

#[derive(Deserialize)]
struct MonitorList {
    monitors: Vec<Monitor>,
}
#[derive(Deserialize)]
struct Monitor {
    name: String,
}

/// A backend implementation for the `MangoWM` compositor.
///
/// Uses the `mmsg get all-monitors` command to list active output names.
pub struct MangoBackend;

#[async_trait]
impl Backend for MangoBackend {
    /// Retrieves a list of currently active monitor names via `mmsg`.
    ///
    /// Executes `mmsg get all-monitors` which prints one output name per line.
    ///
    /// # Errors
    ///
    /// Returns an error if:
    /// * The `mmsg` binary is not found or fails to execute.
    /// * The output is not valid UTF-8.
    /// * No outputs are returned.
    async fn get_active_monitors(&self) -> anyhow::Result<Vec<String>> {
        let out = Command::new("mmsg")
            .args(["get", "all-monitors"])
            .output()
            .await
            .context("failed to execute `mmsg`. Is MangoWM running?")?;

        let stdout = String::from_utf8(out.stdout).context("mmsg output was not valid UTF-8")?;

        let list: MonitorList =
            serde_json::from_str(&stdout).context("failed to parse mmsg JSON output")?;

        let monitors: Vec<String> = list.monitors.into_iter().map(|m| m.name).collect();

        if monitors.is_empty() {
            anyhow::bail!("mmsg returned no active outputs");
        }

        Ok(monitors)
    }
}