fn matches_list_filter(
item: &Value,
args: &ListFilterArgs,
kind: &str,
files: &std::collections::BTreeMap<String, Value>,
) -> bool {
let candidate_paths = match kind {
"relationships" => ["source_path", "target_path"]
.into_iter()
.filter_map(|key| item.get(key).and_then(Value::as_str))
.collect::<Vec<_>>(),
"clusters" => item
.get("member_paths")
.and_then(Value::as_array)
.into_iter()
.flatten()
.filter_map(Value::as_str)
.collect(),
_ => item
.get("path")
.and_then(Value::as_str)
.into_iter()
.collect(),
};
let field_matches = |field: &str, expected: &str| {
item.get(field).and_then(Value::as_str) == Some(expected)
|| candidate_paths.iter().any(|path| {
files
.get(*path)
.and_then(|file| file.get(field))
.and_then(Value::as_str)
== Some(expected)
})
};
args.path
.as_ref()
.is_none_or(|path| candidate_paths.iter().any(|value| value.starts_with(path)))
&& args.profile.as_ref().is_none_or(|value| {
field_matches("profile", value)
|| (kind == "profiles" && item.get("name").and_then(Value::as_str) == Some(value))
})
&& args
.language
.as_ref()
.is_none_or(|value| field_matches("language", value))
&& args.classification.as_ref().is_none_or(|value| {
field_matches("classification", value) || field_matches("class", value)
})
&& args
.severity
.as_ref()
.is_none_or(|value| item.get("severity").and_then(Value::as_str) == Some(value))
}
fn terminal_field(value: &str, width: usize, no_truncate: bool) -> String {
let value = safe_terminal(value).replace(['\n', '\t'], " ");
if no_truncate || value.chars().count() <= width {
return value;
}
if width <= 1 {
return "…".to_string();
}
value.chars().take(width - 1).collect::<String>() + "…"
}
fn run_list(repo_root: &Path, args: ListArgs) -> Result<i32> {
let filter = match &args.command {
ListCommand::Findings(v)
| ListCommand::Relationships(v)
| ListCommand::Clusters(v)
| ListCommand::Profiles(v) => v,
};
let (loaded, _) = report_or_missing(repo_root, filter.report.as_deref())?;
let kind = match &args.command {
ListCommand::Findings(_) => "findings",
ListCommand::Relationships(_) => "relationships",
ListCommand::Clusters(_) => "clusters",
ListCommand::Profiles(_) => "profiles",
};
let files = loaded
.get("files")
.and_then(Value::as_array)
.into_iter()
.flatten()
.filter_map(|record| Some((record.get("path")?.as_str()?.to_string(), record.clone())))
.collect::<std::collections::BTreeMap<_, _>>();
let mut values = match &args.command {
ListCommand::Findings(_) => loaded
.pointer("/health/findings")
.and_then(Value::as_array)
.cloned()
.unwrap_or_default(),
ListCommand::Relationships(_) => loaded
.pointer("/overlays/organization_health/relationships")
.and_then(Value::as_object)
.into_iter()
.flat_map(|map| map.values())
.filter_map(Value::as_array)
.flatten()
.cloned()
.collect(),
ListCommand::Clusters(_) => loaded
.pointer("/overlays/organization_health/clusters")
.and_then(Value::as_object)
.into_iter()
.flat_map(|map| map.values())
.filter_map(Value::as_array)
.flatten()
.cloned()
.collect(),
ListCommand::Profiles(_) => loaded
.pointer("/health/profile_rollups")
.and_then(Value::as_array)
.cloned()
.unwrap_or_default(),
};
let unfiltered_total = values.len();
values.retain(|item| matches_list_filter(item, filter, kind, &files));
let matched_total = values.len();
values.truncate(filter.top);
let returned = values.len();
match filter.format {
DisplayFormat::Json => print_text(&render_json(&json!({
"schema_version": 1,
"command": "list",
"kind": kind,
"items": values,
"collection": {"total": unfiltered_total, "matched": matched_total, "returned": returned, "limit": filter.top, "truncated": returned < matched_total}
}))?),
DisplayFormat::Yaml => print_text(&serde_yaml::to_string(&values)?),
DisplayFormat::Text => {
let terminal_width = std::env::var("COLUMNS")
.ok()
.and_then(|value| value.parse::<usize>().ok())
.unwrap_or(100);
let path_width = if filter.no_truncate {
values
.iter()
.filter_map(|item| {
item.get("path")
.or_else(|| item.get("name"))
.or_else(|| item.get("id"))
.and_then(Value::as_str)
})
.map(str::len)
.max()
.unwrap_or(24)
.max(24)
} else if filter.wide {
80
} else {
terminal_width.saturating_sub(59).clamp(24, 48)
};
println!(
"{:<path_width$} {:<16} {:<10} {:<10} {:<10} {:>7}",
"PATH OR NAME", "PROFILE", "SEVERITY", "CONTEXT", "SLOP", "SCORE"
);
println!(
"{:-<path_width$} {:-<16} {:-<10} {:-<10} {:-<10} {:-<7}",
"", "", "", "", "", ""
);
for item in &values {
let label = item
.get("path")
.or_else(|| item.get("name"))
.or_else(|| item.get("id"))
.and_then(Value::as_str)
.unwrap_or("-");
let profile = item
.get("profile")
.or_else(|| item.get("kind"))
.and_then(Value::as_str)
.unwrap_or("-");
let severity = item.get("severity").and_then(Value::as_str).unwrap_or("-");
let context = item
.get("context_band")
.and_then(Value::as_str)
.unwrap_or("-");
let slop = item.get("slop_band").and_then(Value::as_str).unwrap_or("-");
let score = item
.get("slop_score")
.or_else(|| item.get("evidence_score"))
.and_then(Value::as_f64)
.map_or_else(|| "-".to_string(), |value| format!("{value:.3}"));
println!(
"{:<path_width$} {:<16} {:<10} {:<10} {:<10} {:>7}",
terminal_field(label, path_width, filter.no_truncate),
terminal_field(profile, 16, filter.no_truncate),
terminal_field(severity, 10, filter.no_truncate),
terminal_field(context, 10, filter.no_truncate),
terminal_field(slop, 10, filter.no_truncate),
score
);
}
println!(
"\nReturned {returned} of {matched_total} matching record(s) from {unfiltered_total} total.{}",
if returned < matched_total {
" Increase --top to see more."
} else {
""
}
);
}
}
Ok(0)
}
fn run_prune(repo_root: &Path, args: PruneArgs) -> Result<i32> {
let loaded = config::load(repo_root).unwrap_or_else(|_| config::default_config());
let keep = args
.keep
.unwrap_or_else(|| config::pointer_u64(&loaded, "/output/retention_runs", 20) as usize);
let max_bytes = args
.max_bytes
.unwrap_or_else(|| config::pointer_u64(&loaded, "/output/retention_bytes", 2_147_483_648));
let root = config::runs_dir(repo_root);
if !root.exists() {
let payload = json!({
"schema_version": 1,
"command": "prune",
"dry_run": args.dry_run,
"limits": {"max_runs": keep, "max_bytes": max_bytes},
"before": {"runs": 0, "bytes": 0},
"selected": [],
"after": {"runs": 0, "bytes": 0}
});
match args.format {
DisplayFormat::Text => println!("No run snapshots to prune."),
DisplayFormat::Json => print_text(&render_json(&payload)?),
DisplayFormat::Yaml => print_text(&serde_yaml::to_string(&payload)?),
}
return Ok(0);
}
let mut runs = fs::read_dir(&root)?
.filter_map(Result::ok)
.filter(|entry| entry.file_type().is_ok_and(|kind| kind.is_dir()))
.map(|entry| {
let bytes = directory_size(&entry.path())?;
Ok((entry, bytes))
})
.collect::<Result<Vec<_>>>()?;
runs.sort_by_key(|(entry, _)| std::cmp::Reverse(entry.file_name()));
let before_bytes = runs.iter().map(|(_, bytes)| *bytes).sum::<u64>();
let before_runs = runs.len();
let mut retained_bytes = 0u64;
let mut retained_runs = 0usize;
let mut remove = Vec::new();
let mut retention_prefix_exhausted = false;
for (entry, bytes) in runs {
if !retention_prefix_exhausted
&& retained_runs < keep
&& retained_bytes.saturating_add(bytes) <= max_bytes
{
retained_runs += 1;
retained_bytes = retained_bytes.saturating_add(bytes);
} else {
retention_prefix_exhausted = true;
remove.push((entry, bytes));
}
}
let selected = remove
.iter()
.map(|(entry, bytes)| json!({"path": entry.path(), "bytes": bytes}))
.collect::<Vec<_>>();
if args.format == DisplayFormat::Text {
for (entry, _) in &remove {
println!(
"{} {}",
if args.dry_run {
"Would remove"
} else {
"Removing"
},
entry.path().display()
);
}
}
for (entry, _) in &remove {
if !args.dry_run {
fs::remove_dir_all(entry.path())?;
}
}
let removed_bytes = remove.iter().map(|(_, bytes)| *bytes).sum::<u64>();
let payload = json!({
"schema_version": 1,
"command": "prune",
"dry_run": args.dry_run,
"limits": {"max_runs": keep, "max_bytes": max_bytes},
"before": {"runs": before_runs, "bytes": before_bytes},
"selected": selected,
"removed": {"runs": remove.len(), "bytes": removed_bytes},
"after": {"runs": retained_runs, "bytes": retained_bytes, "projected": args.dry_run}
});
match args.format {
DisplayFormat::Text => println!(
"{} {} old run snapshot(s) ({} bytes); retained {} run(s) ({} bytes).",
if args.dry_run { "Selected" } else { "Pruned" },
remove.len(),
removed_bytes,
retained_runs,
retained_bytes
),
DisplayFormat::Json => print_text(&render_json(&payload)?),
DisplayFormat::Yaml => print_text(&serde_yaml::to_string(&payload)?),
}
Ok(0)
}
fn directory_size(path: &Path) -> Result<u64> {
let mut total = 0u64;
for entry in fs::read_dir(path)? {
let entry = entry?;
let metadata = fs::symlink_metadata(entry.path())?;
if metadata.is_dir() {
total = total.saturating_add(directory_size(&entry.path())?);
} else {
total = total.saturating_add(metadata.len());
}
}
Ok(total)
}
fn run_cache(repo_root: &Path, args: CacheArgs) -> Result<i32> {
let state_root = args.state_dir.map_or_else(
|| config::slop_dir(repo_root),
|path| {
if path.is_absolute() {
path
} else {
repo_root.join(path)
}
},
);
let (payload, format) = match args.command {
CacheCommand::Status { format } => (crate::cache::status(&state_root)?, format),
CacheCommand::Prune {
max_entries,
max_bytes,
dry_run,
compact,
format,
} => (
crate::cache::prune(&state_root, max_entries, max_bytes, dry_run, compact)?,
format,
),
};
match format {
DisplayFormat::Json => print_text(&render_json(&payload)?),
DisplayFormat::Yaml => print_text(&serde_yaml::to_string(&payload)?),
DisplayFormat::Text => {
if payload["command"] == "cache status" {
println!(
"Cache {}: {} entries, {} payload bytes, {} database bytes.",
payload["status"].as_str().unwrap_or("unknown"),
payload["entries"],
payload["payload_bytes"],
payload["database_bytes"]
);
} else {
println!(
"{} {} cache entries ({} payload bytes).",
if payload["dry_run"].as_bool().unwrap_or(false) {
"Would prune"
} else {
"Pruned"
},
payload["removed_entries"],
payload["removed_payload_bytes"]
);
}
}
}
Ok(0)
}