config.rs 84.1%

190 of 226 lines run, 38 of 60 functions · run #302 on main · run missed

//! Layered configuration: defaults, the user file, the repository file.

use super::*;

/// Effective settings: defaults, then the user file (`~/.config/oxy/config.toml`,
/// spec §19), then the repository file (`.oxy/config`). Both files are
/// `key = "value"` lines. `save` writes only the repository layer.
#[derive(Clone, Debug, PartialEq, Eq)]
pub struct Config {
    /// Keys set in the repository file (or via `set`), written by `save`.
    repo_layer: BTreeMap<String, String>,
    pub author_name: String,
    pub author_email: String,
    /// The KeyId of the author's identity, once `create_identity` has run.
    pub author_key: Option<KeyId>,
    /// `author.signer` (or `$OXY_SIGNER`): the key that signs and seals in
    /// place of `author.key`, whose identity lists it as a delegate. An
    /// agent sets it to its own key, so its changes carry the human as
    /// author and the agent's signature (spec §14.2, agent workflows §2).
    pub signer_key: Option<KeyId>,
    /// `core.sign`: sign every change at commit (`true`) or leave signing to
    /// push-time seals (`false`, the spec default).
    pub sign_changes: bool,
    pub bookmark: String,
    /// `remote.<name>.url`.
    pub remotes: BTreeMap<String, String>,
    /// `remote.<name>.token`: bearer token for HTTP pushes.
    pub remote_tokens: BTreeMap<String, String>,
    /// `remote.<name>.ca`: PEM file of extra roots to trust for that remote.
    pub remote_cas: BTreeMap<String, String>,
    /// `core.remote`: the remote `pull`, `fetch` and `push` use when none is
    /// named, for a repository whose remotes include no `origin`.
    pub default_remote: Option<String>,
    /// `git.claim`: a Git import authors the commits whose Git author email
    /// is this repository's identity's with its key (oxygen#97).
    pub git_claim: bool,
    /// `core.op-retention`: days for which operations keep their states reachable (spec §12.1, §21).
    pub op_retention_days: u64,
    /// `core.gc-grace`: days an unreachable object survives, protecting concurrent writers (spec §21).
    pub gc_grace_days: u64,
    /// `core.snapshot-retention`: days for which past operations keep their
    /// working copies reachable (oxygen#98); each workspace's current one is
    /// always kept. A file only ever in a working copy goes with it.
    pub snapshot_retention_days: u64,
    /// `snapshot.max-new-file-size`: a new, untracked file larger than this
    /// is left out of working-copy snapshots and named instead (oxygen#98);
    /// 0 takes in files of any size.
    pub max_new_file: u64,
    /// `core.checkpoint-interval`: changes between automatic checkpoints (spec §11).
    pub checkpoint_interval: u64,
    /// `push.batch-bytes`: about how many bytes of changes and their texts
    /// one request of a long push carries (spec §16.3).
    pub push_batch_bytes: u64,
    /// `filter.max-blob`: blobs larger than this many bytes are fetched lazily (spec §17).
    pub max_blob: Option<u64>,
    /// `filter.paths`: only these subtrees are materialized (spec §17); empty means everything.
    pub sparse_paths: Vec<String>,
    /// `hooks.semantic-deps`: run the semantic-deps hook at commit (spec §20).
    pub semantic_deps: bool,
    /// `revset.<name>`: a saved revset, used as `name()`.
    pub revsets: BTreeMap<String, String>,
    /// `storage.url`: the store the repository's objects and operation
    /// head are kept on (`dir://`, `s3://`, …) instead of `.oxy/objects`
    /// (oxygen#68).
    pub storage_url: Option<String>,
    /// `storage.cache`: the most the local cache in front of that store
    /// holds, in bytes.
    pub storage_cache: u64,
}

impl Config {
    /// Whether the repository's own file sets `key` (as against the user
    /// config or a default).
    pub fn is_repo_set(&self, key: &str) -> bool {
        self.repo_layer.contains_key(key)
    }

