use std::collections::BTreeMap;
use std::sync::RwLock;
pub struct SecretStore {
path: String,
values: RwLock<BTreeMap<String, String>>,
}
impl SecretStore {
pub fn load(path: &str) -> Self {
let values = std::fs::read_to_string(path)
.ok()
.and_then(|raw| toml::from_str::<BTreeMap<String, String>>(&raw).ok())
.unwrap_or_default();
Self {
path: path.to_string(),
values: RwLock::new(values),
}
}
pub fn resolve(&self, env_name: &str) -> Option<String> {
if let Some(v) = self.values.read().unwrap().get(env_name) {
if !v.is_empty() {
return Some(v.clone());
}
}
std::env::var(env_name).ok().filter(|v| !v.is_empty())
}
pub fn source(&self, env_name: &str) -> &'static str {
let in_store = self
.values
.read()
.unwrap()
.get(env_name)
.map(|v| !v.is_empty())
.unwrap_or(false);
if in_store {
"store"
} else if std::env::var(env_name)
.ok()
.filter(|v| !v.is_empty())
.is_some()
{
"env"
} else {
"missing"
}
}
pub fn set(&self, env_name: &str, value: &str) -> anyhow::Result<()> {
self.values
.write()
.unwrap()
.insert(env_name.to_string(), value.to_string());
self.persist()
}
pub fn clear(&self, env_name: &str) -> anyhow::Result<()> {
self.values.write().unwrap().remove(env_name);
self.persist()
}
fn persist(&self) -> anyhow::Result<()> {
let data = {
let map = self.values.read().unwrap();
toml::to_string(&*map)?
};
let p = std::path::Path::new(&self.path);
if let Some(dir) = p.parent() {
std::fs::create_dir_all(dir).ok();
}
let tmp = p.with_extension("toml.tmp");
std::fs::write(&tmp, data.as_bytes())?;
std::fs::rename(&tmp, p)?;
#[cfg(unix)]
{
use std::os::unix::fs::PermissionsExt;
let _ = std::fs::set_permissions(p, std::fs::Permissions::from_mode(0o600));
}
Ok(())
}
}