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
use std::path::Path;
use crate::config::RepositoryConfig;
use crate::core::db::merkle_node::{DEFAULT_MERKLE_NODE_BACKEND, MerkleNodeBackend};
use crate::error::OxenError;
use crate::model::LocalRepository;
use crate::storage::StorageConfig;
use crate::util;
pub fn init(path: &Path) -> Result<LocalRepository, OxenError> {
let hidden_dir = util::fs::oxen_hidden_dir(path);
if hidden_dir.exists() {
let err = format!("Oxen repository already exists: {path:?}");
return Err(OxenError::basic_str(err));
}
// Cleanup the .oxen dir if init fails
match init_with_version_default(path) {
Ok(result) => Ok(result),
Err(error) => {
util::fs::remove_dir_all(hidden_dir)?;
Err(error)
}
}
}
// default storage backend is local
pub fn init_with_version_default(path: &Path) -> Result<LocalRepository, OxenError> {
let hidden_dir = util::fs::oxen_hidden_dir(path);
util::fs::create_dir_all(hidden_dir)?;
if util::fs::config_filepath(path).try_exists()? {
let err = format!("Oxen repository already exists: {path:?}");
return Err(OxenError::basic_str(err));
}
let config = RepositoryConfig::default();
let repo = LocalRepository::new(path, config)?;
repo.save()?;
Ok(repo)
}
pub async fn init_with_version_and_storage_config(
path: &Path,
storage_config: Option<StorageConfig>,
merkle_backend: Option<MerkleNodeBackend>,
) -> Result<LocalRepository, OxenError> {
let hidden_dir = util::fs::oxen_hidden_dir(path);
util::fs::create_dir_all(hidden_dir)?;
if util::fs::config_filepath(path).try_exists()? {
let err = format!("Oxen repository already exists: {path:?}");
return Err(OxenError::basic_str(err));
}
let config = RepositoryConfig {
storage: storage_config,
merkle_node_backend: Some(merkle_backend.unwrap_or(DEFAULT_MERKLE_NODE_BACKEND)),
..Default::default()
};
let repo = LocalRepository::new(path, config)?;
repo.save()?;
let version_store = repo.version_store();
version_store.init().await?;
Ok(repo)
}