konarr 0.5.1

Konarr
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

//! # Server Settings from Config
use super::{ServerSettings, keys::Setting};
use crate::Config;
use geekorm::{Connection, prelude::*};

impl ServerSettings {
    /// The server configuration is the source of truth as the
    /// user can override the settings in the config file but we
    /// need to make sure that the settings are in the database.
    ///
    /// When it gets to this point, the database settings should
    /// already be added so this is just a matter of updating the
    /// settings.
    pub async fn load_config(
        connection: &Connection<'_>,
        config: &Config,
    ) -> Result<(), crate::KonarrError> {
        log::debug!("Loading server settings from config");

        // Server settings
        if let Ok(url) = config.server.url() {
            log::debug!("Server URL: {}", url);
            ServerSettings::update_setting(connection, &Setting::ServerUrl, url.to_string())
                .await?;
        }
        // Data path
        if let Some(path) = config.data_path().ok() {
            log::debug!("Server Data Path: {}", path.canonicalize()?.display());
            if !path.exists() {
                log::debug!("Creating data path: {}", path.display());
                tokio::fs::create_dir_all(&path).await?;
            }

            ServerSettings::update_setting(
                connection,
                &Setting::ServerData,
                config.data_path()?.canonicalize()?.display().to_string(),
            )
            .await?;
        }

        if let Some(path) = config.server.frontend.canonicalize().ok() {
            if path.exists() && path.is_dir() {
                log::debug!("Server Frontend Path: {}", path.display());
                // Frontend setting
                ServerSettings::update_setting(
                    connection,
                    &Setting::ServerFrontendPath,
                    path.display().to_string(),
                )
                .await?;
            } else {
                log::warn!(
                    "Frontend path does not exist or is not a directory: {}",
                    path.display()
                );
            }
        }

        Ok(())
    }

    async fn update_setting(
        connection: &Connection<'_>,
        setting: &Setting,
        value: impl Into<String>,
    ) -> Result<(), crate::KonarrError> {
        let value = value.into();
        log::debug!("Updating setting: {:?}", setting);

        let mut dbsetting = ServerSettings::fetch_by_name(connection, setting).await?;

        if dbsetting.value != value {
            log::debug!("Updating setting: {:?}", setting);
            dbsetting.value = value;
            dbsetting.update(connection).await?;
        } else {
            log::debug!("Setting already up to date: {:?}", setting);
        }

        Ok(())
    }
}