pi_agent_rust 0.7.1

//! Carry trusted content/existence evidence between acknowledged edit batches.
//!
//! Receipts are derived from staged final images, never by reading the disk
//! again after commit. A concurrent writer therefore cannot silently become
//! the trusted baseline for the next workspace/applyEdit callback.

use std::collections::{HashMap, hash_map::DefaultHasher};
use std::hash::{Hash, Hasher};
use std::path::{Path, PathBuf};

use super::{ApplyOutcome, Image, Result, Transaction, WorkspaceEditPlan, conflict};
use crate::lsp::text::content_hash_for_drift;

/// Absence is evidence too: a deleted or moved-away path must not be silently
/// recreated by another writer between callbacks. Text hashes match the
/// existing request-time DocumentSnapshot hash; binary resources remain
/// supported without lossy UTF-8 conversion or conflating them with absence.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub(in crate::lsp) enum FileEvidence {
    Absent,
    Text(u64),
    Binary(u64),
}

impl FileEvidence {
    fn from_image(image: Option<&Image>) -> Self {
        let Some(image) = image else {
            return Self::Absent;
        };
        std::str::from_utf8(&image.bytes).map_or_else(
            |_| {
                let mut hash = DefaultHasher::new();
                image.bytes.hash(&mut hash);
                Self::Binary(hash.finish())
            },
            |text| Self::Text(content_hash_for_drift(text)),
        )
    }
}

#[derive(Debug)]
pub(in crate::lsp) struct CheckedApply {
    pub(in crate::lsp) outcome: ApplyOutcome,
    pub(in crate::lsp) states: HashMap<PathBuf, FileEvidence>,
}

fn prepare_checked(
    plan: &WorkspaceEditPlan,
    expected: &HashMap<PathBuf, FileEvidence>,
) -> Result<Transaction> {
    let mut transaction = super::super::sequence::stage(plan)?;
    for (path, expected) in expected {
        // Guard-only files participate in the commit's existing preimage
        // recheck even when the server edits only a sibling document.
        let normalized = transaction.load(path)?;
        let actual = FileEvidence::from_image(transaction.files[&normalized].before.as_ref());
        if actual != *expected {
            return Err(conflict(format!(
                "{} changed on disk since the selected action or last accepted edit; re-run the request",
                path.display()
            )));
        }
    }
    Ok(transaction)
}

/// An immutable, memory-only transaction retained between review and approval.
/// Staging creates no directories, backups or temporary files. Commit consumes
/// this value and checks the exact original bytes, permissions and absence;
/// it never stages a replacement plan against newly read contents.
pub(in crate::lsp) struct PreparedEdit(Transaction);

impl PreparedEdit {
    #[allow(clippy::implicit_hasher)]
    pub(in crate::lsp) fn new(
        plan: &WorkspaceEditPlan,
        expected: &HashMap<PathBuf, FileEvidence>,
    ) -> Result<Self> {
        prepare_checked(plan, expected).map(Self)
    }

    pub(in crate::lsp) fn paths(&self) -> impl Iterator<Item = &PathBuf> {
        self.0.files.keys()
    }

    pub(in crate::lsp) fn matches_document(&self, path: &Path, text: &str) -> bool {
        self.0
            .files
            .get(path)
            .and_then(|file| file.before.as_ref())
            .is_some_and(|image| image.bytes.as_ref() == text.as_bytes())
    }

    /// Includes guard-only and no-op files, which also constrain approval.
    pub(in crate::lsp) fn summary(&self, cwd: &Path) -> Vec<serde_json::Value> {
        self.0
            .files
            .iter()
            .map(|(path, file)| {
                serde_json::json!({
                    "file":crate::lsp::display_path(path, cwd),
                    "beforeBytes":file.before.as_ref().map(|image| image.bytes.len()),
                    "afterBytes":file.after.as_ref().map(|image| image.bytes.len()),
                    "changed":file.before != file.after
                })
            })
            .collect()
    }

    pub(in crate::lsp) fn verify(&self) -> Result<()> {
        for (path, file) in &self.0.files {
            super::verify_image(path, file.before.as_ref())
                .map_err(|error| super::io_context(path, &error))?;
        }
        Ok(())
    }

    pub(in crate::lsp) fn commit(
        self,
        before_commit: impl FnOnce() -> Result<()>,
    ) -> Result<ApplyOutcome> {
        self.verify()?;
        // Recheck the caller after potentially expensive original-image reads.
        before_commit()?;
        self.0.commit()
    }
}

/// Apply one rollback-safe batch and return staged content/existence evidence.
/// Callers own workspace scoping, document-version checks and the bounded
/// lifetime of the receipt. The callback rechecks ownership/cancellation after
/// expensive staging, immediately before the existing commit implementation.
/// Accepted batches are not one cross-request or crash-atomic transaction.
#[allow(clippy::implicit_hasher)] // Receipts and request snapshots use one concrete map type.
pub(in crate::lsp) fn apply_checked(
    plan: &WorkspaceEditPlan,
    expected: &HashMap<PathBuf, FileEvidence>,
    before_commit: impl FnOnce() -> Result<()>,
) -> Result<CheckedApply> {
    let transaction = prepare_checked(plan, expected)?;
    let states = transaction
        .files
        .iter()
        .map(|(path, staged)| {
            (
                path.clone(),
                FileEvidence::from_image(staged.after.as_ref()),
            )
        })
        .collect();
    before_commit()?;
    let outcome = transaction.commit()?;
    Ok(CheckedApply { outcome, states })
}

#[cfg(test)]
mod tests;