use proxmox::api::{ApiHandler, ApiMethod, Router, RpcEnvironment};
use proxmox::api::schema::*;
+use proxmox::tools::fs::CreateOptions;
use crate::api2::types::*;
use crate::backup::*;
("name", false, &DATASTORE_SCHEMA),
("path", false, &StringSchema::new("Directory path. The directory path is created if it does not already exist.").schema()),
],
- )
+ )
).protected(true);
fn create_datastore(
}
let path: PathBuf = param["path"].as_str().unwrap().into();
- let _store = ChunkStore::create(name, path)?;
+ let backup_user = crate::backup::backup_user()?;
+ let _store = ChunkStore::create(
+ name,
+ path,
+ CreateOptions::new()
+ .owner(backup_user.uid)
+ .group(backup_user.gid),
+ )?;
let datastore = json!({
"path": param["path"]
chunk_dir
}
- pub fn create<P: Into<PathBuf>>(name: &str, path: P) -> Result<Self, Error> {
+ pub fn create<P>(name: &str, path: P, options: CreateOptions) -> Result<Self, Error>
+ where
+ P: Into<PathBuf>,
+ {
let base: PathBuf = path.into();
let chunk_dir = Self::chunk_dir(&base);
- let backup_user = crate::backup::backup_user()?;
-
- let options = CreateOptions::new()
- .owner(backup_user.uid)
- .group(backup_user.gid);
-
let default_options = CreateOptions::new();
if let Err(err) = create_path(&base, Some(default_options.clone()), Some(options.clone())) {
let chunk_store = ChunkStore::open("test", &path);
assert!(chunk_store.is_err());
- let chunk_store = ChunkStore::create("test", &path).unwrap();
+ let chunk_store = ChunkStore::create("test", &path, CreateOptions::new()).unwrap();
let (chunk, digest) = super::DataChunkBuilder::new(&[0u8, 1u8]).build().unwrap();
assert!(exists);
- let chunk_store = ChunkStore::create("test", &path);
+ let chunk_store = ChunkStore::create("test", &path, CreateOptions::new());
assert!(chunk_store.is_err());
if let Err(_e) = std::fs::remove_dir_all(".testdir") { /* ignore */ }