cutler 0.19.7

Powerful, declarative settings management for your Mac, with speed.
Documentation 
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

use anyhow::{Context, Result, bail};
use reqwest::Client;
use tokio::fs;
use tokio::sync::OnceCell;

use crate::config::LoadedConfig;
use crate::config::path::get_config_path;
use crate::log_info;

/// Manages fetching and storing the remote config.
#[derive(Debug, Clone)]
pub struct RemoteConfigManager {
    url: String,
    config: OnceCell<String>,
}

impl RemoteConfigManager {
    /// Create a new `RemoteConfigManager` with a Remote struct.
    #[must_use]
    pub const fn new(url: String) -> Self {
        Self {
            url,
            config: OnceCell::const_new(),
        }
    }

    /// Fetch the remote config file as TOML, only once per instance.
    pub async fn fetch(&self) -> Result<()> {
        self.config
            .get_or_try_init(|| async {
                log_info!("Fetching remote config from {}", self.url);
                let client = Client::builder()
                    .user_agent("cutler-remote-config")
                    .build()?;
                let resp =
                    client.get(&self.url).send().await.with_context(|| {
                        format!("Failed to fetch remote config from {}", self.url)
                    })?;

                if !resp.status().is_success() {
                    bail!("Failed to fetch remote config: HTTP {}", resp.status());
                }

                let text = resp.text().await?;

                toml::from_str::<LoadedConfig>(&text)
                    .with_context(|| format!("Invalid TOML config fetched from {}", self.url))?;

                Ok(text)
            })
            .await?;
        Ok(())
    }

    /// Save the fetched remote config to the given path.
    pub async fn save(&self) -> Result<()> {
        let config = self.get()?;
        let config_path = get_config_path();

        fs::create_dir_all(
            config_path
                .parent()
                .with_context(|| "Failed to initialize config path for remote sync.".to_string())?,
        )
        .await?;

        fs::write(config_path, config).await?;

        log_info!("Successfully saved remote config to destination.");
        Ok(())
    }

    /// Get a reference to the fetched remote config, if available.
    pub fn get(&self) -> Result<&String> {
        let config = self
            .config
            .get()
            .ok_or_else(|| anyhow::anyhow!("Remote config not fetched yet"))?;

        Ok(config)
    }

    /// Get a parsed version of the output of .`get()` as serde-based Config.
    pub fn get_parsed(&self) -> Result<LoadedConfig> {
        let config_str = self.get()?;
        let config = toml::from_str::<LoadedConfig>(config_str)?;
        Ok(config)
    }
}