    pub(super) fn default_for_user() -> Config {
        let user = std::env::var("USER").unwrap_or_else(|_| "unknown".into());
        Config {
            repo_layer: BTreeMap::new(),
            author_name: std::env::var("OXY_AUTHOR_NAME").unwrap_or_else(|_| user.clone()),
            author_email: std::env::var("OXY_AUTHOR_EMAIL")
                .unwrap_or_else(|_| format!("{user}@localhost")),
            author_key: None,
            signer_key: std::env::var("OXY_SIGNER")
                .ok()
                .and_then(|v| KeyId::from_hex(&v)),
            sign_changes: false,
            bookmark: "main".into(),
            remotes: BTreeMap::new(),
            remote_tokens: BTreeMap::new(),
            remote_cas: BTreeMap::new(),
            default_remote: None,
            git_claim: false,
            op_retention_days: 90,
            gc_grace_days: 14,
            max_new_file: 100 << 20,
            snapshot_retention_days: 7,
            checkpoint_interval: 256,
            push_batch_bytes: 256 << 20,
            max_blob: None,
            sparse_paths: Vec::new(),
            semantic_deps: false,
            revsets: BTreeMap::new(),
            storage_url: None,
            storage_cache: DEFAULT_STORAGE_CACHE,
        }
    }

    /// Set a key in the repository layer, as `oxy config` does.
    pub fn set(&mut self, key: &str, value: &str) -> Result<()> {
        self.apply(key, value)?;
        if value.is_empty() {
            self.repo_layer.remove(key);
        } else {
            self.repo_layer.insert(key.to_string(), value.to_string());
        }
        Ok(())
    }

    /// Set a key in the user file without touching any repository.
    pub fn set_user(user_path: &Path, key: &str, value: &str) -> Result<()> {
        Config::default_for_user().apply(key, value)?;
        let mut entries = read_config_file(user_path)?;
        if value.is_empty() {
            entries.remove(key);
        } else {
            entries.insert(key.to_string(), value.to_string());
        }
        if let Some(parent) = user_path.parent() {
            fs::create_dir_all(parent)?;
        }
        write_config_file(user_path, &entries)
    }

    /// Apply a key to the effective values.
    pub(super) fn apply(&mut self, key: &str, value: &str) -> Result<()> {
        match key {
            "author.name" => self.author_name = value.into(),
            "author.email" => self.author_email = value.into(),
            "author.key" => {
                self.author_key = if value.is_empty() {
                    None
                } else {
                    Some(KeyId::from_hex(value).ok_or_else(|| {
                        RepoError::Msg("author.key must be a 64-character hex KeyId".into())
                    })?)
                }
            }
            "author.signer" => {
                self.signer_key = if value.is_empty() {
                    None
                } else {
                    Some(KeyId::from_hex(value).ok_or_else(|| {
                        RepoError::Msg("author.signer must be a 64-character hex KeyId".into())
                    })?)
                }
            }
            "core.sign" => {
                self.sign_changes = match value {
                    "change" => true,
                    "seal" => false,
                    _ => return fail("core.sign must be \"change\" or \"seal\""),
                }
            }
            "workspace.bookmark" => self.bookmark = value.into(),
            // Read by the credential store from the user file.
            "auth.helper" => {}
            "core.op-retention" => self.op_retention_days = parse_days(value)?,
            "core.gc-grace" => self.gc_grace_days = parse_days(value)?,
            "snapshot.max-new-file-size" => self.max_new_file = parse_size(value)?,
            "core.snapshot-retention" => self.snapshot_retention_days = parse_days(value)?,
            "filter.max-blob" => {
                self.max_blob = if value.is_empty() {
                    None
                } else {
                    Some(parse_size(value)?)
                }
            }
            "storage.url" => {
                self.storage_url = (!value.is_empty()).then(|| value.to_string());
            }
            "storage.cache" => {
                self.storage_cache = if value.is_empty() {
                    DEFAULT_STORAGE_CACHE
                } else {
                    parse_size(value)?
                }
            }
            "core.remote" => {
                self.default_remote = (!value.is_empty()).then(|| value.to_string());
            }
            "hooks.semantic-deps" => self.semantic_deps = matches!(value, "true" | "1" | "yes"),
            "git.claim" => self.git_claim = matches!(value, "true" | "1" | "yes"),
            "filter.paths" => {
                self.sparse_paths = value
                    .split(',')
                    .map(|p| {
                        p.trim()
                            .trim_start_matches("./")
                            .trim_matches('/')
                            .to_string()
                    })
                    .filter(|p| !p.is_empty())
                    .collect();
            }
            "core.checkpoint-interval" => {
                self.checkpoint_interval = value
                    .parse()
                    .map_err(|_| RepoError::Msg(format!("expected a number, got {value:?}")))?;
            }
            "push.batch-bytes" => {
                self.push_batch_bytes = value.parse().ok().filter(|n| *n > 0).ok_or_else(|| {
                    RepoError::Msg(format!("expected a number of bytes, got {value:?}"))
                })?;
            }
            k if k.starts_with("remote.") => {
                let rest = &k["remote.".len()..];
                let Some((name, field)) = rest.rsplit_once('.') else {
                    return fail(format!("unknown configuration key {key:?}"));
                };
                if name.is_empty() || name.contains('/') {
                    return fail(format!("invalid remote name in {key:?}"));
                }
                let map = match field {
                    "url" => &mut self.remotes,
                    "token" => &mut self.remote_tokens,
                    "ca" => &mut self.remote_cas,
                    _ => return fail(format!("unknown configuration key {key:?}")),
                };
                if value.is_empty() {
                    map.remove(name);
                    if field == "url" {
                        self.remote_tokens.remove(name);
                        self.remote_cas.remove(name);
                    }
                } else {
                    map.insert(name.to_string(), value.into());
                }
            }
            k if k.starts_with("revset.") => {
                let name = &k["revset.".len()..];
                if name.is_empty()
                    || !name
                        .chars()
                        .all(|c| c.is_ascii_alphanumeric() || c == '_' || c == '-')
                {
                    return fail(format!(
                        "a revset's name is letters, digits, _ and -: {key:?}"
                    ));
                }
                if value.is_empty() {
                    self.revsets.remove(name);
                } else {
                    crate::revset::parse(value)
                        .map_err(|e| RepoError::Msg(format!("{key} = {value:?}: {e}")))?;
                    self.revsets.insert(name.to_string(), value.into());
                }
            }
            _ => return fail(format!("unknown configuration key {key:?}")),
        }
        Ok(())
    }

