87 lines
2.1 KiB
Rust
87 lines
2.1 KiB
Rust
use failure::*;
|
|
|
|
use std::fs::{OpenOptions};
|
|
use std::io::{Read, Write};
|
|
|
|
//use std::sync::Arc;
|
|
use crate::tools;
|
|
use crate::api::schema::*;
|
|
|
|
use crate::section_config::*;
|
|
|
|
use lazy_static::lazy_static;
|
|
|
|
lazy_static!{
|
|
static ref CONFIG: SectionConfig = init();
|
|
}
|
|
|
|
fn init() -> SectionConfig {
|
|
|
|
let plugin = SectionConfigPlugin::new(
|
|
"datastore".to_string(),
|
|
ObjectSchema::new("DataStore properties")
|
|
.required("path", StringSchema::new("Directory name"))
|
|
);
|
|
|
|
let id_schema = StringSchema::new("DataStore ID schema.")
|
|
.min_length(3)
|
|
.into();
|
|
|
|
let mut config = SectionConfig::new(id_schema);
|
|
config.register_plugin(plugin);
|
|
|
|
config
|
|
}
|
|
|
|
const DATASTORE_CFG_FILENAME: &str = "/etc/proxmox-backup/datastore.cfg";
|
|
|
|
pub fn config() -> Result<SectionConfigData, Error> {
|
|
|
|
let mut file = match OpenOptions::new()
|
|
.create(true)
|
|
.read(true)
|
|
.write(true)
|
|
.open(DATASTORE_CFG_FILENAME) {
|
|
Ok(file) => file,
|
|
Err(err) => bail!("Unable to open '{}' - {}",
|
|
DATASTORE_CFG_FILENAME, err),
|
|
};
|
|
|
|
let mut contents = String::new();
|
|
file.read_to_string(&mut contents)?;
|
|
|
|
CONFIG.parse(DATASTORE_CFG_FILENAME, &contents)
|
|
}
|
|
|
|
pub fn save_config(config: &SectionConfigData) -> Result<(), Error> {
|
|
|
|
let raw = CONFIG.write(DATASTORE_CFG_FILENAME, &config)?;
|
|
|
|
let mut file = match OpenOptions::new()
|
|
.create(true)
|
|
.read(true)
|
|
.write(true)
|
|
.open(DATASTORE_CFG_FILENAME) {
|
|
Ok(file) => file,
|
|
Err(err) => bail!("Unable to open '{}' - {}",
|
|
DATASTORE_CFG_FILENAME, err),
|
|
};
|
|
|
|
let mut contents = String::new();
|
|
file.read_to_string(&mut contents)?;
|
|
|
|
//fixme: compute and compare digest
|
|
|
|
tools::file_set_contents(DATASTORE_CFG_FILENAME, raw.as_bytes(), None)?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
// shell completion helper
|
|
pub fn complete_datastore_name() -> Vec<String> {
|
|
match config() {
|
|
Ok(data) => data.sections.iter().map(|(id,_)| id.to_string()).collect(),
|
|
Err(_) => return vec![],
|
|
}
|
|
}
|