bake-agent-context 0.3.0

// Released under the MIT License.
// Copyright, 2026, by Samuel Williams.

#[cfg(test)]
use self::test_filesystem as filesystem;
use super::installer::{ContextPackage, Installer, markdown_files};
use bake::{Error, Result};
use serde::{Deserialize, Serialize};
use socketry_markdown::{ParseOptions, mdast::Node, to_mdast};
use std::cmp::Ordering as Comparison;
use std::collections::{BTreeMap, HashMap, HashSet};
#[cfg(not(test))]
use std::fs as filesystem;
use std::path::{Path, PathBuf};
use std::sync::atomic::{AtomicU64, Ordering as AtomicOrdering};

const REGISTRY_VERSION: u32 = 1;
const REGISTRY_FILE: &str = ".agent-context-skills.json";
static STAGING_SEQUENCE: AtomicU64 = AtomicU64::new(0);

#[cfg(test)]
mod test_filesystem {
    use std::io;
    use std::path::Path;
    use std::sync::Mutex;
    use std::thread::ThreadId;

    pub(super) use std::fs::{Metadata, copy, read_to_string, remove_file};

    #[derive(Clone, Copy, Debug, Eq, PartialEq)]
    pub(super) enum Operation {
        CreateDirectory,
        CreateDirectoryTree,
        Inspect,
        Read,
        ReadDirectoryEntry,
        RenameSource,
        RenameDestination,
        RemoveDirectoryTree,
        Write,
    }

    struct Failure {
        operation: Operation,
        thread: ThreadId,
        matches: Box<dyn Fn(&Path) -> bool + Send + Sync>,
    }

    static FAILURES: Mutex<Vec<Failure>> = Mutex::new(Vec::new());

    pub(super) struct FailureGuard {
        thread: ThreadId,
    }

    impl Drop for FailureGuard {
        fn drop(&mut self) {
            FAILURES
                .lock()
                .unwrap()
                .retain(|failure| failure.thread != self.thread);
        }
    }

    pub(super) fn fail_once(
        operation: Operation,
        matches: impl Fn(&Path) -> bool + Send + Sync + 'static,
    ) -> FailureGuard {
        let thread = std::thread::current().id();
        FAILURES.lock().unwrap().push(Failure {
            operation,
            thread,
            matches: Box::new(matches),
        });
        FailureGuard { thread }
    }

    fn check_failure(operation: Operation, path: &Path) -> io::Result<()> {
        if take_failure(operation, path) {
            Err(io::Error::other("injected filesystem failure"))
        } else {
            Ok(())
        }
    }

    fn take_failure(operation: Operation, path: &Path) -> bool {
        let thread = std::thread::current().id();
        let mut failures = FAILURES.lock().unwrap();
        let failure = failures.iter().position(|failure| {
            failure.thread == thread && failure.operation == operation && (failure.matches)(path)
        });
        failure.is_some_and(|index| {
            failures.remove(index);
            true
        })
    }

    pub(super) fn create_dir(path: impl AsRef<Path>) -> io::Result<()> {
        check_failure(Operation::CreateDirectory, path.as_ref())?;
        std::fs::create_dir(path)
    }

    pub(super) fn create_dir_all(path: impl AsRef<Path>) -> io::Result<()> {
        check_failure(Operation::CreateDirectoryTree, path.as_ref())?;
        std::fs::create_dir_all(path)
    }

    pub(super) fn symlink_metadata(path: impl AsRef<Path>) -> io::Result<std::fs::Metadata> {
        check_failure(Operation::Inspect, path.as_ref())?;
        std::fs::symlink_metadata(path)
    }

    pub(super) struct ReadDir {
        inner: std::fs::ReadDir,
        fail_next_entry: bool,
    }

    impl Iterator for ReadDir {
        type Item = io::Result<std::fs::DirEntry>;

        fn next(&mut self) -> Option<Self::Item> {
            if self.fail_next_entry {
                self.fail_next_entry = false;
                return Some(Err(io::Error::other("injected filesystem failure")));
            }

            self.inner.next()
        }
    }

    pub(super) fn read_dir(path: impl AsRef<Path>) -> io::Result<ReadDir> {
        let path = path.as_ref();
        let fail_next_entry = take_failure(Operation::ReadDirectoryEntry, path);
        std::fs::read_dir(path).map(|inner| ReadDir {
            inner,
            fail_next_entry,
        })
    }

    pub(super) fn remove_dir_all(path: impl AsRef<Path>) -> io::Result<()> {
        check_failure(Operation::RemoveDirectoryTree, path.as_ref())?;
        std::fs::remove_dir_all(path)
    }

    pub(super) fn read(path: impl AsRef<Path>) -> io::Result<Vec<u8>> {
        check_failure(Operation::Read, path.as_ref())?;
        std::fs::read(path)
    }

    pub(super) fn rename(from: impl AsRef<Path>, to: impl AsRef<Path>) -> io::Result<()> {
        check_failure(Operation::RenameSource, from.as_ref())?;
        check_failure(Operation::RenameDestination, to.as_ref())?;
        std::fs::rename(from, to)
    }

    pub(super) fn write(path: impl AsRef<Path>, contents: impl AsRef<[u8]>) -> io::Result<()> {
        check_failure(Operation::Write, path.as_ref())?;
        std::fs::write(path, contents)
    }
}

/// A skill declared by a Markdown file in a dependency's `context/` directory.
#[derive(Clone, Debug)]
pub struct Skill {
    /// Globally unique installed name, prefixed with the provider crate name.
    pub name: String,
    pub description: String,
    pub package: ContextPackage,
    pub(crate) source_name: String,
    assets: Option<PathBuf>,
    body: String,
}

impl Skill {
    /// The package selector accepted by `--package`.
    pub fn package_selector(&self) -> &str {
        self.package.selector()
    }
}

#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
struct ContextFrontmatter {
    #[serde(rename = "type")]
    document_type: Option<String>,
    description: Option<String>,
}

#[derive(Serialize)]
struct SkillFrontmatter<'a> {
    name: &'a str,
    description: &'a str,
}

#[derive(Clone, Debug, Deserialize, Serialize)]
struct Registry {
    version: u32,
    skills: BTreeMap<String, SkillOwner>,
}

#[derive(Clone, Debug, Deserialize, Serialize)]
struct SkillOwner {
    package: String,
    version: String,
}

impl Default for Registry {
    fn default() -> Self {
        Self {
            version: REGISTRY_VERSION,
            skills: BTreeMap::new(),
        }
    }
}

/// Find context documents marked with `type: skill` in YAML front matter.
pub fn list_skills(installer: &Installer, package: Option<&str>) -> Result<Vec<Skill>> {
    let packages = if let Some(selector) = package {
        let Some(package) = installer.find_package(selector)? else {
            return Ok(Vec::new());
        };
        vec![package]
    } else {
        installer.packages().to_vec()
    };

    let mut skills = Vec::new();
    for package in packages {
        skills.extend(list_package_skills(&package)?);
    }

    skills.sort_by(compare_skills);
    Ok(skills)
}

fn compare_skills(left: &Skill, right: &Skill) -> Comparison {
    let package_order = left.package.name.cmp(&right.package.name);
    if package_order != Comparison::Equal {
        return package_order;
    }

    let version_order = left.package.version.cmp(&right.package.version);
    if version_order != Comparison::Equal {
        return version_order;
    }

    left.name.cmp(&right.name)
}

pub(crate) fn list_package_skills(package: &ContextPackage) -> Result<Vec<Skill>> {
    let mut skills = Vec::new();
    let mut files = markdown_files(&package.context_path)?;
    files.sort();

    for source in files {
        let contents = filesystem::read_to_string(&source)
            .map_err(|error| Error::new(format!("cannot read {}: {error}", source.display())))?;
        if let Some(skill) = parse_skill_document(package, &source, &contents)? {
            skills.push(skill);
        }
    }

    Ok(skills)
}

