use anyhow::{Result, bail};
use std::path::Path;
use crate::config::{PerRepoConfig, Registry, Settings};
use crate::output;
struct Setting {
key: &'static str,
since: &'static str,
kind: Kind,
help: &'static str,
plain: &'static str,
get: fn(&Settings) -> String,
set: fn(&mut Settings, &str) -> Result<()>,
}
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
enum Kind {
Toggle,
Number,
Adapters,
AdapterDays,
}
struct Recommendation {
key: &'static str,
label: &'static str,
why: &'static str,
value: &'static str,
cautious: bool,
}
const RECOMMENDED: &[Recommendation] = &[
Recommendation {
key: "enable_cargo",
label: "Rust build folders",
why: "Rust `target/` directories are usually the largest thing on a developer's disk — tens of gigabytes across a handful of old projects. Nothing is lost: `cargo build` rebuilds it, and a project has to sit untouched for 45 days before this one is even considered.",
value: "true",
cautious: false,
},
Recommendation {
key: "enable_gradle",
label: "Android / Gradle builds",
why: "`build/` and `.gradle/` grow with every Android build and are never cleaned up by anything else. They come back on the next build, under the same 45-day wait.",
value: "true",
cautious: false,
},
Recommendation {
key: "enable_maven",
label: "Maven builds",
why: "Maven `target/` directories accumulate quietly per module, so a multi-module project has several. `mvn package` brings them back.",
value: "true",
cautious: false,
},
Recommendation {
key: "enable_swift",
label: "Swift builds",
why: "`.build/` holds compiled modules for every configuration you have ever built, and `swift build` recreates the one you actually use.",
value: "true",
cautious: false,
},
Recommendation {
key: "enable_dart",
label: "Dart / Flutter caches",
why: "`.dart_tool/` carries the pub metadata — back in a second — alongside `build_runner` and `flutter_build` caches that are worth real disk space.",
value: "true",
cautious: false,
},
Recommendation {
key: "enable_mix_build",
label: "Elixir build trees",
why: "`_build/` holds compiled beam files for every Mix environment you have built, and `mix compile` recreates the one you are working in.",
value: "true",
cautious: false,
},
Recommendation {
key: "allow_manifest_rewrite",
label: "Let cargo and go tidy up",
why: "Cautious, not risky. The commands that restore a Rust or Go project can also update `Cargo.lock` or `go.mod` — files Git tracks. Nothing is lost and nothing is deleted, but the next `git status` may show a change you did not make by hand. Turn it on if that is fine; leave it off if a clean working tree matters more than a fully automatic restore.",
value: "true",
cautious: true,
},
];
const SETTINGS: &[Setting] = &[
Setting {
key: "idle_days",
since: "1.0.0",
kind: Kind::Number,
help: "Days a repository must sit untouched before it is eligible for pruning.",
plain: "How long a project has to sit untouched before dev-prune will clean it. Something you worked on yesterday is never touched.",
get: |s| s.idle_days.to_string(),
set: |s, v| {
s.idle_days = v
.parse()
.map_err(|_| anyhow::anyhow!("idle_days must be a whole number of days"))?;
Ok(())
},
},
Setting {
key: "min_size_mb",
since: "1.0.0",
kind: Kind::Number,
help: "Smallest bloat directory worth deleting, in MiB. 0 removes the floor.",
plain: "Ignore small folders. Deleting a 2 MB folder is not worth the download to get it back.",
get: |s| s.min_size_mb.to_string(),
set: |s, v| {
s.min_size_mb = v.parse().map_err(|_| {
anyhow::anyhow!("min_size_mb must be a whole number of MiB (0 disables the floor)")
})?;
Ok(())
},
},
Setting {
key: "scan_depth",
since: "1.0.0",
kind: Kind::Number,
help: "How many directory levels below a repo root project discovery descends.",
plain: "How deep inside a repository to look for projects. Raise it if your projects live several folders down; lower it if scanning feels slow.",
get: |s| s.scan_depth.to_string(),
set: |s, v| {
let depth: usize = v
.parse()
.map_err(|_| anyhow::anyhow!("scan_depth must be a positive integer"))?;
if depth == 0 {
bail!("scan_depth must be at least 1 — 0 would find no projects at all.");
}
if depth > crate::constants::MAX_SCAN_DEPTH_LIMIT {
bail!(
"scan_depth must be at most {} — deeper walks stall on generated trees.",
crate::constants::MAX_SCAN_DEPTH_LIMIT
);
}
s.scan_depth = depth;
Ok(())
},
},
Setting {
key: "require_confirmation",
since: "1.0.0",
kind: Kind::Toggle,
help: "Ask before deleting anything. Turning this off makes every run unattended.",
plain: "Whether dev-prune asks \"delete these?\" before it deletes. Leave this on unless you want it to run silently while you are away.",
get: |s| s.require_confirmation.to_string(),
set: |s, v| {
s.require_confirmation = parse_bool("require_confirmation", v)?;
Ok(())
},
},
Setting {
key: "allow_manifest_rewrite",
since: "1.0.0",
kind: Kind::Toggle,
help: "Let cargo and go run the sync command that rewrites tracked manifests.",
plain: "Lets dev-prune run the command that puts a Rust or Go project back together — which can edit files that are checked into Git. Nothing is lost, but the change shows up in `git status`.",
get: |s| s.allow_manifest_rewrite.to_string(),
set: |s, v| {
s.allow_manifest_rewrite = parse_bool("allow_manifest_rewrite", v)?;
Ok(())
},
},
Setting {
key: "command_timeout_secs",
since: "1.0.0",
kind: Kind::Number,
help: "How long a lockfile command may run before it is killed.",
plain: "How long to wait for a rebuild command before giving up on it. Raise it on a slow connection.",
get: |s| s.command_timeout_secs.to_string(),
set: |s, v| {
let secs: u64 = v
.parse()
.map_err(|_| anyhow::anyhow!("command_timeout_secs must be a positive integer"))?;
if secs == 0 {
bail!(
"command_timeout_secs must be at least 1 — 0 would kill every command \
the instant it starts."
);
}
s.command_timeout_secs = secs;
Ok(())
},
},
Setting {
key: "auto_setup",
since: "1.0.0",
kind: Kind::Toggle,
help: "Install missing integrations by itself, once per installed version.",
plain: "Whether dev-prune finishes setting itself up on its own instead of making you run `devp setup`.",
get: |s| s.auto_setup.to_string(),
set: |s, v| {
s.auto_setup = parse_bool("auto_setup", v)?;
Ok(())
},
},
Setting {
key: "auto_config",
since: "1.3.0",
kind: Kind::Toggle,
help: "Write a default .devprune.json into repositories that link/init register.",
plain: "Drops a small settings file into each repository you register, so you can give that one project different rules later.",
get: |s| s.auto_config.to_string(),
set: |s, v| {
s.auto_config = parse_bool("auto_config", v)?;
Ok(())
},
},
Setting {
key: "auto_daemon",
since: "1.0.0",
kind: Kind::Toggle,
help: "Register the OS scheduler so passes run without being remembered.",
plain: "Lets your operating system run dev-prune on a schedule, so you never have to remember to.",
get: |s| s.auto_daemon.to_string(),
set: |s, v| {
s.auto_daemon = parse_bool("auto_daemon", v)?;
Ok(())
},
},
Setting {
key: "check_interval_days",
since: "1.0.0",
kind: Kind::Number,
help: "Days between scheduled background passes.",
plain: "How often that scheduled cleanup runs.",
get: |s| s.check_interval_days.to_string(),
set: |s, v| {
let days: u64 = v
.parse()
.map_err(|_| anyhow::anyhow!("check_interval_days must be a positive integer"))?;
if days == 0 {
bail!("check_interval_days must be at least 1.");
}
s.check_interval_days = days;
Ok(())
},
},
Setting {
key: "auto_hooks",
since: "1.0.0",
kind: Kind::Toggle,
help: "Install the Git hooks that register repositories as you clone them.",
plain: "Registers new repositories automatically as you clone them, so you never have to add them by hand.",
get: |s| s.auto_hooks.to_string(),
set: |s, v| {
s.auto_hooks = parse_bool("auto_hooks", v)?;
Ok(())
},
},
Setting {
key: "auto_hooks_chain",
since: "1.0.0",
kind: Kind::Toggle,
help: "If another tool owns core.hooksPath, install in front of it and forward.",
plain: "Git only has one slot for this kind of automation. If something else — husky, pre-commit, lefthook — is already using it, share the slot instead of taking it over.",
get: |s| s.auto_hooks_chain.to_string(),
set: |s, v| {
s.auto_hooks_chain = parse_bool("auto_hooks_chain", v)?;
Ok(())
},
},
Setting {
key: "update_check",
since: "1.0.0",
kind: Kind::Toggle,
help: "Ask GitHub for the latest release from time to time. Sends nothing but the request.",
plain: "Whether dev-prune checks GitHub now and then to see if there is a newer version. It sends no information about you.",
get: |s| s.update_check.to_string(),
set: |s, v| {
s.update_check = parse_bool("update_check", v)?;
Ok(())
},
},
Setting {
key: "update_check_interval_days",
since: "1.0.0",
kind: Kind::Number,
help: "Days between automatic release checks.",
plain: "How often that version check happens.",
get: |s| s.update_check_interval_days.to_string(),
set: |s, v| {
let days: i64 = v.parse().map_err(|_| {
anyhow::anyhow!("update_check_interval_days must be a positive integer")
})?;
if days < 1 {
bail!("update_check_interval_days must be at least 1.");
}
s.update_check_interval_days = days;
Ok(())
},
},
Setting {
key: "update_check_timeout_secs",
since: "1.0.0",
kind: Kind::Number,
help: "Seconds the release check waits for GitHub. Raise it behind a slow proxy.",
plain: "How long the version check waits before giving up. Raise it if you are behind a slow proxy.",
get: |s| s.update_check_timeout_secs.to_string(),
set: |s, v| {
let secs: u64 = v.parse().map_err(|_| {
anyhow::anyhow!("update_check_timeout_secs must be a positive integer")
})?;
if secs == 0 {
bail!("update_check_timeout_secs must be at least 1.");
}
s.update_check_timeout_secs = secs;
Ok(())
},
},
Setting {
key: "enable_cargo",
since: "1.5.0",
kind: Kind::Toggle,
help: "Turn on the opt-in Cargo adapter (target/ comes back by recompiling, not downloading).",
plain: "Clean Rust build folders too. These come back by recompiling, which takes minutes rather than a download — so this is off unless you say otherwise.",
get: |s| s.enable_cargo.to_string(),
set: |s, v| {
s.enable_cargo = parse_bool("enable_cargo", v)?;
Ok(())
},
},
Setting {
key: "enable_gradle",
since: "1.3.0",
kind: Kind::Toggle,
help: "Turn on the opt-in Gradle adapter (build/ and .gradle/ come back by recompiling).",
plain: "Clean Android and Java build folders too. Same trade: they come back by recompiling, not downloading.",
get: |s| s.enable_gradle.to_string(),
set: |s, v| {
s.enable_gradle = parse_bool("enable_gradle", v)?;
Ok(())
},
},
Setting {
key: "enable_maven",
since: "1.3.0",
kind: Kind::Toggle,
help: "Turn on the opt-in Maven adapter (target/ comes back by recompiling).",
plain: "Clean Maven build folders too. They come back by recompiling.",
get: |s| s.enable_maven.to_string(),
set: |s, v| {
s.enable_maven = parse_bool("enable_maven", v)?;
Ok(())
},
},
Setting {
key: "enable_swift",
since: "1.4.0",
kind: Kind::Toggle,
help: "Turn on the opt-in SwiftPM adapter (.build/ comes back by recompiling).",
plain: "Clean Swift build folders too. They come back by recompiling.",
get: |s| s.enable_swift.to_string(),
set: |s, v| {
s.enable_swift = parse_bool("enable_swift", v)?;
Ok(())
},
},
Setting {
key: "enable_dart",
since: "1.6.0",
kind: Kind::Toggle,
help: "Turn on the opt-in Dart/Flutter adapter (.dart_tool/ holds build caches).",
plain: "Clean Dart and Flutter caches too. Part comes back instantly, part by recompiling.",
get: |s| s.enable_dart.to_string(),
set: |s, v| {
s.enable_dart = parse_bool("enable_dart", v)?;
Ok(())
},
},
Setting {
key: "enable_mix_build",
since: "1.7.0",
kind: Kind::Toggle,
help: "Turn on the opt-in Mix build-tree adapter (_build/ comes back by recompiling).",
plain: "Clean Elixir _build/ folders too. They come back by recompiling.",
get: |s| s.enable_mix_build.to_string(),
set: |s, v| {
s.enable_mix_build = parse_bool("enable_mix_build", v)?;
Ok(())
},
},
Setting {
key: "build_idle_days",
since: "1.3.0",
kind: Kind::Number,
help: "Idle days before cargo/gradle/maven/swift build trees are pruned. Applied as max(this, idle_days).",
plain: "A longer wait, used only for the build folders above, because getting those back costs a recompile rather than a download.",
get: |s| s.build_idle_days.to_string(),
set: |s, v| {
let days: u64 = v
.parse()
.map_err(|_| anyhow::anyhow!("build_idle_days must be a non-negative integer"))?;
s.build_idle_days = days;
Ok(())
},
},
Setting {
key: "auto_update",
since: "1.3.0",
kind: Kind::Toggle,
help: "Install a newer release by itself at the end of a prune pass. On by default.",
plain: "Whether dev-prune installs its own updates after a cleanup. The download is checked against its published fingerprint first.",
get: |s| s.auto_update.to_string(),
set: |s, v| {
s.auto_update = parse_bool("auto_update", v)?;
Ok(())
},
},
Setting {
key: "disabled_adapters",
since: "1.4.0",
kind: Kind::Adapters,
help: "Adapters to leave alone entirely, by name. Empty means every one of them is active.",
plain: "Ecosystems to ignore completely — as if you did not have them installed at all.",
get: |s| {
if s.disabled_adapters.is_empty() {
"(none)".to_string()
} else {
s.disabled_adapters.join(",")
}
},
set: |s, v| {
s.disabled_adapters = parse_adapter_list(v)?;
Ok(())
},
},
Setting {
key: "adapter_idle_days",
since: "1.5.0",
kind: Kind::AdapterDays,
help: "Per-adapter idle windows, as `cargo=60,npm=30`. Each one can only raise its own wait.",
plain: "A different waiting period for one ecosystem. Useful when your Rust projects should wait longer than your Node ones.",
get: |s| {
if s.adapter_idle_days.is_empty() {
"(none)".to_string()
} else {
s.adapter_idle_days
.iter()
.map(|(name, days)| format!("{name}={days}"))
.collect::<Vec<_>>()
.join(",")
}
},
set: |s, v| {
s.adapter_idle_days = parse_adapter_days(v)?;
Ok(())
},
},
];
fn parse_adapter_days(value: &str) -> Result<std::collections::BTreeMap<String, u64>> {
let trimmed = value.trim();
if trimmed.is_empty() || matches!(trimmed.to_lowercase().as_str(), "none" | "(none)" | "-") {
return Ok(std::collections::BTreeMap::new());
}
let mut days = std::collections::BTreeMap::new();
for raw in trimmed.split(',') {
let entry = raw.trim();
if entry.is_empty() {
continue;
}
let Some((name, value)) = entry.split_once('=') else {
bail!("`{entry}` must be written as `<adapter>=<days>`, for example `cargo=60`.");
};
let name = name.trim().to_lowercase();
if !crate::adapters::is_adapter_name(&name) {
bail!(
"`{name}` is not an adapter. Valid names: {}",
crate::adapters::all_adapter_names().join(", ")
);
}
let parsed: u64 = value.trim().parse().map_err(|_| {
anyhow::anyhow!(
"`{name}` needs a whole number of days, not `{}`.",
value.trim()
)
})?;
days.insert(name, parsed);
}
Ok(days)
}
fn parse_adapter_list(value: &str) -> Result<Vec<String>> {
let trimmed = value.trim();
if trimmed.is_empty() || matches!(trimmed.to_lowercase().as_str(), "none" | "(none)" | "-") {
return Ok(Vec::new());
}
let mut names: Vec<String> = Vec::new();
for raw in trimmed.split(',') {
let name = raw.trim().to_lowercase();
if name.is_empty() {
continue;
}
if !crate::adapters::is_adapter_name(&name) {
bail!(
"`{name}` is not an adapter. Valid names: {}",
crate::adapters::all_adapter_names().join(", ")
);
}
if !names.contains(&name) {
names.push(name);
}
}
Ok(names)
}
fn parse_bool(key: &str, value: &str) -> Result<bool> {
match value.trim().to_lowercase().as_str() {
"true" | "yes" | "y" | "on" | "1" => Ok(true),
"false" | "no" | "n" | "off" | "0" => Ok(false),
_ => bail!("{key} must be true or false"),
}
}
pub fn invalid_settings(settings: &Settings) -> Vec<(&'static str, String)> {
SETTINGS
.iter()
.filter_map(|setting| {
let mut probe = settings.clone();
(setting.set)(&mut probe, &(setting.get)(settings))
.err()
.map(|e| (setting.key, e.to_string()))
})
.collect()
}
pub fn setting_count() -> usize {
SETTINGS.len()
}
fn find_setting(key: &str) -> Result<&'static Setting> {
SETTINGS
.iter()
.find(|s| s.key == key)
.ok_or_else(|| anyhow::anyhow!("Unknown config key: {key}. Valid keys: {}", valid_keys()))
}
fn valid_keys() -> String {
SETTINGS
.iter()
.map(|s| s.key)
.collect::<Vec<_>>()
.join(", ")
}
#[derive(Debug, PartialEq, Eq)]
pub enum Toggle {
Enable,
Disable,
Status,
}
pub fn parse_toggle(action: &str) -> Result<Toggle> {
match action.to_lowercase().as_str() {
"enable" | "install" | "on" => Ok(Toggle::Enable),
"disable" | "uninstall" | "remove" | "off" => Ok(Toggle::Disable),
"" | "status" | "show" => Ok(Toggle::Status),
other => bail!(
"Unknown action `{other}`. Expected `enable`, `disable` or `status` \
(`install` / `uninstall` / `on` / `off` also work)."
),
}
}
pub fn is_toggle_word(word: &str) -> bool {
parse_toggle(word).is_ok() && !word.is_empty()
}
fn resolve_workspace(path: &str) -> Result<std::path::PathBuf> {
let raw = Path::new(path);
if !raw.is_dir() {
bail!(
"`{path}` is neither an action nor an existing directory.\n\
Expected `enable`, `disable` or `status`, or a path to a repository."
);
}
Ok(raw.canonicalize().unwrap_or_else(|_| raw.to_path_buf()))
}
pub fn run_get(key: &str) -> Result<()> {
let registry = Registry::load()?;
let setting = find_setting(key)?;
println!("{key} = {}", (setting.get)(®istry.settings));
Ok(())
}
pub fn run_set(key: &str, value: &str) -> Result<()> {
let mut registry = Registry::load()?;
let setting = find_setting(key)?;
(setting.set)(&mut registry.settings, value)?;
registry.save()?;
output::print_success(&format!("{key} = {}", (setting.get)(®istry.settings)));
Ok(())
}
fn key_column_width() -> usize {
SETTINGS.iter().map(|s| s.key.len()).max().unwrap_or(0)
}
pub fn run_show() -> Result<()> {
let registry = Registry::load()?;
let width = key_column_width();
output::print_header("dev-prune Global Configuration");
for setting in SETTINGS {
println!(
" {:<width$} = {}",
setting.key,
(setting.get)(®istry.settings)
);
}
println!(" {:<width$} = {}", "tracked_repos", registry.repo_count());
let reg_path = Registry::registry_path()
.map(|p| output::clean_path(&p))
.unwrap_or_else(|_| "unknown".to_string());
println!("\n {:<width$} = {reg_path}", "registry_file");
println!();
output::print_info("Change any of these with `devp config set <key> <value>`.");
output::print_info("Walk through them one at a time with `devp config wizard`.");
Ok(())
}
pub fn run_wizard(no_tui: bool) -> Result<()> {
if !no_tui && full_screen_is_usable() {
return run_wizard_tui();
}
run_wizard_prompts()
}
fn full_screen_is_usable() -> bool {
use std::io::IsTerminal;
if std::env::var_os(crate::constants::ENV_NO_TUI).is_some() {
return false;
}
std::io::stdin().is_terminal() && std::io::stdout().is_terminal()
}
fn run_wizard_tui() -> Result<()> {
use crate::tui::config_view::{ConfigRow, ConfigSession, Control, Outcome};
let mut registry = Registry::load()?;
let new_keys = settings_added_since_review();
let rows: Vec<ConfigRow> = SETTINGS
.iter()
.map(|setting| {
let value = (setting.get)(®istry.settings);
ConfigRow {
key: setting.key,
help: setting.help,
plain: setting.plain,
control: match setting.kind {
Kind::Toggle => Control::Toggle,
Kind::Number => Control::Number,
Kind::Adapters => Control::Adapters,
Kind::AdapterDays => Control::AdapterDays,
},
original: value.clone(),
value,
is_new: new_keys.contains(&setting.key),
}
})
.collect();
let base = registry.settings.clone();
let validate = move |key: &str, value: &str| -> std::result::Result<(), String> {
let setting = find_setting(key).map_err(|e| e.to_string())?;
let mut probe = base.clone();
(setting.set)(&mut probe, value).map_err(|e| format!("{e}"))
};
let report = crate::commands::trust::build(®istry);
let adapters = crate::adapters::all_adapter_names();
let opt_in = crate::adapters::opt_in_adapter_names();
let outcome = crate::tui::config_view::run(ConfigSession {
declaration: declaration_lines(&report),
standing: NOTHING_DELETED_YET.to_string(),
suggestions: first_run_suggestions(),
rows,
adapters: &adapters,
opt_in_adapters: &opt_in,
groups: crate::adapters::ADAPTER_GROUPS,
validate: &validate,
title: "dev-prune configuration",
})?;
match outcome {
Outcome::Cancelled => {
output::print_info("Cancelled — nothing was changed.");
Ok(())
}
Outcome::KeepAll => {
mark_reviewed();
output::print_success(
"Keeping the current values. `devp config set <key> <value>` changes any.",
);
Ok(())
}
Outcome::Save(changed) => {
for row in &changed {
(find_setting(row.key)?.set)(&mut registry.settings, &row.value)?;
}
registry.save()?;
mark_reviewed();
output::print_header("Saved");
let width = changed.iter().map(|r| r.key.len()).max().unwrap_or(0);
for row in &changed {
println!(
" {:<width$} = {} (was {})",
row.key, row.value, row.original
);
}
println!();
output::print_success(&format!(
"{} {} saved. `devp config show` lists every setting.",
changed.len(),
output::plural(changed.len(), "change", "changes")
));
Ok(())
}
}
}
fn first_run_suggestions() -> Vec<crate::tui::config_view::Suggestion> {
use crate::tui::config_view::Suggestion;
if reviewed_version().is_some() {
return Vec::new();
}
RECOMMENDED
.iter()
.filter_map(|r| {
let setting = find_setting(r.key).ok()?;
Some(Suggestion {
key: r.key,
label: r.label,
help: setting.help,
plain: setting.plain,
why: r.why,
value: r.value,
cautious: r.cautious,
})
})
.collect()
}
const NOTHING_DELETED_YET: &str =
"Nothing has been deleted, and nothing will be until a lockfile proves it comes back.";
fn declaration_lines(
report: &crate::commands::trust::TrustReport,
) -> Vec<crate::tui::config_view::DeclarationLine> {
use crate::commands::trust::{TrustRow, Verdict};
use crate::tui::config_view::DeclarationLine;
let heading = |text: &str| DeclarationLine {
mark: '#',
subject: text.to_string(),
state: String::new(),
};
let row = |r: &TrustRow| DeclarationLine {
mark: match r.verdict {
Verdict::Guaranteed | Verdict::Safe => '+',
Verdict::Widened => '!',
Verdict::Neutral => ' ',
},
subject: r.subject.to_string(),
state: r.state.clone(),
};
let mut lines = vec![heading("Guaranteed by the code")];
lines.extend(report.guarantees.iter().map(&row));
lines.push(heading(""));
lines.push(heading("On this machine"));
lines.extend(report.machine.iter().map(&row));
lines
}
fn run_wizard_prompts() -> Result<()> {
use std::io::{self, IsTerminal, Write};
if !io::stdin().is_terminal() {
bail!(
"`devp config wizard` needs a terminal to ask questions on.\n\
Use `devp config show` to read the settings and `devp config set <key> <value>` \
to change one."
);
}
let mut registry = Registry::load()?;
let width = key_column_width();
let new_keys = settings_added_since_review();
output::print_header("dev-prune configuration");
output::print_info("These are the defaults every run will use. Nothing has been changed yet.");
println!();
for setting in SETTINGS {
let badge = if new_keys.contains(&setting.key) {
" (new in this version)"
} else {
""
};
println!(
" {:<width$} = {}{badge}",
setting.key,
(setting.get)(®istry.settings)
);
println!(" {:<width$} {}", "", setting.help);
println!(" {:<width$} {}", "", setting.plain);
}
println!();
print!("Keep all of these? [Y/n] ");
io::stdout().flush()?;
let mut answer = String::new();
io::stdin().read_line(&mut answer)?;
let keep = !matches!(answer.trim().to_lowercase().as_str(), "n" | "no");
if keep {
mark_reviewed();
output::print_success("Keeping the defaults. `devp config set <key> <value>` changes any.");
return Ok(());
}
println!();
output::print_info("Enter a new value, or press Enter to keep the one shown.");
println!();
let mut changed = 0usize;
for setting in SETTINGS {
let current = (setting.get)(®istry.settings);
loop {
print!(" {} [{current}]: ", setting.key);
io::stdout().flush()?;
let mut line = String::new();
if io::stdin().read_line(&mut line)? == 0 {
println!();
break;
}
let typed = line.trim();
if typed.is_empty() {
break;
}
match (setting.set)(&mut registry.settings, typed) {
Ok(()) => {
changed += 1;
break;
}
Err(e) => output::print_error(&format!("{e}")),
}
}
}
registry.save()?;
mark_reviewed();
println!();
if changed == 0 {
output::print_success("Nothing changed — the defaults are in place.");
} else {
output::print_success(&format!(
"Saved {changed} {}. `devp config show` lists them all.",
output::plural(changed, "change", "changes")
));
}
Ok(())
}
const REVIEW_MARKER: &str = "config-reviewed";
pub fn config_review_is_due() -> bool {
let Ok(dir) = Registry::config_dir() else {
return false;
};
if !dir.join(REVIEW_MARKER).exists() {
return true;
}
!settings_added_since_review().is_empty()
}
fn reviewed_version() -> Option<String> {
let dir = Registry::config_dir().ok()?;
let recorded = std::fs::read_to_string(dir.join(REVIEW_MARKER)).ok()?;
let recorded = recorded.trim().to_string();
(!recorded.is_empty()).then_some(recorded)
}
pub fn settings_added_since_review() -> Vec<&'static str> {
let Some(reviewed) = reviewed_version() else {
return Vec::new();
};
SETTINGS
.iter()
.filter(|s| {
crate::commands::update::compare_versions(s.since, &reviewed)
== Some(std::cmp::Ordering::Greater)
})
.map(|s| s.key)
.collect()
}
fn mark_reviewed() {
if let Ok(dir) = Registry::config_dir() {
let _ = std::fs::create_dir_all(&dir);
let _ = std::fs::write(dir.join(REVIEW_MARKER), crate::constants::VERSION);
}
}
pub fn skip_config_review() {
mark_reviewed();
}
pub fn run_global_update() -> Result<()> {
output::print_header("dev-prune Global Configuration Audit & Sync");
let registry = Registry::load()?;
let mut total_audited = 0;
let mut errors_found = 0;
for repo_path in registry.repositories.keys() {
let clean = output::clean_path(repo_path);
if !repo_path.exists() {
output::print_warning(&format!(
"Skipped {clean} — the path no longer exists. `devp unlink --missing` \
clears such entries."
));
continue;
}
total_audited += 1;
match PerRepoConfig::load_with_diagnostics(repo_path) {
Ok(Some(cfg)) => {
if let Err(e) = cfg.save_to_repo(repo_path) {
output::print_error(&format!("Failed to write config for {clean}: {e}"));
errors_found += 1;
} else {
output::print_success(&format!("Audited & synced config for {clean}"));
}
}
Ok(None) => {
output::print_info(&format!(
"{clean} has no .devprune.json — global defaults apply."
));
}
Err(err_msg) => {
errors_found += 1;
output::print_error(&format!("Syntax/Schema Error in {clean}:"));
for line in err_msg.lines() {
eprintln!(" {line}");
}
output::print_info(&format!(
"Hint: fix the syntax by hand, or run `devp config {clean} --update` to \
replace the file with a valid default."
));
}
}
}
if errors_found > 0 {
anyhow::bail!(
"Audit complete: {total_audited} repos checked, {errors_found} could not be read \
or written."
);
}
output::print_success(&format!(
"Audit complete: All {total_audited} registered repositories are healthy & synced!"
));
Ok(())
}
pub fn run_path_config(path_str: &str, force_update: bool) -> Result<()> {
let raw_path = Path::new(path_str);
let path = if raw_path.exists() {
raw_path
.canonicalize()
.unwrap_or_else(|_| raw_path.to_path_buf())
} else {
raw_path.to_path_buf()
};
let clean = output::clean_path(&path);
if !path.exists() {
bail!("Path does not exist: {clean}");
}
if !crate::scanner::is_git_repo(&path) {
bail!(
"`{clean}` is not a Git repository.\n \
Run `git init` there first, then `devp config {clean}` again."
);
}
let mut registry = Registry::load()?;
if !registry.repositories.contains_key(&path) {
output::print_info(&format!(
"{clean} is not yet registered with dev-prune. Registering now..."
));
registry.add_repo(path.clone());
registry.save()?;
}
let cfg_file = path.join(crate::constants::PER_REPO_CONFIG_FILE);
if cfg_file.exists() && !force_update {
output::print_header(&format!("dev-prune Per-Repo Config for {clean}"));
match PerRepoConfig::load_with_diagnostics(&path) {
Ok(cfg) => {
let json_str = serde_json::to_string_pretty(&cfg)?;
println!("{json_str}");
output::print_info("File location: .devprune.json");
}
Err(err_msg) => {
output::print_error(&format!("Invalid configuration in {clean}:"));
for line in err_msg.lines() {
eprintln!(" {line}");
}
anyhow::bail!(
"Run `devp config {clean} --update` to reset this file back to defaults \
(your current overrides in it are discarded)."
);
}
}
} else {
output::print_info(&format!("Initializing .devprune.json for {clean}..."));
let cfg = PerRepoConfig::default();
cfg.save_to_repo(&path)?;
output::print_success(&format!("Created .devprune.json in {clean}"));
}
Ok(())
}
fn load_workspace_config_for_write(repo_path: &Path) -> Result<PerRepoConfig> {
match PerRepoConfig::load_with_diagnostics(repo_path) {
Ok(Some(cfg)) => Ok(cfg),
Ok(None) => Ok(PerRepoConfig::default()),
Err(e) => bail!(
"{e}\n \
Fix that file, or run `devp config {} --update` to reset it back to defaults \
(your current overrides in it are discarded).",
output::clean_path(repo_path)
),
}
}
pub fn run_daemon_toggle(path: Option<&str>, action: &str) -> Result<()> {
if let Some(p) = path {
let repo_path = resolve_workspace(p)?;
let mut cfg = load_workspace_config_for_write(&repo_path)?;
match parse_toggle(action)? {
Toggle::Enable => {
cfg.disable_daemon = false;
cfg.save_to_repo(&repo_path)?;
output::print_success(&format!(
"Enabled background daemon for workspace: {}",
output::clean_path(&repo_path)
));
}
Toggle::Disable => {
cfg.disable_daemon = true;
cfg.save_to_repo(&repo_path)?;
output::print_success(&format!(
"Disabled background daemon for workspace: {}",
output::clean_path(&repo_path)
));
}
Toggle::Status => {
let st = if cfg.disable_daemon {
"Disabled for workspace"
} else {
"Enabled for workspace"
};
output::print_info(&format!(
"Daemon Status ({}): {}",
output::clean_path(&repo_path),
st
));
}
}
} else {
match parse_toggle(action)? {
Toggle::Enable => crate::commands::daemon::run_install()?,
Toggle::Disable => crate::commands::daemon::run_uninstall()?,
Toggle::Status => crate::commands::daemon::run_status()?,
}
}
Ok(())
}
pub fn run_hook_toggle(path: Option<&str>, action: &str, chain: bool) -> Result<()> {
if let Some(p) = path {
if chain {
bail!(
"`--chain` changes the single global `core.hooksPath`, so it has no \
per-workspace form. Drop the path: `devp hook install --chain`."
);
}
let repo_path = resolve_workspace(p)?;
let mut cfg = load_workspace_config_for_write(&repo_path)?;
match parse_toggle(action)? {
Toggle::Enable => {
cfg.disable_hooks = false;
cfg.save_to_repo(&repo_path)?;
output::print_success(&format!(
"Enabled background Git hooks for workspace: {}",
output::clean_path(&repo_path)
));
}
Toggle::Disable => {
cfg.disable_hooks = true;
cfg.save_to_repo(&repo_path)?;
output::print_success(&format!(
"Disabled background Git hooks for workspace: {}",
output::clean_path(&repo_path)
));
}
Toggle::Status => {
let st = if cfg.disable_hooks {
"Disabled for workspace"
} else {
"Enabled for workspace"
};
output::print_info(&format!(
"Git Hook Status ({}): {}",
output::clean_path(&repo_path),
st
));
}
}
} else {
match parse_toggle(action)? {
Toggle::Enable => crate::commands::hook::run_install(chain)?,
Toggle::Disable => crate::commands::hook::run_uninstall()?,
Toggle::Status => crate::commands::hook::run_status()?,
}
}
Ok(())
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn enable_synonyms_all_resolve_to_enable() {
for word in ["enable", "install", "on", "INSTALL", "On"] {
assert_eq!(parse_toggle(word).unwrap(), Toggle::Enable, "{word}");
}
}
#[test]
fn disable_synonyms_all_resolve_to_disable() {
for word in ["disable", "uninstall", "remove", "off", "Uninstall"] {
assert_eq!(parse_toggle(word).unwrap(), Toggle::Disable, "{word}");
}
}
#[test]
fn status_is_the_default_and_is_also_spellable() {
for word in ["", "status", "show"] {
assert_eq!(parse_toggle(word).unwrap(), Toggle::Status, "{word}");
}
}
#[test]
fn a_typo_is_an_error_rather_than_a_silent_status_report() {
let err = parse_toggle("enabel").unwrap_err().to_string();
assert!(err.contains("enabel"), "{err}");
assert!(err.contains("enable"), "{err}");
}
#[test]
fn a_workspace_toggle_refuses_to_write_over_a_broken_config() {
let tmp = tempfile::TempDir::new().unwrap();
let broken = r#"{ "project_name": "api", "override_idle_days": 90, }"#;
std::fs::write(
tmp.path().join(crate::constants::PER_REPO_CONFIG_FILE),
broken,
)
.unwrap();
let err = load_workspace_config_for_write(tmp.path())
.unwrap_err()
.to_string();
assert!(err.contains("Syntax error"), "{err}");
assert!(err.contains("--update"), "{err}");
let on_disk =
std::fs::read_to_string(tmp.path().join(crate::constants::PER_REPO_CONFIG_FILE))
.unwrap();
assert_eq!(on_disk, broken);
}
#[test]
fn a_workspace_with_no_config_yet_starts_from_the_defaults() {
let tmp = tempfile::TempDir::new().unwrap();
assert_eq!(
load_workspace_config_for_write(tmp.path()).unwrap(),
PerRepoConfig::default()
);
}
#[test]
fn every_setting_round_trips_through_its_own_getter() {
let mut settings = Settings::default();
for setting in SETTINGS {
let before = (setting.get)(&settings);
let probe = match setting.kind {
Kind::Toggle => if before == "true" { "false" } else { "true" }.to_string(),
Kind::Number => "7".to_string(),
Kind::Adapters => "cargo".to_string(),
Kind::AdapterDays => "cargo=45".to_string(),
};
(setting.set)(&mut settings, &probe)
.unwrap_or_else(|e| panic!("{} rejected `{probe}`: {e}", setting.key));
assert_eq!(
(setting.get)(&settings),
probe,
"{} reads back a different field than it writes",
setting.key
);
}
}
#[test]
fn every_setting_is_documented_and_uniquely_named() {
let mut seen = std::collections::HashSet::new();
for setting in SETTINGS {
assert!(seen.insert(setting.key), "duplicate key {}", setting.key);
assert!(!setting.help.is_empty(), "{} has no help", setting.key);
assert!(
!setting.plain.is_empty(),
"{} has no plain text",
setting.key
);
assert!(
setting.help.ends_with('.'),
"{} help should read as a sentence",
setting.key
);
assert!(
setting.plain.ends_with('.'),
"{} plain text should read as a sentence",
setting.key
);
assert_ne!(
setting.plain, setting.help,
"{} says the same thing twice",
setting.key
);
}
}
#[test]
fn the_settings_table_covers_every_field_of_settings() {
let json = serde_json::to_value(Settings::default()).unwrap();
let fields: Vec<String> = json.as_object().unwrap().keys().cloned().collect();
for field in fields {
assert!(
SETTINGS.iter().any(|s| s.key == field),
"`{field}` is a setting with no entry in SETTINGS, so `devp config set \
{field}` cannot reach it"
);
}
}
#[test]
fn a_rejected_value_leaves_the_previous_one_in_place() {
let mut settings = Settings::default();
assert!((find_setting("scan_depth").unwrap().set)(&mut settings, "0").is_err());
assert_eq!(settings.scan_depth, Settings::default().scan_depth);
assert!((find_setting("command_timeout_secs").unwrap().set)(&mut settings, "0").is_err());
assert!((find_setting("check_interval_days").unwrap().set)(&mut settings, "0").is_err());
assert!(
(find_setting("update_check_interval_days").unwrap().set)(&mut settings, "0").is_err()
);
}
#[test]
fn booleans_accept_the_words_people_actually_type() {
assert!(parse_bool("k", "yes").unwrap());
assert!(parse_bool("k", "ON").unwrap());
assert!(!parse_bool("k", "0").unwrap());
assert!(parse_bool("k", "maybe").is_err());
}
#[test]
fn an_unknown_key_lists_the_ones_that_exist() {
let err = match find_setting("idel_days") {
Ok(_) => panic!("`idel_days` is not a setting"),
Err(e) => e.to_string(),
};
assert!(err.contains("idle_days"), "{err}");
}
#[test]
fn a_path_is_never_mistaken_for_an_action() {
assert!(!is_toggle_word("~/Code/my-repo"));
assert!(!is_toggle_word("."));
assert!(!is_toggle_word(""));
assert!(is_toggle_word("install"));
}
}