use config::builder::DefaultState;
use config::{Config, ConfigBuilder, Environment};
use lazy_static::{__Deref, lazy_static};
use serde::{Deserialize, Serialize};
use std::path::Path;
use std::sync::RwLock;
use super::error::Result;
use super::types::LogLevel;
lazy_static! {
pub static ref BUILDER: RwLock<ConfigBuilder<DefaultState>> = RwLock::new(Config::builder());
}
#[derive(Debug, Serialize, Deserialize)]
pub struct AppConfig {
pub debug: bool,
pub log_level: LogLevel,
pub cache_file: String,
}
impl AppConfig {
pub fn init(default_config: Option<&str>) -> Result<()> {
let mut builder = Config::builder();
if let Some(config_contents) = default_config {
builder = builder.add_source(config::File::from_str(
config_contents,
config::FileFormat::Toml,
));
}
builder = builder.add_source(Environment::with_prefix("CODEINPUT"));
{
let mut w = BUILDER.write()?;
*w = builder;
}
Ok(())
}
pub fn merge_args(args: clap::ArgMatches) -> Result<()> {
if args.contains_id("debug") {
let value: &bool = args.get_one("debug").unwrap_or(&false);
AppConfig::set("debug", &value.to_string())?;
}
if args.contains_id("log_level") {
let value: &LogLevel = args.get_one("log_level").unwrap_or(&LogLevel::Info);
AppConfig::set("log_level", &value.to_string())?;
}
Ok(())
}
pub fn merge_config(config_file: Option<&Path>) -> Result<()> {
if let Some(config_file_path) = config_file {
{
let mut w = BUILDER.write().unwrap();
*w = w.clone().add_source(config::File::with_name(
config_file_path.to_str().unwrap_or(""),
));
}
}
Ok(())
}
pub fn set(key: &str, value: &str) -> Result<()> {
{
let mut w = BUILDER.write().unwrap();
*w = w.clone().set_override(key, value)?;
}
Ok(())
}
pub fn get<'de, T>(key: &'de str) -> Result<T>
where
T: serde::Deserialize<'de>,
{
Ok(BUILDER.read()?.deref().clone().build()?.get::<T>(key)?)
}
pub fn fetch() -> Result<AppConfig> {
let r = BUILDER.read()?;
let config_clone = r.deref().clone().build()?;
let app_config: AppConfig = config_clone.try_into()?;
Ok(app_config)
}
}
impl TryFrom<Config> for AppConfig {
type Error = super::error::Error;
fn try_from(config: Config) -> Result<Self> {
Ok(AppConfig {
debug: config.get_bool("debug")?,
log_level: config.get::<LogLevel>("log_level")?,
cache_file: config.get::<String>("cache_file")?,
})
}
}