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;
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::new(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::new(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::new(format!("no lock entry for '{id}' at target '{target}'")))?;
let expected = &target_entry.sha256;
if expected.is_empty() {
return Err(TuffError::new(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 entry.source.is_none()
&& !Path::new(&entry.source_path).is_absolute()
&& !scope_root.join(&entry.source_path).exists()
{
return Err(TuffError::new(format!(
"The recorded baseline for \"{id}\" is not cached, and its local source \"{}\" 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.",
entry.source_path
)));
}
return Err(TuffError::new(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> {
if entry.source.is_none() {
return Err(TuffError::new(
"upstream diff only available for git-sourced capabilities",
));
}
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::new(format!("unknown target '{target}'")))?;
let source = entry.source.as_ref();
if source.is_none() && is_in_place_source_path(&entry.source_path) {
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(&entry.source_path));
if !path.is_dir() {
return Err(TuffError::new(format!(
"The recorded baseline for \"{id}\" is not cached, and its local source \"{}\" 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.",
entry.source_path
)));
}
return Ok(MaterializedTree {
_sources: Vec::new(),
path,
});
}
let (source_guard, source_dir) = if let Some(source) = source {
let reference = pinned.then_some(source.source_ref.as_str());
let (guard, path, _) = git::clone_to_temp(&source.url, reference)?;
(Some(guard), path)
} else {
let source_dir = lockfile::absolutize(scope_root, Path::new(&entry.source_path));
if !source_dir.is_dir() {
return Err(TuffError::new(format!(
"The recorded baseline for \"{id}\" is not cached, and its local source \"{}\" 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.",
entry.source_path
)));
}
(None, source_dir)
};
let capability_dir = if let Some(source) = source {
git::discover_capability(&source_dir, &source.skill, entry.capability_type)?
} else {
lockfile::absolutize(scope_root, Path::new(&entry.source_path))
};
let manifest = if capability_dir.join("tuff.toml").is_file() {
load_manifest(&capability_dir)?
} else {
manifest::synthetic_manifest(&capability_dir, id, "materialized")?
};
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()
}