fn parse_skill_document(
    package: &ContextPackage,
    source: &Path,
    contents: &str,
) -> Result<Option<Skill>> {
    let mut options = ParseOptions::default();
    options.constructs.frontmatter = true;
    // MDX parsing is disabled here, so Markdown syntax itself cannot fail.
    let mut document =
        to_mdast(contents, &options).expect("Markdown parsing without MDX support is infallible");

    let Some(frontmatter) = context_frontmatter(&document, source)? else {
        return Ok(None);
    };
    let Some(document_type) = frontmatter.document_type else {
        return Ok(None);
    };
    if document_type != "skill" {
        return Err(Error::new(format!(
            "unsupported context type {document_type:?} in {}; supported type: skill",
            source.display()
        )));
    }

    if source.parent() != Some(package.context_path.as_path()) {
        return Err(Error::new(format!(
            "skill document {} must be directly inside context/",
            source.display()
        )));
    }

    let source_name = source_name(source)?;
    validate_skill_name(&source_name)?;

    let package_prefix = package.name.to_ascii_lowercase().replace('_', "-");
    let name = format!("{package_prefix}-{source_name}");
    validate_skill_name(&name)?;

    let description = frontmatter
        .description
        .map(|description| description.trim().to_owned())
        .filter(|description| !description.is_empty())
        .ok_or_else(|| {
            Error::new(format!(
                "skill {} in crate {} requires a non-empty `description`",
                name, package.name
            ))
        })?;
    if description.chars().count() > 1024 {
        return Err(Error::new(format!(
            "skill description for {name:?} exceeds the 1024 character limit"
        )));
    }

    let assets = skill_assets_path(&package.context_path, &source_name)?;
    let body = skill_body(&mut document);

    Ok(Some(Skill {
        name,
        description,
        package: package.clone(),
        source_name,
        assets,
        body,
    }))
}

fn skill_assets_path(context_path: &Path, source_name: &str) -> Result<Option<PathBuf>> {
    let assets = context_path.join(source_name);
    match filesystem::symlink_metadata(&assets) {
        Ok(metadata) if metadata.file_type().is_dir() => Ok(Some(assets)),
        Ok(_) => Err(Error::new(format!(
            "skill assets path {} is not a directory",
            assets.display()
        ))),
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => Ok(None),
        Err(error) => Err(Error::new(format!(
            "cannot inspect skill assets {}: {error}",
            assets.display()
        ))),
    }
}

fn skill_body(document: &mut Node) -> String {
    // parse_skill_document only calls this after context_frontmatter has found
    // and parsed the leading YAML block.
    let children = document
        .children_mut()
        .expect("a Markdown document root always has children");
    children.remove(0);
    document.to_markdown()
}

/// Install skills from all providers, one provider, or one named skill.
///
/// If both filters are omitted, all discovered skills are installed. Existing
/// project-owned skill directories are never replaced; installed dependency
/// skills are tracked in a registry under `.agents/skills/`.
pub fn install_skills(
    installer: &Installer,
    package_selector: Option<&str>,
    skill_name: Option<&str>,
) -> Result<Vec<String>> {
    // Resolve a package selector only once. Resolving it again after listing
    // skills introduced a second, unreachable error path and a small TOCTOU
    // window if package state ever becomes mutable.
    let (selected_package, mut skills) = if let Some(selector) = package_selector {
        let Some(package) = installer.find_package(selector)? else {
            return Err(Error::new(format!(
                "no context found for crate {selector:?}"
            )));
        };
        let skills = list_package_skills(&package)?;
        (Some(package), skills)
    } else {
        (None, list_skills(installer, None)?)
    };

    if let Some(skill_name) = skill_name {
        skills.retain(|skill| skill.name == skill_name);
        if skills.is_empty() {
            return Err(Error::new(format!(
                "no dependency skill named {skill_name:?} was found"
            )));
        }
    }

    if let Some(skill_name) = skill_name
        && skills.len() > 1
    {
        let packages = skills
            .iter()
            .map(|skill| skill.package_selector())
            .collect::<Vec<_>>()
            .join(", ");
        return Err(Error::new(format!(
            "skill {skill_name:?} is provided by multiple crates ({packages}); select one with --package"
        )));
    }

    let mut selected_names = HashSet::new();
    for skill in &skills {
        if !selected_names.insert(skill.name.as_str()) {
            return Err(Error::new(format!(
                "multiple selected crates provide skill {:?}; select one with --package",
                skill.name
            )));
        }
    }

    let reconcile_all = package_selector.is_none() && skill_name.is_none();
    let reconcile_package = if skill_name.is_none() {
        selected_package
            .as_ref()
            .map(|package| package.name.as_str())
    } else {
        None
    };

    let skills_root = installer.root().join(".agents/skills");
    ensure_directory(&skills_root)?;
    let registry_path = skills_root.join(REGISTRY_FILE);
    let (mut registry, had_registry) = load_registry_with_existence(&registry_path)?;

    let selected_by_name: HashMap<_, _> = skills
        .iter()
        .map(|skill| (skill.name.as_str(), skill))
        .collect();

    let mut destination_exists = HashMap::new();
    for skill in &skills {
        if let Some(owner) = registry.skills.get(&skill.name)
            && owner.package != skill.package.name
        {
            return Err(Error::new(format!(
                "skill {:?} is already installed from crate {:?}; it cannot be replaced by {:?}",
                skill.name, owner.package, skill.package.name
            )));
        }

        let destination = skills_root.join(&skill.name);
        let exists = path_exists(&destination)?;
        destination_exists.insert(skill.name.clone(), exists);
        if exists
            && registry
                .skills
                .get(&skill.name)
                .is_none_or(|owner| owner.package != skill.package.name)
        {
            return Err(Error::new(format!(
                "skill destination {} already exists and is not managed by Bake Agent Context",
                destination.display()
            )));
        }
    }

    let stale_skills: Vec<_> = registry
        .skills
        .iter()
        .filter(|(name, owner)| {
            !selected_by_name.contains_key(name.as_str())
                && (reconcile_all
                    || match reconcile_package {
                        Some(package) => owner.package == package,
                        None => false,
                    })
        })
        .map(|(name, _)| name.clone())
        .collect();
    let mut stale_exists = HashMap::new();
    for name in &stale_skills {
        stale_exists.insert(name.clone(), path_exists(&skills_root.join(name))?);
    }

    for name in &stale_skills {
        registry.skills.remove(name);
    }
    for skill in &skills {
        registry.skills.insert(
            skill.name.clone(),
            SkillOwner {
                package: skill.package.name.clone(),
                version: skill.package.version.clone(),
            },
        );
    }
    let encoded_registry = serde_json::to_vec_pretty(&registry)
        .expect("the skill registry contains only serializable values");
    let exclude_update =
        super::exclude::prepare(installer.root(), registry.skills.keys().cloned())?;

    let stage = staging_path(&skills_root);
    filesystem::create_dir(&stage)
        .map_err(|error| Error::new(format!("cannot create {}: {error}", stage.display())))?;
    let new_skills = stage.join("new");
    let backups = stage.join("backups");
    if let Err(error) =
        filesystem::create_dir(&new_skills).and_then(|_| filesystem::create_dir(&backups))
    {
        let _ = filesystem::remove_dir_all(&stage);
        return Err(Error::new(format!(
            "cannot prepare {}: {error}",
            stage.display()
        )));
    }

    for skill in &skills {
        let result = write_staged_skill(skill, &new_skills.join(&skill.name));
        if let Err(error) = result {
            let _ = filesystem::remove_dir_all(&stage);
            return Err(error);
        }
    }

    if let Err(error) = apply_exclude_update(exclude_update) {
        let _ = filesystem::remove_dir_all(&stage);
        return Err(error);
    }

    let mut changes = Vec::new();
    for skill in &skills {
        let destination = skills_root.join(&skill.name);
        let backup = backups.join(&skill.name);
        let had_previous = destination_exists[&skill.name];
        if had_previous && let Err(error) = filesystem::rename(&destination, &backup) {
            rollback(&skills_root, &backups, &changes);
            let _ = filesystem::remove_dir_all(&stage);
            return Err(Error::new(format!(
                "cannot move existing skill {}: {error}",
                destination.display()
            )));
        }

        if let Err(error) = filesystem::rename(new_skills.join(&skill.name), &destination) {
            if had_previous {
                let _ = filesystem::rename(&backup, &destination);
            }
            rollback(&skills_root, &backups, &changes);
            let _ = filesystem::remove_dir_all(&stage);
            return Err(Error::new(format!(
                "cannot install skill {}: {error}",
                destination.display()
            )));
        }
        changes.push(AppliedChange::Installed {
            name: skill.name.clone(),
            had_previous,
        });
    }

    for name in &stale_skills {
        let destination = skills_root.join(name);
        if stale_exists[name] {
            if let Err(error) = filesystem::rename(&destination, backups.join(name)) {
                rollback(&skills_root, &backups, &changes);
                let _ = filesystem::remove_dir_all(&stage);
                return Err(Error::new(format!(
                    "cannot remove stale installed skill {}: {error}",
                    destination.display()
                )));
            }
            changes.push(AppliedChange::Removed { name: name.clone() });
        }
    }

    let staged_registry = stage.join("registry.json");
    if let Err(error) = filesystem::write(&staged_registry, encoded_registry) {
        rollback(&skills_root, &backups, &changes);
        let _ = filesystem::remove_dir_all(&stage);
        return Err(Error::new(format!(
            "cannot write staged skill registry {}: {error}",
            staged_registry.display()
        )));
    }

    if had_registry
        && let Err(error) = filesystem::rename(&registry_path, backups.join("registry.json"))
    {
        rollback(&skills_root, &backups, &changes);
        let _ = filesystem::remove_dir_all(&stage);
        return Err(Error::new(format!(
            "cannot move existing skill registry {}: {error}",
            registry_path.display()
        )));
    }
    if let Err(error) = filesystem::rename(&staged_registry, &registry_path) {
        if had_registry {
            let _ = filesystem::rename(backups.join("registry.json"), &registry_path);
        }
        rollback(&skills_root, &backups, &changes);
        let _ = filesystem::remove_dir_all(&stage);
        return Err(Error::new(format!(
            "cannot update skill registry {}: {error}",
            registry_path.display()
        )));
    }

    filesystem::remove_dir_all(&stage)
        .map_err(|error| Error::new(format!("cannot remove {}: {error}", stage.display())))?;

    Ok(skills
        .iter()
        .map(|skill| format!("{} ({})", skill.name, skill.package_selector()))
        .collect())
}

