use std::path::{Path, PathBuf};
use clap::ValueEnum;
use serde::Serialize;
use tempfile::TempDir;
use crate::adapter::{AdapterKind, AgentAdapter, resolve_capability};
use crate::error::{Result, TuffError};
use crate::git;
use crate::lockfile::{self, CapabilitySource};
use crate::manifest::{self, load_manifest};
use crate::resolver::{self, Scope};
use crate::tree_diff::{self, FileChange};
use super::{home_dir, resolve_agent_selection};
#[derive(Debug, Clone, Copy, ValueEnum)]
pub enum DiffFormat {
Unified,
Json,
}
#[derive(Debug)]
pub(crate) struct MaterializedTree {
_sources: Vec<TempDir>,
path: PathBuf,
}
#[derive(Debug, Serialize)]
struct JsonDiff {
capability: String,
target: String,
changes: Vec<FileChange>,
}
pub fn cmd_diff(
repo_root: &Path,
capability_id: &str,
target: Option<&str>,
upstream: bool,
format: DiffFormat,
) -> Result<()> {
let (scope, entry, scope_root) = match resolver::resolve_entry(capability_id, repo_root)? {
Some((scope, entry)) => {
let root = match scope {
Scope::Project => repo_root.to_path_buf(),
Scope::Global => home_dir()?,
};
(scope, entry, root)
}
None => {
return Err(TuffError::not_found(format!(
"capability is not installed: {capability_id}"
)));
}
};
let _ = scope;
let requested = target
.map(|value| vec![value.to_string()])
.unwrap_or_default();
let targets = resolve_agent_selection(&scope_root, &requested, scope == Scope::Global)?;
let mut unified = String::new();
let mut json = Vec::new();
for target in targets {
let target_entry = entry.targets.get(&target).ok_or_else(|| {
TuffError::not_found(format!(
"'{capability_id}' is not installed for target '{target}'"
))
})?;
let live = installed_path(&scope_root, capability_id, &entry, target_entry, &target);
let baseline = if upstream {
materialize_upstream(&scope_root, capability_id, &entry, &target)?
} else {
materialize_baseline(&scope_root, capability_id, &entry, &target)?
};
let live_temp = TempDir::new()?;
if live.is_dir() {
copy_tree(&live, live_temp.path())?;
}
let comparison = tree_diff::compare(&baseline.path, live_temp.path())?;
if matches!(format, DiffFormat::Json) {
json.push(JsonDiff {
capability: capability_id.to_string(),
target,
changes: comparison.changes,
});
} else if !comparison.patch.is_empty() {
unified.push_str(&comparison.patch);
}
}
match format {
DiffFormat::Json => println!("{}", serde_json::to_string_pretty(&json)?),
DiffFormat::Unified => {
if unified.is_empty() && upstream {
println!("no upstream changes");
} else if !unified.is_empty() {
print!("{}", style_diff(&unified));
}
}
}
Ok(())
}
pub(crate) fn materialize_baseline(
scope_root: &Path,
id: &str,
entry: &lockfile::CapabilityLockEntry,
target: &str,
) -> Result<MaterializedTree> {
let target_entry = entry.targets.get(target).ok_or_else(|| {
TuffError::not_found(format!("no lock entry for '{id}' at target '{target}'"))
})?;
let expected = &target_entry.sha256;
if expected.is_empty() {
return Err(TuffError::corrupt(format!(
"lock entry for '{id}' has no materialized baseline hash"
)));
}
let home = super::home_dir()?;
if let Some(path) = crate::cache::read_verified(&home, expected)? {
return Ok(MaterializedTree {
_sources: Vec::new(),
path,
});
}
let materialized = materialize_source(scope_root, id, entry, target, true)?;
let actual = crate::cache::hash_tree(&materialized.path)?;
if actual != *expected {
if let Some(source_path) = entry.source.local_path()
&& !Path::new(source_path).is_absolute()
&& !scope_root.join(source_path).exists()
{
return Err(TuffError::not_found(format!(
"The recorded baseline for \"{id}\" is not cached, and its local source \"{source_path}\" is no longer available.\n\nRestore the source, reinstall the capability, or run the appropriate Tuff command to accept the current content as a new baseline."
)));
}
return Err(TuffError::corrupt(format!(
"recorded baseline verification failed for '{id}': expected {expected}, got {actual}; the source does not reproduce the recorded baseline"
)));
}
let cached = crate::cache::populate(&home, expected, &materialized.path)?;
Ok(MaterializedTree {
_sources: materialized._sources,
path: cached,
})
}
fn materialize_upstream(
scope_root: &Path,
id: &str,
entry: &lockfile::CapabilityLockEntry,
target: &str,
) -> Result<MaterializedTree> {
match &entry.source {
CapabilitySource::Local(_) | CapabilitySource::Pack(_) => {
return Err(TuffError::unsupported(
"upstream diff only available for git-sourced capabilities",
));
}
CapabilitySource::Catalog(_) => {
return Err(TuffError::unsupported(
"upstream diff is not available for catalog capabilities",
)
.with_hint("run 'tuff outdated' to compare against the built-in catalog"));
}
CapabilitySource::Git(_) => {}
}
materialize_source(scope_root, id, entry, target, false)
}
fn materialize_source(
scope_root: &Path,
id: &str,
entry: &lockfile::CapabilityLockEntry,
target: &str,
pinned: bool,
) -> Result<MaterializedTree> {
let adapter = AdapterKind::from_id(target)
.ok_or_else(|| TuffError::usage(format!("unknown target '{target}'")))?;
let missing_local = |source_path: &str| {
TuffError::not_found(format!(
"The recorded baseline for \"{id}\" is not cached, and its local source \"{source_path}\" is no longer available.\n\nRestore the source, reinstall the capability, or run the appropriate Tuff command to accept the current content as a new baseline."
))
};
let in_place = match &entry.source {
CapabilitySource::Local(local) => is_in_place_source_path(&local.path),
CapabilitySource::Pack(_) => true,
CapabilitySource::Git(_) | CapabilitySource::Catalog(_) => false,
};
if in_place {
let fallback = entry.source.local_path().unwrap_or_default();
let path = entry
.targets
.get(target)
.map(|target_entry| target_entry.installed_path.as_str())
.filter(|path| !path.is_empty())
.map(|path| scope_root.join(path))
.unwrap_or_else(|| scope_root.join(fallback));
if !path.is_dir() {
return Err(missing_local(fallback));
}
return Ok(MaterializedTree {
_sources: Vec::new(),
path,
});
}
let (source_guard, capability_dir) = match &entry.source {
CapabilitySource::Catalog(catalog) => {
let manifest = crate::catalog::lookup(&catalog.id)?.ok_or_else(|| {
TuffError::not_found(format!(
"The recorded baseline for \"{id}\" is not cached, and '{}' is no longer in the built-in catalog.",
catalog.id
))
})?;
return plan_into_temp(adapter, &manifest, entry, id, None);
}
CapabilitySource::Git(git) => {
let reference = pinned.then_some(git.git_ref.as_str());
let (guard, checkout, _) = git::clone_to_temp(&git.url, reference)?;
let dir = git::discover_capability(&checkout, &git.path, entry.capability_type)?;
(Some(guard), dir)
}
CapabilitySource::Local(local) => {
let dir = lockfile::absolutize(scope_root, Path::new(&local.path));
if !dir.is_dir() {
return Err(missing_local(&local.path));
}
(None, dir)
}
CapabilitySource::Pack(_) => unreachable!("pack members are materialized in place"),
};
let manifest = if capability_dir.join("tuff.toml").is_file() {
load_manifest(&capability_dir)?
} else {
manifest::synthetic_manifest(&capability_dir, id, "materialized")?
};
plan_into_temp(adapter, &manifest, entry, id, source_guard)
}
fn plan_into_temp(
adapter: AdapterKind,
manifest: &manifest::CapabilityManifest,
entry: &lockfile::CapabilityLockEntry,
id: &str,
source_guard: Option<TempDir>,
) -> Result<MaterializedTree> {
let capability = resolve_capability(manifest)?;
let temp = TempDir::new()?;
let plans = adapter.plan(&capability, temp.path())?;
let target_root = temp
.path()
.join(adapter.dir_prefix())
.join(entry.capability_type.plural_dir())
.join(id);
for planned in plans {
let path = temp.path().join(&planned.path);
if path.starts_with(&target_root) {
if let Some(parent) = path.parent() {
std::fs::create_dir_all(parent)?;
}
std::fs::write(path, planned.content)?;
}
}
let mut sources = vec![temp];
if let Some(source_guard) = source_guard {
sources.push(source_guard);
}
Ok(MaterializedTree {
_sources: sources,
path: target_root,
})
}
fn installed_path(
root: &Path,
id: &str,
entry: &lockfile::CapabilityLockEntry,
target_entry: &lockfile::TargetLockEntry,
target: &str,
) -> PathBuf {
if !target_entry.installed_path.is_empty() {
return root.join(&target_entry.installed_path);
}
let adapter = AdapterKind::from_id(target).unwrap_or(AdapterKind::OpenAgents);
root.join(adapter.dir_prefix())
.join(entry.capability_type.plural_dir())
.join(id)
}
fn is_in_place_source_path(path: &str) -> bool {
path.starts_with(".agents/") || path.starts_with(".claude/")
}
fn copy_tree(source: &Path, destination: &Path) -> Result<()> {
std::fs::create_dir_all(destination)?;
for entry in std::fs::read_dir(source)? {
let entry = entry?;
let source_path = entry.path();
let destination_path = destination.join(entry.file_name());
if source_path.is_dir() {
copy_tree(&source_path, &destination_path)?;
} else if source_path.is_file() {
std::fs::copy(source_path, destination_path)?;
}
}
Ok(())
}
fn style_diff(diff: &str) -> String {
if !super::use_color() {
return diff.to_string();
}
diff.split_inclusive('\n')
.map(|line| {
let code = if line.starts_with("+++") || line.starts_with("---") {
"36"
} else if line.starts_with('+') {
"32"
} else if line.starts_with('-') {
"31"
} else {
return line.to_string();
};
format!("\x1b[{code}m{line}\x1b[0m")
})
.collect()
}