    /// Defaults, then the user file if it exists, then the repository file.
    pub(super) fn load(user_path: Option<&Path>, repo_path: &Path) -> Result<Config> {
        let mut c = Config::default_for_user();
        if let Some(u) = user_path {
            for (k, v) in read_config_file(u)? {
                let _ = c.apply(&k, &v);
            }
        }
        for (k, v) in read_config_file(repo_path)? {
            if c.apply(&k, &v).is_ok() {
                c.repo_layer.insert(k, v);
            }
        }
        Ok(c)
    }

    pub(super) fn save(&self, path: &Path) -> Result<()> {
        write_config_file(path, &self.repo_layer)
    }

    /// Keys explicitly set for this repository.
    pub fn repo_layer(&self) -> &BTreeMap<String, String> {
        &self.repo_layer
    }
}

/// A byte count with an optional `K`, `M`, or `G` suffix (binary units).
/// `storage.cache` when unset: 2 GiB.
pub const DEFAULT_STORAGE_CACHE: u64 = 2 << 30;

pub fn parse_size(v: &str) -> Result<u64> {
    let v = v.trim();
    let (num, mult) = match v.chars().last() {
        Some('K' | 'k') => (&v[..v.len() - 1], 1u64 << 10),
        Some('M' | 'm') => (&v[..v.len() - 1], 1u64 << 20),
        Some('G' | 'g') => (&v[..v.len() - 1], 1u64 << 30),
        _ => (v, 1),
    };
    let n: u64 = num
        .trim()
        .parse()
        .map_err(|_| RepoError::Msg(format!("expected a size like 1M, got {v:?}")))?;
    Ok(n * mult)
}

/// A count of days, optionally suffixed `d`.
fn parse_days(v: &str) -> Result<u64> {
    v.trim_end_matches('d')
        .parse()
        .map_err(|_| RepoError::Msg(format!("expected a number of days, got {v:?}")))
}