fn apply_exclude_update(update: Option<super::exclude::Update>) -> Result<()> {
    if let Some(update) = update {
        update.apply()?;
    }
    Ok(())
}

fn staging_path(skills_root: &Path) -> PathBuf {
    let sequence = STAGING_SEQUENCE.fetch_add(1, AtomicOrdering::Relaxed);
    skills_root.join(format!(
        ".agent-context-staging-{}-{sequence}",
        std::process::id()
    ))
}

pub(crate) fn frontmatter_description(document: &Node, source: &Path) -> Result<Option<String>> {
    let Some(frontmatter) = context_frontmatter(document, source)? else {
        return Ok(None);
    };
    let Some(description) = frontmatter.description else {
        return Ok(None);
    };
    let description = description.trim();
    if description.is_empty() {
        return Ok(None);
    }
    Ok(Some(description.to_owned()))
}

fn context_frontmatter(document: &Node, source: &Path) -> Result<Option<ContextFrontmatter>> {
    let children = document
        .children()
        .expect("a Markdown document root always has children");
    let Some(Node::Yaml(frontmatter)) = children.first() else {
        return Ok(None);
    };

    serde_yaml_ng::from_str(&frontmatter.value)
        .map(Some)
        .map_err(|error| {
            Error::new(format!(
                "invalid YAML front matter in {}: {error}",
                source.display()
            ))
        })
}

fn validate_skill_name(name: &str) -> Result<()> {
    let valid = !name.is_empty()
        && name.len() <= 64
        && !name.starts_with('-')
        && !name.ends_with('-')
        && !name.contains("--")
        && name
            .bytes()
            .all(|byte| byte.is_ascii_lowercase() || byte.is_ascii_digit() || byte == b'-');
    if valid {
        Ok(())
    } else {
        Err(Error::new(format!(
            "invalid skill name {name:?}; use 1–64 lowercase ASCII letters, digits, or single hyphens"
        )))
    }
}

fn source_name(source: &Path) -> Result<String> {
    let Some(stem) = source.file_stem().and_then(|stem| stem.to_str()) else {
        return Err(Error::new(format!(
            "invalid skill filename: {}",
            source.display()
        )));
    };
    Ok(stem.to_owned())
}

fn write_staged_skill(skill: &Skill, destination: &Path) -> Result<()> {
    filesystem::create_dir_all(destination)
        .map_err(|error| Error::new(format!("cannot create {}: {error}", destination.display())))?;

    if let Some(assets) = &skill.assets {
        copy_skill_assets(assets, destination, true)?;
    }

    let metadata = SkillFrontmatter {
        name: &skill.name,
        description: &skill.description,
    };
    let yaml = serde_yaml_ng::to_string(&metadata)
        .expect("skill front matter contains only serializable strings");
    let mut output = format!("---\n{yaml}---\n\n");
    output.push_str(&skill.body);
    if !output.ends_with('\n') {
        output.push('\n');
    }

    let skill_file = destination.join("SKILL.md");
    filesystem::write(&skill_file, output)
        .map_err(|error| Error::new(format!("cannot write {}: {error}", skill_file.display())))
}

fn copy_skill_assets(source: &Path, destination: &Path, top_level: bool) -> Result<()> {
    let entries = filesystem::read_dir(source)
        .map_err(|error| Error::new(format!("cannot read {}: {error}", source.display())))?;
    let mut entries = entries.collect::<std::io::Result<Vec<_>>>()?;
    entries.sort_by_key(|entry| entry.file_name());

    for entry in entries {
        let source_path = entry.path();
        let destination_path = destination.join(entry.file_name());
        copy_skill_asset(&source_path, &destination_path, top_level)?;
    }

    Ok(())
}

fn copy_skill_asset(source: &Path, destination: &Path, top_level: bool) -> Result<()> {
    let metadata = inspect_skill_asset(source)?;
    let file_type = metadata.file_type();

    if file_type.is_symlink() {
        return Err(Error::new(format!(
            "skill assets cannot contain symbolic links: {}",
            source.display()
        )));
    } else if file_type.is_dir() {
        filesystem::create_dir(destination).map_err(|error| {
            Error::new(format!("cannot create {}: {error}", destination.display()))
        })?;
        copy_skill_assets(source, destination, false)?;
    } else if file_type.is_file() {
        if top_level
            && source
                .file_name()
                .unwrap_or_default()
                .to_string_lossy()
                .eq_ignore_ascii_case("SKILL.md")
        {
            return Err(Error::new(format!(
                "{} is reserved for the generated skill instructions",
                source.display()
            )));
        }
        filesystem::copy(source, destination)
            .map(|_| ())
            .map_err(|error| {
                Error::new(format!(
                    "cannot copy {} to {}: {error}",
                    source.display(),
                    destination.display()
                ))
            })?;
    } else {
        return Err(Error::new(format!(
            "unsupported skill asset: {}",
            source.display()
        )));
    }
    Ok(())
}

fn inspect_skill_asset(path: &Path) -> Result<filesystem::Metadata> {
    filesystem::symlink_metadata(path)
        .map_err(|error| Error::new(format!("cannot inspect {}: {error}", path.display())))
}

fn ensure_directory(path: &Path) -> Result<()> {
    match filesystem::symlink_metadata(path) {
        Ok(metadata) if metadata.file_type().is_dir() => Ok(()),
        Ok(_) => Err(Error::new(format!(
            "skill installation path {} is not a regular directory",
            path.display()
        ))),
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => {
            match filesystem::create_dir_all(path) {
                Ok(()) => Ok(()),
                Err(error) => Err(Error::new(format!(
                    "cannot create {}: {error}",
                    path.display()
                ))),
            }
        }
        Err(error) => Err(Error::new(format!(
            "cannot inspect {}: {error}",
            path.display()
        ))),
    }
}

pub(crate) fn installed_skill_names(root: &Path) -> Result<Vec<String>> {
    let registry_path = root.join(".agents/skills").join(REGISTRY_FILE);
    let registry = load_registry(&registry_path)?;
    Ok(registry.skills.keys().cloned().collect())
}

fn load_registry(path: &Path) -> Result<Registry> {
    load_registry_with_existence(path).map(|(registry, _)| registry)
}

fn load_registry_with_existence(path: &Path) -> Result<(Registry, bool)> {
    let metadata = match filesystem::symlink_metadata(path) {
        Ok(metadata) => metadata,
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => {
            return Ok((Registry::default(), false));
        }
        Err(error) => {
            return Err(Error::new(format!(
                "cannot inspect {}: {error}",
                path.display()
            )));
        }
    };
    if !metadata.file_type().is_file() {
        return Err(Error::new(format!(
            "skill registry {} is not a regular file",
            path.display()
        )));
    }

    let bytes = match filesystem::read(path) {
        Ok(bytes) => bytes,
        Err(error) => {
            return Err(Error::new(format!(
                "cannot read {}: {error}",
                path.display()
            )));
        }
    };
    let registry: Registry = serde_json::from_slice(&bytes).map_err(|error| {
        Error::new(format!(
            "invalid skill registry {}: {error}",
            path.display()
        ))
    })?;
    if registry.version != REGISTRY_VERSION {
        return Err(Error::new(format!(
            "unsupported skill registry version {} in {}",
            registry.version,
            path.display()
        )));
    }
    for name in registry.skills.keys() {
        validate_skill_name(name)?;
    }
    Ok((registry, true))
}

fn path_exists(path: &Path) -> Result<bool> {
    match filesystem::symlink_metadata(path) {
        Ok(_) => Ok(true),
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => Ok(false),
        Err(error) => Err(Error::new(format!(
            "cannot inspect {}: {error}",
            path.display()
        ))),
    }
}

enum AppliedChange {
    Installed { name: String, had_previous: bool },
    Removed { name: String },
}

fn rollback(root: &Path, backups: &Path, changes: &[AppliedChange]) {
    for change in changes.iter().rev() {
        match change {
            AppliedChange::Installed { name, had_previous } => {
                let destination = root.join(name);
                let _ = remove_existing(&destination);
                if *had_previous {
                    let _ = filesystem::rename(backups.join(name), destination);
                }
            }
            AppliedChange::Removed { name } => {
                let _ = filesystem::rename(backups.join(name), root.join(name));
            }
        }
    }
}

fn remove_existing(path: &Path) -> Result<()> {
    let metadata = match filesystem::symlink_metadata(path) {
        Ok(metadata) => metadata,
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => return Ok(()),
        Err(error) => {
            return Err(Error::new(format!(
                "cannot inspect {}: {error}",
                path.display()
            )));
        }
    };
    let result = if metadata.file_type().is_dir() {
        filesystem::remove_dir_all(path)
    } else {
        filesystem::remove_file(path)
    };
    result.map_err(|error| Error::new(format!("cannot remove {}: {error}", path.display())))
}

#[cfg(test)]
mod tests {
    use super::*;
    use std::fs;
    use tempfile::tempdir;

    fn package(root: &Path, name: &str, version: &str) -> ContextPackage {
        let context_path = root.join(format!("{name}-{version}/context"));
        fs::create_dir_all(&context_path).unwrap();
        super::super::installer::ContextPackage::for_test(name, version, context_path)
    }

    fn make_installer(root: &Path, packages: Vec<ContextPackage>) -> Installer {
        super::super::installer::Installer::for_test(root, packages)
    }

    fn write(root: &Path, relative: &str, contents: &str) {
        let path = root.join(relative);
        fs::create_dir_all(path.parent().unwrap()).unwrap();
        fs::write(path, contents).unwrap();
    }

    fn skill_document(description: &str, body: &str) -> String {
        format!("---\ntype: skill\ndescription: {description}\n---\n\n{body}")
    }

    fn write_skill(package: &ContextPackage, file: &str, contents: &str) {
        write(&package.context_path, file, contents);
    }

    fn error_for_document(name: &str, file: &str, contents: &str) -> String {
        let directory = tempdir().unwrap();
        let package = package(directory.path(), name, "1.0.0");
        write_skill(&package, file, contents);
        list_package_skills(&package).err().unwrap().to_string()
    }

    #[test]
    fn discovers_skills_in_sorted_order_with_normalized_package_prefixes() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let later = package(root, "zeta", "1.0.0");
        let earlier = package(root, "alpha_provider", "2.0.0");
        write_skill(
            &later,
            "second.md",
            &skill_document(" Second skill. ", "# Second"),
        );
        write_skill(
            &earlier,
            "first.md",
            &skill_document("First skill.", "# First"),
        );
        write_skill(&earlier, "ordinary.md", "# Ordinary context\n");
        write_skill(
            &earlier,
            "other-type.md",
            "---\ndescription: not opted in\n---\n\n# Ordinary\n",
        );