/// Read `key = "value"` lines; a missing file is empty.
pub fn read_config_file(path: &Path) -> Result<BTreeMap<String, String>> {
    let text = match fs::read_to_string(path) {
        Ok(t) => t,
        Err(e) if e.kind() == std::io::ErrorKind::NotFound => return Ok(BTreeMap::new()),
        Err(e) => return Err(e.into()),
    };
    let mut out = BTreeMap::new();
    for line in text.lines() {
        let line = line.trim();
        if line.is_empty() || line.starts_with('#') {
            continue;
        }
        let Some((k, v)) = line.split_once('=') else {
            continue;
        };
        out.insert(k.trim().to_string(), v.trim().trim_matches('"').to_string());
    }
    Ok(out)
}

fn write_config_file(path: &Path, entries: &BTreeMap<String, String>) -> Result<()> {
    let text: String = entries
        .iter()
        .map(|(k, v)| format!("{k} = \"{v}\"\n"))
        .collect();
    write_atomic(path, text.as_bytes())
}

`/`	Search
`g` `c`	Code
`g` `h`	History
`g` `b`	Bookmarks
`g` `t`	Trust
`y`	Permalink to this state (files and trees)
`?`	This sheet

1		//! Layered configuration: defaults, the user file, the repository file.
2
3		use super::*;
4
5		/// Effective settings: defaults, then the user file (`~/.config/oxy/config.toml`,
6		/// spec §19), then the repository file (`.oxy/config`). Both files are
7		/// `key = "value"` lines. `save` writes only the repository layer.
8		#[derive(Clone, Debug, PartialEq, Eq)]
9		pub struct Config {
10		/// Keys set in the repository file (or via `set`), written by `save`.
11		repo_layer: BTreeMap<String, String>,
12		pub author_name: String,
13		pub author_email: String,
14		/// The KeyId of the author's identity, once `create_identity` has run.
15		pub author_key: Option<KeyId>,
16		/// `author.signer` (or `$OXY_SIGNER`): the key that signs and seals in
17		/// place of `author.key`, whose identity lists it as a delegate. An
18		/// agent sets it to its own key, so its changes carry the human as
19		/// author and the agent's signature (spec §14.2, agent workflows §2).
20		pub signer_key: Option<KeyId>,
21		/// `core.sign`: sign every change at commit (`true`) or leave signing to
22		/// push-time seals (`false`, the spec default).
23		pub sign_changes: bool,
24		pub bookmark: String,
25		/// `remote.<name>.url`.
26		pub remotes: BTreeMap<String, String>,
27		/// `remote.<name>.token`: bearer token for HTTP pushes.
28		pub remote_tokens: BTreeMap<String, String>,
29		/// `remote.<name>.ca`: PEM file of extra roots to trust for that remote.
30		pub remote_cas: BTreeMap<String, String>,
31		/// `core.remote`: the remote `pull`, `fetch` and `push` use when none is
32		/// named, for a repository whose remotes include no `origin`.
33		pub default_remote: Option<String>,
34		/// `git.claim`: a Git import authors the commits whose Git author email
35		/// is this repository's identity's with its key (oxygen#97).
36		pub git_claim: bool,
37		/// `core.op-retention`: days for which operations keep their states reachable (spec §12.1, §21).
38		pub op_retention_days: u64,
39		/// `core.gc-grace`: days an unreachable object survives, protecting concurrent writers (spec §21).
40		pub gc_grace_days: u64,
41		/// `core.snapshot-retention`: days for which past operations keep their
42		/// working copies reachable (oxygen#98); each workspace's current one is
43		/// always kept. A file only ever in a working copy goes with it.
44		pub snapshot_retention_days: u64,
45		/// `snapshot.max-new-file-size`: a new, untracked file larger than this
46		/// is left out of working-copy snapshots and named instead (oxygen#98);
47		/// 0 takes in files of any size.
48		pub max_new_file: u64,
49		/// `core.checkpoint-interval`: changes between automatic checkpoints (spec §11).
50		pub checkpoint_interval: u64,
51		/// `push.batch-bytes`: about how many bytes of changes and their texts
52		/// one request of a long push carries (spec §16.3).
53		pub push_batch_bytes: u64,
54		/// `filter.max-blob`: blobs larger than this many bytes are fetched lazily (spec §17).
55		pub max_blob: Option<u64>,
56		/// `filter.paths`: only these subtrees are materialized (spec §17); empty means everything.
57		pub sparse_paths: Vec<String>,
58		/// `hooks.semantic-deps`: run the semantic-deps hook at commit (spec §20).
59		pub semantic_deps: bool,
60		/// `revset.<name>`: a saved revset, used as `name()`.
61		pub revsets: BTreeMap<String, String>,
62		/// `storage.url`: the store the repository's objects and operation
63		/// head are kept on (`dir://`, `s3://`, …) instead of `.oxy/objects`
64		/// (oxygen#68).
65		pub storage_url: Option<String>,
66		/// `storage.cache`: the most the local cache in front of that store
67		/// holds, in bytes.
68		pub storage_cache: u64,
69		}
70
71		impl Config {
72		/// Whether the repository's own file sets `key` (as against the user
73		/// config or a default).
74	2×	pub fn is_repo_set(&self, key: &str) -> bool {
75	2×	self.repo_layer.contains_key(key)
76	2×	}
77
78	2777×	pub(super) fn default_for_user() -> Config {
79	2777×	let user = std::env::var("USER").unwrap_or_else(\|_\| "unknown".into());
80		Config {
81	2777×	repo_layer: BTreeMap::new(),
82	2777×	author_name: std::env::var("OXY_AUTHOR_NAME").unwrap_or_else(\|_\| user.clone()),
83	2777×	author_email: std::env::var("OXY_AUTHOR_EMAIL")
84	2777×	.unwrap_or_else(\|_\| format!("{user}@localhost")),
85	2777×	author_key: None,
86	2777×	signer_key: std::env::var("OXY_SIGNER")
87	2777×	.ok()
88	2777×	.and_then(\|v\| KeyId::from_hex(&v)),
89		sign_changes: false,
90	2777×	bookmark: "main".into(),
91	2777×	remotes: BTreeMap::new(),
92	2777×	remote_tokens: BTreeMap::new(),
93	2777×	remote_cas: BTreeMap::new(),
94	2777×	default_remote: None,
95		git_claim: false,
96		op_retention_days: 90,
97		gc_grace_days: 14,
98	2777×	max_new_file: 100 << 20,
99		snapshot_retention_days: 7,
100		checkpoint_interval: 256,
101	2777×	push_batch_bytes: 256 << 20,
102	2777×	max_blob: None,
103	2777×	sparse_paths: Vec::new(),
104		semantic_deps: false,
105	2777×	revsets: BTreeMap::new(),
106	2777×	storage_url: None,
107		storage_cache: DEFAULT_STORAGE_CACHE,
108		}
109	2777×	}
110
111		/// Set a key in the repository layer, as `oxy config` does.
112	476×	pub fn set(&mut self, key: &str, value: &str) -> Result<()> {
113	476×	self.apply(key, value)?;
114	476×	if value.is_empty() {
115	4×	self.repo_layer.remove(key);
116	472×	} else {
117	472×	self.repo_layer.insert(key.to_string(), value.to_string());
118	472×	}
119	476×	Ok(())
120	476×	}
121
122		/// Set a key in the user file without touching any repository.
123	101×	pub fn set_user(user_path: &Path, key: &str, value: &str) -> Result<()> {
124	101×	Config::default_for_user().apply(key, value)?;
125	100×	let mut entries = read_config_file(user_path)?;
126	100×	if value.is_empty() {
127	0×	entries.remove(key);
128	100×	} else {
129	100×	entries.insert(key.to_string(), value.to_string());
130	100×	}
131	100×	if let Some(parent) = user_path.parent() {
132	100×	fs::create_dir_all(parent)?;
133	0×	}
134	100×	write_config_file(user_path, &entries)
135	101×	}
136
137		/// Apply a key to the effective values.
138	1575×	pub(super) fn apply(&mut self, key: &str, value: &str) -> Result<()> {
139	3×	match key {
140	1575×	"author.name" => self.author_name = value.into(),
141	1312×	"author.email" => self.author_email = value.into(),
142	1049×	"author.key" => {
143	265×	self.author_key = if value.is_empty() {
144	0×	None
145		} else {
146	265×	Some(KeyId::from_hex(value).ok_or_else(\|\| {
147	0×	RepoError::Msg("author.key must be a 64-character hex KeyId".into())
148	0×	})?)
149		}
150		}
151	784×	"author.signer" => {
152	5×	self.signer_key = if value.is_empty() {
153	0×	None
154		} else {
155	5×	Some(KeyId::from_hex(value).ok_or_else(\|\| {
156	0×	RepoError::Msg("author.signer must be a 64-character hex KeyId".into())
157	0×	})?)
158		}
159		}
160	779×	"core.sign" => {
161	87×	self.sign_changes = match value {
162	87×	"change" => true,
163	7×	"seal" => false,
164	0×	_ => return fail("core.sign must be \"change\" or \"seal\""),
165		}
166		}
167	692×	"workspace.bookmark" => self.bookmark = value.into(),
168		// Read by the credential store from the user file.
169	688×	"auth.helper" => {}
170	688×	"core.op-retention" => self.op_retention_days = parse_days(value)?,
171	676×	"core.gc-grace" => self.gc_grace_days = parse_days(value)?,
172	676×	"snapshot.max-new-file-size" => self.max_new_file = parse_size(value)?,
173	676×	"core.snapshot-retention" => self.snapshot_retention_days = parse_days(value)?,
174	676×	"filter.max-blob" => {
175	5×	self.max_blob = if value.is_empty() {
176	0×	None
177		} else {
178	5×	Some(parse_size(value)?)
179		}
180		}
181	671×	"storage.url" => {
182	5×	self.storage_url = (!value.is_empty()).then(\|\| value.to_string());
183		}
184	666×	"storage.cache" => {
185	0×	self.storage_cache = if value.is_empty() {
186	0×	DEFAULT_STORAGE_CACHE
187		} else {
188	0×	parse_size(value)?
189		}
190		}
191	666×	"core.remote" => {
192	1×	self.default_remote = (!value.is_empty()).then(\|\| value.to_string());
193		}
194	665×	"hooks.semantic-deps" => self.semantic_deps = matches!(value, "true" \| "1" \| "yes"),
195	664×	"git.claim" => self.git_claim = matches!(value, "true" \| "1" \| "yes"),
196	662×	"filter.paths" => {
197	3×	self.sparse_paths = value
198	3×	.split(',')
199	4×	.map(\|p\| {
200	4×	p.trim()
201	4×	.trim_start_matches("./")
202	4×	.trim_matches('/')
203	4×	.to_string()
204	4×	})
205	4×	.filter(\|p\| !p.is_empty())
206	3×	.collect();
207		}
208	659×	"core.checkpoint-interval" => {
209	3×	self.checkpoint_interval = value
210	3×	.parse()
211	3×	.map_err(\|_\| RepoError::Msg(format!("expected a number, got {value:?}")))?;
212		}
213	656×	"push.batch-bytes" => {
214	1×	self.push_batch_bytes = value.parse().ok().filter(\|n\| *n > 0).ok_or_else(\|\| {
215	0×	RepoError::Msg(format!("expected a number of bytes, got {value:?}"))
216	0×	})?;
217		}
218	655×	k if k.starts_with("remote.") => {
219	652×	let rest = &k["remote.".len()..];
220	652×	let Some((name, field)) = rest.rsplit_once('.') else {
221	0×	return fail(format!("unknown configuration key {key:?}"));
222		};
223	652×	if name.is_empty() \|\| name.contains('/') {
224	0×	return fail(format!("invalid remote name in {key:?}"));
225	652×	}
226	652×	let map = match field {
227	652×	"url" => &mut self.remotes,
228	14×	"token" => &mut self.remote_tokens,
229	4×	"ca" => &mut self.remote_cas,
230	0×	_ => return fail(format!("unknown configuration key {key:?}")),
231		};
232	652×	if value.is_empty() {
233	4×	map.remove(name);
234	4×	if field == "url" {
235	3×	self.remote_tokens.remove(name);
236	3×	self.remote_cas.remove(name);
237	3×	}
238	648×	} else {
239	648×	map.insert(name.to_string(), value.into());
240	648×	}
241		}
242	3×	k if k.starts_with("revset.") => {
243	3×	let name = &k["revset.".len()..];
244	3×	if name.is_empty()
245	3×	\|\| !name
246	3×	.chars()
247	11×	.all(\|c\| c.is_ascii_alphanumeric() \|\| c == '_' \|\| c == '-')
248		{
249	0×	return fail(format!(
250		"a revset's name is letters, digits, _ and -: {key:?}"
251		));
252	3×	}
253	3×	if value.is_empty() {
254	0×	self.revsets.remove(name);
255	0×	} else {
256	3×	crate::revset::parse(value)
257	3×	.map_err(\|e\| RepoError::Msg(format!("{key} = {value:?}: {e}")))?;
258	2×	self.revsets.insert(name.to_string(), value.into());
259		}
260		}
261	0×	_ => return fail(format!("unknown configuration key {key:?}")),
262		}
263	1574×	Ok(())
264	1575×	}
265
266		/// Defaults, then the user file if it exists, then the repository file.
267	2676×	pub(super) fn load(user_path: Option<&Path>, repo_path: &Path) -> Result<Config> {
268	2676×	let mut c = Config::default_for_user();
269	2676×	if let Some(u) = user_path {
270	2676×	for (k, v) in read_config_file(u)? {
271	322×	let _ = c.apply(&k, &v);
272	322×	}
273	0×	}
274	2676×	for (k, v) in read_config_file(repo_path)? {
275	676×	if c.apply(&k, &v).is_ok() {
276	676×	c.repo_layer.insert(k, v);
277	676×	}
278		}
279	2676×	Ok(c)
280	2676×	}
281
282	897×	pub(super) fn save(&self, path: &Path) -> Result<()> {
283	897×	write_config_file(path, &self.repo_layer)
284	897×	}
285
286		/// Keys explicitly set for this repository.
287	20×	pub fn repo_layer(&self) -> &BTreeMap<String, String> {
288	20×	&self.repo_layer
289	20×	}
290		}
291
292		/// A byte count with an optional `K`, `M`, or `G` suffix (binary units).
293		/// `storage.cache` when unset: 2 GiB.
294		pub const DEFAULT_STORAGE_CACHE: u64 = 2 << 30;
295
296	7×	pub fn parse_size(v: &str) -> Result<u64> {
297	7×	let v = v.trim();
298	7×	let (num, mult) = match v.chars().last() {
299	1×	Some('K' \| 'k') => (&v[..v.len() - 1], 1u64 << 10),
300	1×	Some('M' \| 'm') => (&v[..v.len() - 1], 1u64 << 20),
301	0×	Some('G' \| 'g') => (&v[..v.len() - 1], 1u64 << 30),
302	5×	_ => (v, 1),
303		};
304	7×	let n: u64 = num
305	7×	.trim()
306	7×	.parse()
307	7×	.map_err(\|_\| RepoError::Msg(format!("expected a size like 1M, got {v:?}")))?;
308	6×	Ok(n * mult)
309	7×	}
310
311		/// A count of days, optionally suffixed `d`.
312	12×	fn parse_days(v: &str) -> Result<u64> {
313	12×	v.trim_end_matches('d')
314	12×	.parse()
315	12×	.map_err(\|_\| RepoError::Msg(format!("expected a number of days, got {v:?}")))
316	12×	}
317
318		/// Read `key = "value"` lines; a missing file is empty.
319	5946×	pub fn read_config_file(path: &Path) -> Result<BTreeMap<String, String>> {
320	5946×	let text = match fs::read_to_string(path) {
321	2340×	Ok(t) => t,
322	3606×	Err(e) if e.kind() == std::io::ErrorKind::NotFound => return Ok(BTreeMap::new()),
323	0×	Err(e) => return Err(e.into()),
324		};
325	2340×	let mut out = BTreeMap::new();
326	2340×	for line in text.lines() {
327	1233×	let line = line.trim();
328	1233×	if line.is_empty() \|\| line.starts_with('#') {
329	0×	continue;
330	1233×	}
331	1233×	let Some((k, v)) = line.split_once('=') else {
332	0×	continue;
333		};
334	1233×	out.insert(k.trim().to_string(), v.trim().trim_matches('"').to_string());
335		}
336	2340×	Ok(out)
337	5946×	}
338
339	997×	fn write_config_file(path: &Path, entries: &BTreeMap<String, String>) -> Result<()> {
340	997×	let text: String = entries
341	997×	.iter()
342	997×	.map(\|(k, v)\| format!("{k} = \"{v}\"\n"))
343	997×	.collect();
344	997×	write_atomic(path, text.as_bytes())
345	997×	}

Coverage / crates/oxy-core/src/repo/config.rs 84.1%

Keyboard