        let installer = make_installer(root, vec![later, earlier]);
        let skills = list_skills(&installer, None).unwrap();
        assert_eq!(
            skills
                .iter()
                .map(|skill| skill.name.as_str())
                .collect::<Vec<_>>(),
            ["alpha-provider-first", "zeta-second",]
        );
        assert_eq!(skills[0].package_selector(), "alpha_provider@2.0.0");
        assert_eq!(skills[0].description, "First skill.");
        assert!(list_skills(&installer, Some("missing")).unwrap().is_empty());
        assert_eq!(
            list_skills(&installer, Some("zeta@1.0.0")).unwrap().len(),
            1
        );
    }

    #[test]
    fn sorts_skills_by_provider_name_version_and_skill_name() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let newer = package(root, "provider", "2.0.0");
        let older = package(root, "provider", "1.0.0");
        let alpha = package(root, "alpha", "1.0.0");
        write_skill(&newer, "first.md", &skill_document("First.", "# First"));
        write_skill(&older, "zeta.md", &skill_document("Zeta.", "# Zeta"));
        write_skill(&older, "alpha.md", &skill_document("Alpha.", "# Alpha"));
        write_skill(&alpha, "one.md", &skill_document("One.", "# One"));

        let skills = list_skills(&make_installer(root, vec![newer, older, alpha]), None).unwrap();
        let names: Vec<_> = skills.iter().map(|skill| skill.name.as_str()).collect();
        assert_eq!(
            names,
            [
                "alpha-one",
                "provider-alpha",
                "provider-zeta",
                "provider-first"
            ]
        );
    }

    #[test]
    fn rejects_unsupported_nested_invalid_and_incomplete_skill_documents() {
        assert!(
            error_for_document(
                "provider",
                "unsupported.md",
                "---\ntype: guide\ndescription: Guide.\n---\n\n# Guide\n"
            )
            .contains("unsupported context type")
        );
        assert!(
            error_for_document(
                "provider",
                "nested/skill.md",
                &skill_document("Nested skill.", "# Skill\n")
            )
            .contains("directly inside context")
        );
        assert!(
            error_for_document(
                "provider",
                "Bad_Name.md",
                &skill_document("Invalid name.", "# Skill\n")
            )
            .contains("invalid skill name")
        );
        assert!(
            error_for_document(
                &"p".repeat(61),
                "name.md",
                &skill_document("Long prefix.", "# Skill\n")
            )
            .contains("invalid skill name")
        );
        assert!(
            error_for_document(
                "provider",
                "missing-description.md",
                "---\ntype: skill\n---\n\n# Skill\n"
            )
            .contains("requires a non-empty")
        );
        assert!(
            error_for_document(
                "provider",
                "blank-description.md",
                "---\ntype: skill\ndescription: '  '\n---\n\n# Skill\n"
            )
            .contains("requires a non-empty")
        );
        assert!(
            error_for_document(
                "provider",
                "long-description.md",
                &skill_document(&"x".repeat(1025), "# Skill\n")
            )
            .contains("1024 character limit")
        );
        assert!(
            error_for_document(
                "provider",
                "unknown-key.md",
                "---\ntype: skill\ndescription: Skill.\nunknown: value\n---\n\n# Skill\n"
            )
            .contains("invalid YAML front matter")
        );
    }

    #[test]
    fn propagates_skill_discovery_errors_through_public_operations() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(
            &provider,
            "unsupported.md",
            "---\ntype: guide\ndescription: Guide.\n---\n\n# Guide\n",
        );
        let installer = make_installer(root, vec![provider]);

        assert!(
            list_skills(&installer, None)
                .unwrap_err()
                .to_string()
                .contains("unsupported context type")
        );
        assert!(
            install_skills(&installer, None, None)
                .unwrap_err()
                .to_string()
                .contains("unsupported context type")
        );
        assert!(
            install_skills(&installer, Some("provider@1.0.0"), None)
                .unwrap_err()
                .to_string()
                .contains("unsupported context type")
        );
    }

    #[test]
    fn reports_context_directory_read_errors_during_skill_discovery() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        fs::remove_dir(&provider.context_path).unwrap();
        fs::write(&provider.context_path, "not a directory").unwrap();

        assert!(
            list_package_skills(&provider)
                .unwrap_err()
                .to_string()
                .contains("cannot read")
        );
    }

    #[cfg(unix)]
    #[test]
    fn parses_invalid_unicode_filenames_without_creating_them_on_disk() {
        use std::os::unix::ffi::OsStrExt;

        let directory = tempdir().unwrap();
        let provider = package(directory.path(), "provider", "1.0.0");
        let source = provider
            .context_path
            .join(std::ffi::OsStr::from_bytes(b"invalid\xff.md"));
        let error = parse_skill_document(
            &provider,
            &source,
            &skill_document("Invalid filename.", "# Skill\n"),
        )
        .unwrap_err()
        .to_string();
        assert!(error.contains("invalid skill filename"));
    }

    #[test]
    fn validates_skill_assets_and_frontmatter_structure() {
        let directory = tempdir().unwrap();
        let package = package(directory.path(), "provider", "1.0.0");
        write_skill(&package, "asset.md", &skill_document("Asset.", "# Asset\n"));
        fs::write(package.context_path.join("asset"), "not a directory").unwrap();
        assert!(
            list_package_skills(&package)
                .err()
                .unwrap()
                .to_string()
                .contains("is not a directory")
        );

        let blocker = directory.path().join("asset-parent-is-file");
        fs::write(&blocker, "file").unwrap();
        let failure_path = blocker.join("skill");
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });
        assert!(
            skill_assets_path(&blocker, "skill")
                .err()
                .unwrap()
                .to_string()
                .contains("cannot inspect skill assets")
        );

        let no_frontmatter = to_mdast("# Heading\n", &ParseOptions::default()).unwrap();
        assert!(
            context_frontmatter(&no_frontmatter, Path::new("plain.md"))
                .unwrap()
                .is_none()
        );
        assert!(
            frontmatter_description(&no_frontmatter, Path::new("plain.md"))
                .unwrap()
                .is_none()
        );
        assert!(
            parse_skill_document(&package, Path::new("plain.md"), "# Plain\n")
                .unwrap()
                .is_none()
        );

        assert!(validate_skill_name("valid-name-12").is_ok());
        for invalid in [
            "",
            "-first",
            "last-",
            "double--dash",
            "Upper",
            "white space",
            &"a".repeat(65),
        ] {
            assert!(validate_skill_name(invalid).is_err(), "{invalid:?}");
        }
    }

    #[test]
    fn normalizes_frontmatter_descriptions_and_omits_blank_descriptions() {
        let mut options = ParseOptions::default();
        options.constructs.frontmatter = true;
        let document = to_mdast(
            "---\ndescription: \"  A useful guide.  \"\n---\n\n# Guide\n",
            &options,
        )
        .unwrap();
        assert_eq!(
            frontmatter_description(&document, Path::new("guide.md")).unwrap(),
            Some("A useful guide.".to_owned())
        );

        let document = to_mdast("---\ndescription: \"   \"\n---\n\n# Guide\n", &options).unwrap();
        assert_eq!(
            frontmatter_description(&document, Path::new("guide.md")).unwrap(),
            None
        );
    }

    #[cfg(unix)]
    #[test]
    fn reports_invalid_filenames_and_skill_asset_inspection_errors() {
        use std::os::unix::ffi::OsStrExt;

        assert_eq!(
            source_name(Path::new("valid-name.md")).unwrap(),
            "valid-name"
        );
        let invalid_filename = Path::new(std::ffi::OsStr::from_bytes(b"invalid\xff.md"));
        assert!(
            source_name(invalid_filename)
                .unwrap_err()
                .to_string()
                .contains("invalid skill filename")
        );

        let directory = tempdir().unwrap();
        let error = inspect_skill_asset(&directory.path().join("missing/assets"))
            .unwrap_err()
            .to_string();
        assert!(error.contains("cannot inspect"));
    }

    #[cfg(unix)]
    #[test]
    fn reports_skill_removal_errors() {
        use std::os::unix::fs::PermissionsExt;

        let directory = tempdir().unwrap();
        let parent = directory.path().join("skills");
        fs::create_dir(&parent).unwrap();
        let skill = parent.join("installed");
        fs::write(&skill, "previous skill").unwrap();
        fs::set_permissions(&parent, fs::Permissions::from_mode(0o555)).unwrap();

        let result = remove_existing(&skill);
        fs::set_permissions(&parent, fs::Permissions::from_mode(0o755)).unwrap();

        assert!(result.unwrap_err().to_string().contains("cannot remove"));
    }

    #[test]
    fn staged_skill_includes_assets_frontmatter_and_final_newline() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let assets = root.join("assets");
        fs::create_dir_all(assets.join("references")).unwrap();
        fs::write(assets.join("references/guide.md"), "Guide.\n").unwrap();
        fs::write(assets.join("alpha.txt"), "Alpha asset.\n").unwrap();
        fs::write(assets.join("zeta.txt"), "Zeta asset.\n").unwrap();
        let package = package(root, "provider", "1.0.0");
        let skill = Skill {
            name: "provider-example".to_owned(),
            description: "Example skill.".to_owned(),
            package,
            source_name: "example".to_owned(),
            assets: Some(assets),
            body: "# Example".to_owned(),
        };
        let destination = root.join("installed/provider-example");
        write_staged_skill(&skill, &destination).unwrap();
        let markdown = fs::read_to_string(destination.join("SKILL.md")).unwrap();
        assert!(
            markdown
                .starts_with("---\nname: provider-example\ndescription: Example skill.\n---\n\n")
        );
        assert!(markdown.ends_with("# Example\n"));
        assert_eq!(
            fs::read_to_string(destination.join("references/guide.md")).unwrap(),
            "Guide.\n"
        );
        assert_eq!(
            fs::read_to_string(destination.join("alpha.txt")).unwrap(),
            "Alpha asset.\n"
        );
        assert_eq!(
            fs::read_to_string(destination.join("zeta.txt")).unwrap(),
            "Zeta asset.\n"
        );

        let invalid_assets = root.join("invalid-assets");
        fs::write(&invalid_assets, "not a directory").unwrap();
        let invalid_skill = Skill {
            assets: Some(invalid_assets),
            ..skill.clone()
        };
        assert!(
            write_staged_skill(&invalid_skill, &root.join("invalid-install"))
                .unwrap_err()
                .to_string()
                .contains("cannot read")
        );

        let bad_destination = root.join("blocked");
        fs::write(&bad_destination, "file").unwrap();
        assert!(write_staged_skill(&skill, &bad_destination).is_err());

        let blocked_skill = root.join("blocked-skill");
        fs::create_dir_all(blocked_skill.join("SKILL.md")).unwrap();
        assert!(
            write_staged_skill(&skill, &blocked_skill)
                .unwrap_err()
                .to_string()
                .contains("cannot write")
        );
    }

    #[test]
    fn reports_skill_asset_directory_entry_errors() {
        let directory = tempdir().unwrap();
        let assets = directory.path().join("assets");
        let destination = directory.path().join("destination");
        fs::create_dir(&assets).unwrap();
        fs::create_dir(&destination).unwrap();

        let failure_path = assets.clone();
        let _failure = filesystem::fail_once(
            test_filesystem::Operation::ReadDirectoryEntry,
            move |path| path == failure_path,
        );

        let error = copy_skill_assets(&assets, &destination, true).unwrap_err();

        assert!(error.to_string().contains("injected filesystem failure"));
    }

    #[cfg(unix)]
    #[test]
    fn reports_context_document_read_errors() {
        use std::os::unix::fs::PermissionsExt;

        let directory = tempdir().unwrap();
        let package = package(directory.path(), "provider", "1.0.0");
        let document = package.context_path.join("unreadable.md");
        fs::write(&document, "---\ntype: skill\ndescription: Skill.\n---\n").unwrap();
        let mut permissions = fs::metadata(&document).unwrap().permissions();
        permissions.set_mode(0o0);
        fs::set_permissions(&document, permissions).unwrap();

        let error = list_package_skills(&package).unwrap_err();
        assert!(error.to_string().contains("cannot read"));

        let mut permissions = fs::metadata(&document).unwrap().permissions();
        permissions.set_mode(0o600);
        fs::set_permissions(&document, permissions).unwrap();
    }

    #[cfg(unix)]
    #[test]
    fn rejects_symlinks_reserved_files_and_unsupported_skill_assets() {
        use std::os::unix::fs::symlink;
        use std::os::unix::net::UnixListener;

        let directory = tempdir().unwrap();
        let root = directory.path();
        let assets = root.join("assets");
        let destination = root.join("destination");
        fs::create_dir_all(&assets).unwrap();
        fs::create_dir_all(&destination).unwrap();
        let target = root.join("target");
        fs::write(&target, "target").unwrap();
        symlink(&target, assets.join("link")).unwrap();
        assert!(
            copy_skill_assets(&assets, &destination, true)
                .err()
                .unwrap()
                .to_string()
                .contains("symbolic links")
        );

        fs::remove_file(assets.join("link")).unwrap();
        fs::write(assets.join("skill.MD"), "reserved").unwrap();
        assert!(
            copy_skill_assets(&assets, &destination, true)
                .err()
                .unwrap()
                .to_string()
                .contains("reserved")
        );

        fs::remove_file(assets.join("skill.MD")).unwrap();
        let socket_path = assets.join("socket");
        let _listener = UnixListener::bind(&socket_path).unwrap();
        assert!(
            copy_skill_assets(&assets, &destination, true)
                .err()
                .unwrap()
                .to_string()
                .contains("unsupported skill asset")
        );
        drop(_listener);
        fs::remove_file(socket_path).unwrap();

        let nested = assets.join("nested");
        fs::create_dir(&nested).unwrap();
        let nested_socket_path = nested.join("socket");
        let nested_listener = UnixListener::bind(&nested_socket_path).unwrap();
        assert!(
            copy_skill_assets(&assets, &destination, true)
                .unwrap_err()
                .to_string()
                .contains("unsupported skill asset")
        );
        drop(nested_listener);
        fs::remove_file(nested_socket_path).unwrap();
        fs::remove_dir(nested).unwrap();

        let copy_source = root.join("copy-source");
        let copy_destination = root.join("copy-destination");
        fs::create_dir_all(&copy_source).unwrap();
        fs::create_dir_all(copy_destination.join("note.txt")).unwrap();
        fs::write(copy_source.join("note.txt"), "note").unwrap();
        assert!(
            copy_skill_assets(&copy_source, &copy_destination, true)
                .err()
                .unwrap()
                .to_string()
                .contains("cannot copy")
        );

        let missing = root.join("missing");
        assert!(copy_skill_assets(&missing, &destination, true).is_err());
        assert!(
            copy_skill_asset(&missing, &destination.join("missing"), true)
                .unwrap_err()
                .to_string()
                .contains("cannot inspect")
        );
        fs::create_dir(assets.join("folder")).unwrap();
        fs::create_dir(destination.join("folder")).unwrap();
        assert!(copy_skill_assets(&assets, &destination, true).is_err());
    }

    #[test]
    fn validates_skill_registry_and_installation_directory_states() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let registry_path = root.join("registry.json");
        assert_eq!(
            load_registry(&registry_path).unwrap().version,
            REGISTRY_VERSION
        );
        assert!(
            !load_registry_with_existence(&root.join("absent.json"))
                .unwrap()
                .1
        );
        assert!(installed_skill_names(root).unwrap().is_empty());

        fs::create_dir(&registry_path).unwrap();
        assert!(
            load_registry(&registry_path)
                .err()
                .unwrap()
                .to_string()
                .contains("not a regular file")
        );
        fs::remove_dir(&registry_path).unwrap();
        fs::write(&registry_path, "not json").unwrap();
        assert!(
            load_registry(&registry_path)
                .err()
                .unwrap()
                .to_string()
                .contains("invalid skill registry")
        );
        fs::write(&registry_path, r#"{"version": 2, "skills": {}}"#).unwrap();
        assert!(
            load_registry(&registry_path)
                .err()
                .unwrap()
                .to_string()
                .contains("unsupported skill registry version")
        );
        fs::write(&registry_path, r#"{"version": 1, "skills": {"Bad_Name": {"package": "provider", "version": "1.0.0"}}}"#).unwrap();
        assert!(
            load_registry(&registry_path)
                .err()
                .unwrap()
                .to_string()
                .contains("invalid skill name")
        );

        let blocker = root.join("registry-parent-is-file");
        fs::write(&blocker, "file").unwrap();
        let blocked_registry_path = blocker.join("registry.json");
        let failure_path = blocked_registry_path.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });
        assert!(
            load_registry(&blocked_registry_path)
                .err()
                .unwrap()
                .to_string()
                .contains("cannot inspect")
        );

        assert!(path_exists(&registry_path).unwrap());
        assert!(!path_exists(&root.join("absent")).unwrap());
        let blocker = root.join("blocker");
        fs::write(&blocker, "file").unwrap();
        let child = blocker.join("child");
        let failure_path = child.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });
        assert!(path_exists(&child).is_err());
        let failure_path = child.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });
        assert!(remove_existing(&child).is_err());
        assert!(ensure_directory(&blocker).is_err());
        assert!(ensure_directory(&blocker.join("child")).is_err());
        let new_directory = root.join("new-directory");
        ensure_directory(&new_directory).unwrap();
        ensure_directory(&new_directory).unwrap();

        let removable_file = root.join("removable-file");
        fs::write(&removable_file, "file").unwrap();
        remove_existing(&removable_file).unwrap();
        assert!(!removable_file.exists());
    }

    #[test]
    fn reconciles_owned_skills_and_rejects_missing_or_ambiguous_selections() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let first = package(root, "provider", "1.0.0");
        let second = package(root, "provider", "2.0.0");
        write_skill(&first, "one.md", &skill_document("One.", "# One\n"));
        write_skill(&second, "one.md", &skill_document("One v2.", "# One\n"));
        let installer = make_installer(root, vec![first.clone(), second.clone()]);

        assert!(list_skills(&installer, Some("provider")).is_err());
        assert!(install_skills(&installer, Some("provider"), None).is_err());

        let error = install_skills(&installer, None, Some("provider-one"))
            .err()
            .unwrap();
        assert!(error.to_string().contains("provided by multiple crates"));
        let error = install_skills(&installer, None, None).err().unwrap();
        assert!(
            error
                .to_string()
                .contains("multiple selected crates provide skill")
        );
        assert!(install_skills(&installer, None, Some("unknown")).is_err());
        assert!(install_skills(&installer, Some("missing"), None).is_err());

        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(&provider, "one.md", &skill_document("One.", "# One\n"));
        let installer = make_installer(root, vec![provider.clone()]);
        let skills_root = root.join(".agents/skills");
        fs::create_dir_all(&skills_root).unwrap();
        let registry = Registry {
            version: REGISTRY_VERSION,
            skills: BTreeMap::from([(
                "provider-one".to_owned(),
                SkillOwner {
                    package: "different-provider".to_owned(),
                    version: "1.0.0".to_owned(),
                },
            )]),
        };
        fs::write(
            skills_root.join(REGISTRY_FILE),
            serde_json::to_vec(&registry).unwrap(),
        )
        .unwrap();
        assert!(
            install_skills(&installer, None, None)
                .err()
                .unwrap()
                .to_string()
                .contains("already installed from crate")
        );

        let directory = tempdir().unwrap();
        let root = directory.path();
        let empty = make_installer(root, Vec::new());
        assert!(install_skills(&empty, None, None).unwrap().is_empty());
        assert!(install_skills(&empty, None, None).unwrap().is_empty());
        assert!(root.join(".agents/skills").join(REGISTRY_FILE).is_file());
    }

    #[test]
    fn reconciliation_removes_stale_skills_and_preserves_other_packages() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        let other = package(root, "other", "1.0.0");
        let installer = make_installer(root, vec![provider.clone(), other]);
        let skills_root = root.join(".agents/skills");
        fs::create_dir_all(skills_root.join("provider-stale")).unwrap();
        fs::create_dir_all(skills_root.join("other-stale")).unwrap();
        let registry = Registry {
            version: REGISTRY_VERSION,
            skills: BTreeMap::from([
                (
                    "provider-stale".to_owned(),
                    SkillOwner {
                        package: "provider".to_owned(),
                        version: "0.9.0".to_owned(),
                    },
                ),
                (
                    "other-stale".to_owned(),
                    SkillOwner {
                        package: "other".to_owned(),
                        version: "0.9.0".to_owned(),
                    },
                ),
                (
                    "provider-vanished".to_owned(),
                    SkillOwner {
                        package: "provider".to_owned(),
                        version: "0.8.0".to_owned(),
                    },
                ),
            ]),
        };
        fs::write(
            skills_root.join(REGISTRY_FILE),
            serde_json::to_vec(&registry).unwrap(),
        )
        .unwrap();

        assert!(
            install_skills(&installer, Some("provider@1.0.0"), None)
                .unwrap()
                .is_empty()
        );
        assert!(!skills_root.join("provider-stale").exists());
        assert!(skills_root.join("other-stale").is_dir());
        let updated = load_registry(&skills_root.join(REGISTRY_FILE)).unwrap();
        assert!(!updated.skills.contains_key("provider-stale"));
        assert!(!updated.skills.contains_key("provider-vanished"));
        assert!(updated.skills.contains_key("other-stale"));
    }

    #[test]
    fn installing_one_skill_preserves_stale_skills_from_other_installations() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(&provider, "one.md", &skill_document("One.", "# One\n"));
        let installer = make_installer(root, vec![provider]);
        let skills_root = root.join(".agents/skills");
        let stale_skill = skills_root.join("provider-stale");
        fs::create_dir_all(&stale_skill).unwrap();
        fs::write(stale_skill.join("SKILL.md"), "stale skill\n").unwrap();
        let registry = Registry {
            version: REGISTRY_VERSION,
            skills: BTreeMap::from([(
                "provider-stale".to_owned(),
                SkillOwner {
                    package: "provider".to_owned(),
                    version: "0.9.0".to_owned(),
                },
            )]),
        };
        fs::write(
            skills_root.join(REGISTRY_FILE),
            serde_json::to_vec(&registry).unwrap(),
        )
        .unwrap();

        install_skills(&installer, None, Some("provider-one")).unwrap();

        assert!(stale_skill.join("SKILL.md").is_file());
        let registry = load_registry(&skills_root.join(REGISTRY_FILE)).unwrap();
        assert!(registry.skills.contains_key("provider-stale"));
        assert!(registry.skills.contains_key("provider-one"));
    }

    #[test]
    fn does_not_replace_a_project_owned_skill_directory() {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(&provider, "one.md", &skill_document("One.", "# One\n"));
        let installer = make_installer(root, vec![provider]);
        let destination = root.join(".agents/skills/provider-one");
        fs::create_dir_all(&destination).unwrap();
        fs::write(destination.join("SKILL.md"), "project-owned skill\n").unwrap();

        let error = install_skills(&installer, None, None).unwrap_err();

        assert!(
            error
                .to_string()
                .contains("not managed by Bake Agent Context")
        );
        assert_eq!(
            fs::read_to_string(destination.join("SKILL.md")).unwrap(),
            "project-owned skill\n"
        );
        assert!(!root.join(".agents/skills").join(REGISTRY_FILE).exists());
    }

    #[test]
    fn rolls_back_installed_and_removed_skill_changes() {
        let directory = tempdir().unwrap();
        let root = directory.path().join("skills");
        let backups = directory.path().join("backups");
        fs::create_dir_all(&root).unwrap();
        fs::create_dir_all(&backups).unwrap();
        fs::create_dir(root.join("new")).unwrap();
        fs::write(root.join("new/SKILL.md"), "new").unwrap();
        fs::create_dir_all(backups.join("replaced")).unwrap();
        fs::write(backups.join("replaced/SKILL.md"), "old").unwrap();
        fs::create_dir_all(backups.join("removed")).unwrap();
        fs::write(backups.join("removed/SKILL.md"), "removed").unwrap();

        rollback(
            &root,
            &backups,
            &[
                AppliedChange::Installed {
                    name: "new".to_owned(),
                    had_previous: false,
                },
                AppliedChange::Installed {
                    name: "replaced".to_owned(),
                    had_previous: true,
                },
                AppliedChange::Removed {
                    name: "removed".to_owned(),
                },
            ],
        );
        assert!(!root.join("new").exists());
        assert_eq!(
            fs::read_to_string(root.join("replaced/SKILL.md")).unwrap(),
            "old"
        );
        assert_eq!(
            fs::read_to_string(root.join("removed/SKILL.md")).unwrap(),
            "removed"
        );
    }

    fn transaction_fixture() -> (
        tempfile::TempDir,
        Installer,
        PathBuf,
        PathBuf,
        PathBuf,
        Vec<u8>,
    ) {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(
            &provider,
            "example.md",
            &skill_document("Updated example.", "# Updated example"),
        );
        let installer = make_installer(root, vec![provider]);

        let skills_root = root.join(".agents/skills");
        let previous_skill = skills_root.join("provider-example");
        let stale_skill = skills_root.join("provider-stale");
        fs::create_dir_all(&previous_skill).unwrap();
        fs::write(previous_skill.join("SKILL.md"), "previous version\n").unwrap();
        fs::create_dir_all(&stale_skill).unwrap();
        fs::write(stale_skill.join("SKILL.md"), "stale skill\n").unwrap();

        let registry_path = skills_root.join(REGISTRY_FILE);
        let registry = Registry {
            version: REGISTRY_VERSION,
            skills: BTreeMap::from([
                (
                    "provider-example".to_owned(),
                    SkillOwner {
                        package: "provider".to_owned(),
                        version: "0.9.0".to_owned(),
                    },
                ),
                (
                    "provider-stale".to_owned(),
                    SkillOwner {
                        package: "provider".to_owned(),
                        version: "0.9.0".to_owned(),
                    },
                ),
            ]),
        };
        let previous_registry = serde_json::to_vec_pretty(&registry).unwrap();
        fs::write(&registry_path, &previous_registry).unwrap();

        (
            directory,
            installer,
            previous_skill,
            stale_skill,
            registry_path,
            previous_registry,
        )
    }

    fn fresh_install_fixture() -> (tempfile::TempDir, Installer, PathBuf, PathBuf) {
        let directory = tempdir().unwrap();
        let root = directory.path();
        let provider = package(root, "provider", "1.0.0");
        write_skill(
            &provider,
            "example.md",
            &skill_document("Example.", "# Example"),
        );
        let installer = make_installer(root, vec![provider]);
        let skills_root = root.join(".agents/skills");
        let skill_path = skills_root.join("provider-example");
        let registry_path = skills_root.join(REGISTRY_FILE);

        (directory, installer, skill_path, registry_path)
    }

    fn assert_transaction_restored(
        previous_skill: &Path,
        stale_skill: &Path,
        registry_path: &Path,
        previous_registry: &[u8],
    ) {
        assert_eq!(
            fs::read_to_string(previous_skill.join("SKILL.md")).unwrap(),
            "previous version\n"
        );
        assert_eq!(
            fs::read_to_string(stale_skill.join("SKILL.md")).unwrap(),
            "stale skill\n"
        );
        assert_eq!(fs::read(registry_path).unwrap(), previous_registry);
    }

    #[test]
    fn restores_the_previous_install_when_registry_update_fails() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = registry_path.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameDestination, move |path| {
                path == failure_path
            });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot update skill registry"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn restores_the_previous_skill_when_replacement_fails() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = previous_skill.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameDestination, move |path| {
                path == failure_path
            });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot install skill"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn rolls_back_a_first_install_when_skill_rename_fails() {
        let (_directory, installer, skill_path, registry_path) = fresh_install_fixture();
        let failure_path = skill_path.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameDestination, move |path| {
                path == failure_path
            });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot install skill"));
        assert!(!skill_path.exists());
        assert!(!registry_path.exists());
    }

    #[test]
    fn rolls_back_a_first_install_when_registry_commit_fails() {
        let (_directory, installer, skill_path, registry_path) = fresh_install_fixture();
        let failure_path = registry_path.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameDestination, move |path| {
                path == failure_path
            });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot update skill registry"));
        assert!(!skill_path.exists());
        assert!(!registry_path.exists());
    }

    #[test]
    fn preserves_the_previous_install_when_existing_skill_cannot_be_moved() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = previous_skill.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameSource, move |path| {
                path == failure_path
            });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot move existing skill"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn rolls_back_installed_skills_when_stale_skill_cannot_be_moved() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = stale_skill.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameSource, move |path| {
                path == failure_path
            });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(
            error
                .to_string()
                .contains("cannot remove stale installed skill")
        );
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn rolls_back_installed_skills_when_staged_registry_write_fails() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Write, |path| {
            path.file_name() == Some(std::ffi::OsStr::new("registry.json"))
        });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(
            error
                .to_string()
                .contains("cannot write staged skill registry")
        );
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn rolls_back_installed_skills_when_existing_registry_cannot_be_moved() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = registry_path.clone();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RenameSource, move |path| {
                path == failure_path
            });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(
            error
                .to_string()
                .contains("cannot move existing skill registry")
        );
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn cleans_staging_directory_when_preparing_staging_files_fails() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let _failure = filesystem::fail_once(test_filesystem::Operation::CreateDirectory, |path| {
            path.file_name() == Some(std::ffi::OsStr::new("backups"))
        });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot prepare"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
        assert!(
            fs::read_dir(registry_path.parent().unwrap())
                .unwrap()
                .all(|entry| !entry
                    .unwrap()
                    .file_name()
                    .to_string_lossy()
                    .starts_with(".agent-context-staging-"))
        );
    }

    #[test]
    fn reports_staging_directory_creation_failure() {
        let (_directory, installer, _, _, _, _) = transaction_fixture();
        let _failure = filesystem::fail_once(test_filesystem::Operation::CreateDirectory, |path| {
            path.file_name()
                .and_then(std::ffi::OsStr::to_str)
                .is_some_and(|name| name.starts_with(".agent-context-staging-"))
        });
        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot create"));
    }

    #[test]
    fn cleans_staging_files_when_writing_a_skill_fails() {
        let (_directory, installer, skill_path, registry_path) = fresh_install_fixture();
        let skills_root = registry_path.parent().unwrap();
        fs::create_dir_all(skills_root).unwrap();
        let unrelated_file = skills_root.join("unrelated-file");
        fs::write(&unrelated_file, "keep this file\n").unwrap();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Write, |path| {
            path.file_name() == Some(std::ffi::OsStr::new("SKILL.md"))
        });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot write"));
        assert!(!skill_path.exists());
        assert!(!registry_path.exists());
        assert!(unrelated_file.is_file());
        assert!(fs::read_dir(skills_root).unwrap().all(|entry| {
            !entry
                .unwrap()
                .file_name()
                .to_string_lossy()
                .starts_with(".agent-context-staging-")
        }));
    }

    #[test]
    fn reports_directory_tree_creation_errors() {
        let directory = tempdir().unwrap();
        let destination = directory.path().join("created/nested");
        let failure_path = destination.clone();
        let _failure = filesystem::fail_once(
            test_filesystem::Operation::CreateDirectoryTree,
            move |path| path == failure_path,
        );

        let error = ensure_directory(&destination).unwrap_err();

        assert!(error.to_string().contains("cannot create"));
        assert!(!destination.exists());
    }

    #[test]
    fn reports_skill_registry_read_errors() {
        let directory = tempdir().unwrap();
        let registry_path = directory.path().join("registry.json");
        fs::write(&registry_path, r#"{"version":1,"skills":{}}"#).unwrap();
        let failure_path = registry_path.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Read, move |path| {
            path == failure_path
        });

        let error = load_registry(&registry_path).unwrap_err();

        assert!(error.to_string().contains("cannot read"));
    }

    #[test]
    fn reports_destination_inspection_errors_before_changing_installed_skills() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = previous_skill.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot inspect"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn reports_stale_skill_inspection_errors_before_changing_installed_skills() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, previous_registry) =
            transaction_fixture();
        let failure_path = stale_skill.clone();
        let _failure = filesystem::fail_once(test_filesystem::Operation::Inspect, move |path| {
            path == failure_path
        });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot inspect"));
        assert_transaction_restored(
            &previous_skill,
            &stale_skill,
            &registry_path,
            &previous_registry,
        );
    }

    #[test]
    fn reports_staging_cleanup_errors_after_committing_the_install() {
        let (_directory, installer, previous_skill, stale_skill, registry_path, _) =
            transaction_fixture();
        let _failure =
            filesystem::fail_once(test_filesystem::Operation::RemoveDirectoryTree, |path| {
                path.file_name()
                    .and_then(std::ffi::OsStr::to_str)
                    .is_some_and(|name| name.starts_with(".agent-context-staging-"))
            });

        let error = install_skills(&installer, Some("provider@1.0.0"), None).unwrap_err();

        assert!(error.to_string().contains("cannot remove"));
        assert!(
            fs::read_to_string(previous_skill.join("SKILL.md"))
                .unwrap()
                .contains("# Updated example")
        );
        assert!(!stale_skill.exists());
        let registry = load_registry(&registry_path).unwrap();
        assert_eq!(registry.skills["provider-example"].version, "1.0.0");
        assert!(!registry.skills.contains_key("provider-stale"));
    }

    #[cfg(unix)]
    #[test]
    fn handles_exclude_errors_before_installing_skills() {
        use std::os::unix::fs::PermissionsExt;

        let directory = tempdir().unwrap();
        let root = directory.path();
        assert!(
            std::process::Command::new("git")
                .args(["init", "--quiet"])
                .current_dir(root)
                .status()
                .unwrap()
                .success()
        );
        let exclude = root.join(".git/info/exclude");
        fs::remove_file(&exclude).unwrap();
        fs::create_dir(&exclude).unwrap();
        let provider = package(root, "provider", "1.0.0");
        write_skill(&provider, "one.md", &skill_document("One.", "# One\n"));
        let installer = make_installer(root, vec![provider]);
        let error = install_skills(&installer, None, None)
            .unwrap_err()
            .to_string();
        assert!(error.contains("cannot read"), "{error}");
        assert!(!root.join(".agents/skills/provider-one").exists());

        let directory = tempdir().unwrap();
        let root = directory.path();
        assert!(
            std::process::Command::new("git")
                .args(["init", "--quiet"])
                .current_dir(root)
                .status()
                .unwrap()
                .success()
        );
        let exclude = root.join(".git/info/exclude");
        fs::set_permissions(&exclude, fs::Permissions::from_mode(0o444)).unwrap();
        let provider = package(root, "provider", "1.0.0");
        write_skill(&provider, "one.md", &skill_document("One.", "# One\n"));
        let installer = make_installer(root, vec![provider]);
        let result = install_skills(&installer, None, None);
        fs::set_permissions(&exclude, fs::Permissions::from_mode(0o644)).unwrap();
        let error = result.unwrap_err().to_string();
        assert!(error.contains("cannot update"), "{error}");
        assert!(!root.join(".agents/skills/provider-one").exists());
        assert!(!root.join(".agents/skills").join(REGISTRY_FILE).exists());
    }
}