intentional_core/

init.rs

// ---
// relationships:
//   implements: intent-driven-polyglot-release
// ---

//! Workspace-aware initialization and explicit Changesets takeover.

use crate::config::{
    validate_detector_id, validate_exact_discovery_path, validate_sha256, validate_tag_template,
    Config, ExcludedPathReceipt, ManagedPathReceipt, Projection, ReleaseUnitConfig, TagConfig,
    CONFIG_PATH, CONFIG_SCHEMA, CURRENT_CONTRACT,
};
use crate::error::{Error, Result};
use crate::model::{
    Adapter, Bump, Pre1BumpMapping, ProjectionMode, ReleaseUnitDisposition, TagRole,
};
use crate::plan::{canonical_json, lower_hex, sha256_digest};
use crate::version::{
    bump_version_with_mapping, effective_bumps, resolve_versions, ReleaseUnitVersion,
};
use glob::glob;
use node_semver::{Range as NodeRange, Version as NodeVersion};
use semver::Version;
use serde::{Deserialize, Serialize};
use serde_json::Value as JsonValue;
use sha2::{Digest, Sha256};
use std::collections::{BTreeMap, BTreeSet};
use std::io::Write;
use std::path::{Path, PathBuf};
use std::process::{Command, Stdio};
use walkdir::WalkDir;

/// Transient initialization-plan location.
pub const INIT_PLAN_PATH: &str = ".intentional/init-plan.yml";

/// Published initialization-plan schema identifier.
pub const INIT_PLAN_SCHEMA: &str = "https://intentional.foo/schemas/init-plan.yml";

const CHANGESETS_CONFIG: &str = ".changeset/config.json";
const TRANSACTION_PATH: &str = ".intentional/.takeover-transaction";
const TRANSACTION_STATE_PATH: &str = ".intentional/.takeover-state";
const DEVCONTAINER_FEATURE_MANIFEST: &str = "devcontainer-feature.json";
const DEVCONTAINER_TEMPLATE_MANIFEST: &str = "devcontainer-template.json";

/// Process outcome for initialization.
#[derive(Debug, Clone, Copy, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case")]
pub enum InitState {
    /// Canonical configuration was produced, or takeover completed.
    Success,
    /// A deterministic plan exists but needs finite resolutions or repository edits.
    NeedsInput,
    /// A Changesets plan is complete and awaits explicit takeover.
    Ready,
}

/// One source artifact used as initialization evidence.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq, PartialOrd, Ord)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct SourceEvidence {
    /// Workspace-relative source path.
    pub path: PathBuf,
    /// SHA-256 of the complete file contents.
    pub digest: String,
    /// Relevant one-based source lines.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub lines: Vec<usize>,
}

/// Optional raw version text together with the evidence from which it was extracted.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct RawVersionEvidence {
    /// Uninterpreted version text supplied by the artifact.
    pub value: String,
    /// Exact evidence supporting the extracted text.
    pub evidence: Vec<SourceEvidence>,
}

/// A projection a detector can suggest when its required fields were extracted.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct CandidateProjectionSuggestion {
    /// Adapter specialization.
    pub adapter: Adapter,
    /// Exact workspace-relative projection path.
    pub path: PathBuf,
    /// Projection materialization mode.
    pub mode: ProjectionMode,
    /// JSON Pointer or dotted TOML/YAML key path for generic formats.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub pointer: Option<String>,
}

/// A tag a detector can suggest without granting it version authority.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct CandidateTagSuggestion {
    /// Suggested tag id within the resolved release unit.
    pub id: String,
    /// Suggested primary or projection role.
    pub role: TagRole,
    /// Suggested template containing exactly one `{version}` placeholder.
    pub template: String,
}

/// Evidence-backed extraction problem that does not assert artifact invalidity.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct ExtractionDiagnostic {
    /// Stable diagnostic identity within the candidate.
    pub id: String,
    /// Stable extraction category.
    pub code: String,
    /// Human-readable extraction problem.
    pub message: String,
    /// Exact evidence encountered by the detector.
    pub evidence: Vec<SourceEvidence>,
}

/// Explicit user or agent resolution for one discovery candidate.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(
    tag = "kind",
    rename_all = "kebab-case",
    rename_all_fields = "kebab-case",
    deny_unknown_fields
)]
pub enum CandidateResolution {
    /// Create one independently versioned release unit from this candidate.
    Independent {
        /// Stable id for the new release unit.
        release_unit: String,
    },
    /// Add this candidate as a projection of a release unit.
    Projection {
        /// Final configured or planned release-unit id.
        release_unit: String,
        /// Planned candidate to follow; omitted when the release unit is already configured.
        #[serde(default, skip_serializing_if = "Option::is_none")]
        target_candidate: Option<String>,
    },
    /// Keep this exact detector/path evidence outside the release-unit inventory.
    Excluded,
}

/// Artifact-neutral evidence emitted by any release-unit detector.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct DiscoveryCandidate {
    /// Stable hash of detector and exact path identity.
    pub id: String,
    /// Stable detector id, independent from adapter or ecosystem names.
    pub detector: String,
    /// Exact workspace-relative artifact path.
    pub path: PathBuf,
    /// All evidence used to create this candidate.
    pub evidence: Vec<SourceEvidence>,
    /// Manifest-native identity, when extraction succeeds.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub native_identity: Option<String>,
    /// Uninterpreted version evidence, when present and readable.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub raw_version: Option<RawVersionEvidence>,
    /// Projection suggestion, only when the detector has enough evidence.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub projection: Option<CandidateProjectionSuggestion>,
    /// Tag suggestion, only when the detector has enough evidence.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub tag: Option<CandidateTagSuggestion>,
    /// Narrow extraction diagnostics; these do not validate publication or artifact completeness.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub diagnostics: Vec<ExtractionDiagnostic>,
    /// Editable independent, projection, or excluded choice.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub resolution: Option<CandidateResolution>,
}

impl DiscoveryCandidate {
    /// Derive the stable candidate id from detector and exact path identity.
    pub fn stable_id(detector: &str, path: &Path) -> Result<String> {
        validate_detector_id(detector)?;
        validate_exact_discovery_path(path, "discovery candidate path")?;
        let mut path_parts = Vec::new();
        for component in path.components() {
            if let std::path::Component::Normal(value) = component {
                path_parts.push(value.to_str().ok_or_else(|| {
                    Error::Validation("discovery candidate path must be valid UTF-8".to_owned())
                })?);
            }
        }
        let path = path_parts.join("/");
        let mut identity = Sha256::new();
        identity.update(detector.as_bytes());
        identity.update([0]);
        identity.update(path.as_bytes());
        Ok(format!("candidate:{}", lower_hex(&identity.finalize())))
    }

    fn validate(&self) -> Result<()> {
        let expected = Self::stable_id(&self.detector, &self.path)?;
        if self.id != expected {
            return Err(Error::Validation(format!(
                "discovery candidate {} does not match detector {} and path {}",
                self.id,
                self.detector,
                self.path.display()
            )));
        }
        if self.evidence.is_empty() {
            return Err(Error::Validation(format!(
                "discovery candidate {} must contain evidence",
                self.id
            )));
        }
        validate_source_evidence(&self.evidence, &format!("discovery candidate {}", self.id))?;
        if !self.evidence.iter().any(|item| item.path == self.path) {
            return Err(Error::Validation(format!(
                "discovery candidate {} evidence must include its exact path {}",
                self.id,
                self.path.display()
            )));
        }
        if self.native_identity.as_deref().is_some_and(str::is_empty) {
            return Err(Error::Validation(format!(
                "discovery candidate {} native identity must not be empty",
                self.id
            )));
        }
        if let Some(version) = &self.raw_version {
            if version.value.is_empty() {
                return Err(Error::Validation(format!(
                    "discovery candidate {} raw version must not be empty",
                    self.id
                )));
            }
            validate_source_evidence(
                &version.evidence,
                &format!("discovery candidate {} raw version", self.id),
            )?;
            if !version
                .evidence
                .iter()
                .all(|item| self.evidence.contains(item))
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} raw version references evidence outside the candidate",
                    self.id
                )));
            }
        }
        if let Some(projection) = &self.projection {
            validate_exact_discovery_path(&projection.path, "candidate projection path")?;
            if !self
                .evidence
                .iter()
                .any(|item| item.path == projection.path)
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} projection path lacks candidate evidence",
                    self.id
                )));
            }
            if projection.adapter.requires_pointer()
                && projection.pointer.as_deref().is_none_or(str::is_empty)
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} generic projection requires a pointer",
                    self.id
                )));
            }
        }
        if let Some(tag) = &self.tag {
            if tag.id.is_empty()
                || !tag
                    .id
                    .chars()
                    .next()
                    .is_some_and(|character| character.is_ascii_alphanumeric())
                || !tag
                    .id
                    .chars()
                    .all(|character| character.is_ascii_alphanumeric() || "-_.".contains(character))
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} has invalid tag id {:?}",
                    self.id, tag.id
                )));
            }
            validate_tag_template(
                &format!("discovery candidate {} tag", self.id),
                &tag.template,
                true,
            )?;
        }
        let mut diagnostic_ids = BTreeSet::new();
        for diagnostic in &self.diagnostics {
            if diagnostic.id.is_empty()
                || diagnostic.code.is_empty()
                || diagnostic.message.is_empty()
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} has an incomplete extraction diagnostic",
                    self.id
                )));
            }
            if !diagnostic_ids.insert(&diagnostic.id) {
                return Err(Error::Validation(format!(
                    "discovery candidate {} repeats extraction diagnostic {}",
                    self.id, diagnostic.id
                )));
            }
            validate_source_evidence(
                &diagnostic.evidence,
                &format!(
                    "discovery candidate {} diagnostic {}",
                    self.id, diagnostic.id
                ),
            )?;
            if !diagnostic
                .evidence
                .iter()
                .all(|item| self.evidence.contains(item))
            {
                return Err(Error::Validation(format!(
                    "discovery candidate {} diagnostic {} references evidence outside the candidate",
                    self.id, diagnostic.id
                )));
            }
        }
        Ok(())
    }
}

/// One detector invocation before its candidates are flattened into an initialization plan.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct DetectorResult {
    /// Stable detector id.
    pub detector: String,
    /// Candidates emitted in stable path order.
    pub candidates: Vec<DiscoveryCandidate>,
}

impl DetectorResult {
    /// Validate detector identity and candidate ownership.
    pub fn validate(&self) -> Result<()> {
        validate_detector_id(&self.detector)?;
        let mut paths = BTreeSet::new();
        for candidate in &self.candidates {
            if candidate.detector != self.detector {
                return Err(Error::Validation(format!(
                    "detector {} returned candidate owned by {}",
                    self.detector, candidate.detector
                )));
            }
            candidate.validate()?;
            if !paths.insert(&candidate.path) {
                return Err(Error::Validation(format!(
                    "detector {} repeated candidate path {}",
                    self.detector,
                    candidate.path.display()
                )));
            }
        }
        Ok(())
    }

    /// Return candidates in deterministic path order for plan serialization.
    pub fn into_candidates(mut self) -> Result<Vec<DiscoveryCandidate>> {
        self.validate()?;
        self.candidates
            .sort_by(|left, right| left.path.cmp(&right.path));
        Ok(self.candidates)
    }
}

fn validate_source_evidence(evidence: &[SourceEvidence], description: &str) -> Result<()> {
    if evidence.is_empty() {
        return Err(Error::Validation(format!(
            "{description} must contain evidence"
        )));
    }
    let mut paths = BTreeSet::new();
    if evidence.windows(2).any(|pair| pair[0] >= pair[1]) {
        return Err(Error::Validation(format!(
            "{description} evidence must be ordered by path"
        )));
    }
    for item in evidence {
        validate_exact_discovery_path(&item.path, &format!("{description} evidence path"))?;
        validate_sha256(&item.digest, &format!("{description} evidence digest"))?;
        if !paths.insert(&item.path) {
            return Err(Error::Validation(format!(
                "{description} repeats evidence path {}",
                item.path.display()
            )));
        }
        if item.lines.contains(&0) {
            return Err(Error::Validation(format!(
                "{description} evidence lines must be one-based"
            )));
        }
        let unique_lines = item.lines.iter().collect::<BTreeSet<_>>();
        if unique_lines.len() != item.lines.len() {
            return Err(Error::Validation(format!(
                "{description} repeats an evidence line for {}",
                item.path.display()
            )));
        }
        if item.lines.windows(2).any(|pair| pair[0] >= pair[1]) {
            return Err(Error::Validation(format!(
                "{description} evidence lines for {} must be ordered",
                item.path.display()
            )));
        }
    }
    Ok(())
}

/// One finite initialization decision or warning.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct InitDiagnostic {
    /// Stable diagnostic identity.
    pub id: String,
    /// Stable diagnostic category.
    pub code: String,
    /// Actionable human-readable explanation.
    pub message: String,
    /// Exact evidence supporting the diagnostic.
    pub evidence: Vec<SourceEvidence>,
    /// Finite resolution values. Empty means informational.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub choices: Vec<String>,
    /// Parity-preserving or boundary-preserving recommendation.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub recommended: Option<String>,
    /// Editable user/agent resolution.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub resolution: Option<String>,
    /// Whether repository state proves the selected resolution.
    #[serde(default)]
    pub verified: bool,
    /// Whether a prior resolution was discarded because its evidence became stale.
    #[serde(default, skip_serializing_if = "std::ops::Not::not")]
    pub invalidated_resolution: bool,
    /// Evidence supporting a best-effort recommendation.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub supporting_evidence: Vec<SourceEvidence>,
    /// Evidence that weakens or contradicts a best-effort recommendation.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub contradictory_evidence: Vec<SourceEvidence>,
    /// Explicit uncertainty boundary for a best-effort recommendation.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub uncertainty: Option<String>,
}

/// One side of a Changesets takeover parity comparison.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct ParityRelease {
    /// Aggregate requested bump after dependency and group propagation.
    pub requested_bump: Bump,
    /// Resulting version under that authority's contract.
    pub next_version: String,
}

/// Changesets and proposed release results used for takeover parity.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct ParityReleaseUnit {
    /// Release-unit id.
    pub release_unit: String,
    /// Version in source projections.
    pub current_version: String,
    /// Independently computed Changesets result, when the source releases this release unit.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub source: Option<ParityRelease>,
    /// Proposed Intentional result, when the proposed contract releases this release unit.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub proposed: Option<ParityRelease>,
}

/// Deterministic parity comparison.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct ParityResult {
    /// `equivalent` when all logical releases agree; otherwise `blocked`.
    pub status: String,
    /// Per-release-unit results.
    pub release_units: Vec<ParityReleaseUnit>,
}

/// One pending Changesets file converted losslessly at takeover.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct ConvertedIntent {
    /// Changeset filename stem retained as the Intentional intent id.
    pub id: String,
    /// Release-unit bumps.
    pub release_units: BTreeMap<String, Bump>,
    /// Markdown body, excluding Changesets frontmatter delimiters.
    pub message: String,
    /// Original Changesets file.
    pub source: PathBuf,
    /// Intentional target file.
    pub target: PathBuf,
}

impl ConvertedIntent {
    fn contents(&self) -> Result<String> {
        Ok(format!(
            "---\n{}---\n\n{}\n",
            serde_yaml::to_string(&self.release_units)?,
            self.message.trim()
        ))
    }
}

/// Durable, editable handoff produced while Changesets still owns authority.
#[derive(Debug, Clone, Deserialize, Serialize, PartialEq, Eq)]
#[serde(rename_all = "kebab-case", deny_unknown_fields)]
pub struct InitPlan {
    /// Published schema location.
    #[serde(rename = "$schema")]
    pub schema: String,
    /// Computed state. Editing this field never bypasses validation.
    pub state: InitState,
    /// Existing authority kind.
    pub source_kind: String,
    /// Digest over all current source evidence.
    pub source_fingerprint: String,
    /// Complete confidently inferred canonical configuration.
    pub inferred_config: Config,
    /// Artifact-neutral candidates awaiting or carrying explicit resolutions.
    pub discovery_candidates: Vec<DiscoveryCandidate>,
    /// Finite choices, warnings, and verified repository integration outcomes.
    pub diagnostics: Vec<InitDiagnostic>,
    /// Pending source intents and their lossless targets.
    pub converted_intents: Vec<ConvertedIntent>,
    /// Independent source/proposed release comparison.
    pub parity: ParityResult,
    /// Exact operations an explicit takeover performs.
    pub planned_operations: Vec<String>,
    /// Required command after the takeover changes are committed.
    pub post_commit_action: String,
}

impl InitPlan {
    /// Validate candidate evidence and its projection resolution graph.
    pub fn validate(&self) -> Result<()> {
        if self.inferred_config.release_units.is_empty() {
            if self.state != InitState::NeedsInput || self.discovery_candidates.is_empty() {
                return Err(Error::Validation(
                    "an empty inferred config requires unresolved discovery candidates".to_owned(),
                ));
            }
            validate_empty_inferred_config(&self.inferred_config)?;
        } else {
            self.inferred_config.validate()?;
        }
        let mut candidates = BTreeMap::new();
        for candidate in &self.discovery_candidates {
            candidate.validate()?;
            if candidates
                .insert(candidate.id.as_str(), candidate)
                .is_some()
            {
                return Err(Error::Validation(format!(
                    "duplicate discovery candidate {}",
                    candidate.id
                )));
            }
        }

        let mut creators = self
            .inferred_config
            .release_units
            .keys()
            .map(|id| (id.as_str(), "configured release unit"))
            .collect::<BTreeMap<_, _>>();
        let mut edges = BTreeMap::<&str, &str>::new();
        for candidate in &self.discovery_candidates {
            match &candidate.resolution {
                Some(CandidateResolution::Independent { release_unit }) => {
                    validate_resolution_release_unit(release_unit)?;
                    if let Some(previous) = creators.insert(release_unit, candidate.id.as_str()) {
                        return Err(Error::Validation(format!(
                            "duplicate creator for release unit {release_unit}: {previous} and {}",
                            candidate.id
                        )));
                    }
                }
                Some(CandidateResolution::Projection {
                    release_unit,
                    target_candidate,
                }) => {
                    validate_resolution_release_unit(release_unit)?;
                    if let Some(target) = target_candidate {
                        if !candidates.contains_key(target.as_str()) {
                            return Err(Error::Validation(format!(
                                "discovery candidate {} projects onto absent candidate {target}",
                                candidate.id
                            )));
                        }
                        edges.insert(candidate.id.as_str(), target.as_str());
                    } else if !self
                        .inferred_config
                        .release_units
                        .contains_key(release_unit)
                    {
                        return Err(Error::Validation(format!(
                            "discovery candidate {} projects onto absent configured release unit {release_unit}",
                            candidate.id
                        )));
                    }
                }
                Some(CandidateResolution::Excluded) | None => {}
            }
        }

        validate_candidate_graph_acyclic(&edges)?;
        for candidate in &self.discovery_candidates {
            let Some(CandidateResolution::Projection {
                release_unit,
                target_candidate: Some(target),
            }) = &candidate.resolution
            else {
                continue;
            };
            validate_projection_target(candidate, release_unit, target, &candidates)?;
        }
        Ok(())
    }

    /// Serialize deterministically with compact, explained YAML enum choices.
    pub fn to_yaml(&self) -> Result<String> {
        self.validate()?;
        let yaml = serde_yaml::to_string(self)?;
        Ok(annotate_choice_lines(&yaml))
    }

    /// Equivalent structured JSON for agent consumers.
    pub fn to_json(&self) -> Result<String> {
        self.validate()?;
        canonical_json(self)
    }
}

fn validate_empty_inferred_config(config: &Config) -> Result<()> {
    if config
        .schema
        .as_deref()
        .is_some_and(|schema| schema != CONFIG_SCHEMA)
    {
        return Err(Error::Validation(format!(
            "empty inferred config schema must be {CONFIG_SCHEMA}"
        )));
    }
    if config.contract != CURRENT_CONTRACT {
        return Err(Error::Validation(format!(
            "unsupported interpretation contract {:?}; expected {CURRENT_CONTRACT}",
            config.contract
        )));
    }
    if config.settings.internal_dependency_bump == Bump::None {
        return Err(Error::Validation(
            "internal-dependency-bump must be major, minor, or patch".to_owned(),
        ));
    }
    if !config.fixed.is_empty()
        || !config.linked.is_empty()
        || !config.workspace_tags.is_empty()
        || !config.discovery.managed_paths.is_empty()
        || !config.discovery.excluded_paths.is_empty()
    {
        return Err(Error::Validation(
            "empty inferred config may only contain schema, contract, settings, and release-units"
                .to_owned(),
        ));
    }
    Ok(())
}

fn validate_resolution_release_unit(id: &str) -> Result<()> {
    if id.is_empty()
        || !id
            .chars()
            .all(|character| character.is_ascii_alphanumeric() || "-_.@/".contains(character))
    {
        return Err(Error::Validation(format!(
            "invalid candidate resolution release-unit id {id:?}"
        )));
    }
    Ok(())
}

fn validate_candidate_graph_acyclic(edges: &BTreeMap<&str, &str>) -> Result<()> {
    fn visit<'a>(
        id: &'a str,
        edges: &BTreeMap<&'a str, &'a str>,
        visiting: &mut BTreeSet<&'a str>,
        visited: &mut BTreeSet<&'a str>,
    ) -> Result<()> {
        if visited.contains(id) {
            return Ok(());
        }
        if !visiting.insert(id) {
            return Err(Error::Validation(format!(
                "discovery candidate projection cycle includes {id}"
            )));
        }
        if let Some(target) = edges.get(id) {
            visit(target, edges, visiting, visited)?;
        }
        visiting.remove(id);
        visited.insert(id);
        Ok(())
    }

    let mut visiting = BTreeSet::new();
    let mut visited = BTreeSet::new();
    for id in edges.keys() {
        visit(id, edges, &mut visiting, &mut visited)?;
    }
    Ok(())
}

fn validate_projection_target(
    source: &DiscoveryCandidate,
    release_unit: &str,
    target: &str,
    candidates: &BTreeMap<&str, &DiscoveryCandidate>,
) -> Result<()> {
    let target = candidates[target];
    match &target.resolution {
        Some(CandidateResolution::Independent {
            release_unit: target_release_unit,
        }) => {
            if target_release_unit != release_unit {
                return Err(Error::Validation(format!(
                    "discovery candidate {} resolves to {release_unit} but target {} creates {target_release_unit}",
                    source.id, target.id
                )));
            }
            Ok(())
        }
        Some(CandidateResolution::Projection {
            release_unit: _,
            target_candidate: _,
        }) => Err(Error::Validation(format!(
            "discovery candidate {} projects onto target {} that is not an independent creator",
            source.id, target.id
        ))),
        Some(CandidateResolution::Excluded) | None => Err(Error::Validation(format!(
            "discovery candidate {} projects onto target {} without an independent or configured resolution",
            source.id, target.id
        ))),
    }
}

/// Planned initialization or takeover output.
#[derive(Debug, Clone)]
pub struct InitResult {
    /// Computed process outcome.
    pub state: InitState,
    /// Primary output path.
    pub path: PathBuf,
    /// Human-readable/schema-backed file contents.
    pub contents: String,
    /// Exact operations.
    pub operations: Vec<String>,
    /// Structured plan when adopting Changesets.
    pub plan: Option<InitPlan>,
    writes: Vec<(PathBuf, String)>,
    deletes: Vec<PathBuf>,
    proxy_removals: Vec<ProxyRemoval>,
    takeover: bool,
    takeover_evidence: Option<(String, BTreeSet<PathBuf>)>,
}

#[derive(Debug, Clone)]
struct ProxyRemoval {
    path: PathBuf,
    native_identity: String,
}

impl InitResult {
    /// Materialize initialization unless this is a dry run.
    pub fn apply(&self, root: &Path, dry_run: bool) -> Result<()> {
        if dry_run {
            return Ok(());
        }
        if self.takeover {
            let (expected_fingerprint, evidence_paths) = self
                .takeover_evidence
                .as_ref()
                .expect("takeover carries evidence");
            verify_proxy_removal_preconditions(root, &self.proxy_removals)?;
            verify_takeover_preconditions(
                root,
                &self.writes,
                expected_fingerprint,
                evidence_paths,
            )?;
            return apply_takeover_transaction(root, &self.writes, &self.deletes);
        }
        for (relative, contents) in &self.writes {
            let path = root.join(relative);
            if let Some(parent) = path.parent() {
                std::fs::create_dir_all(parent).map_err(|error| Error::io(parent, error))?;
            }
            std::fs::write(&path, contents).map_err(|error| Error::io(&path, error))?;
        }
        for relative in &self.deletes {
            let path = root.join(relative);
            if path.is_file() {
                std::fs::remove_file(&path).map_err(|error| Error::io(&path, error))?;
            }
        }
        if self.state == InitState::Success {
            std::fs::create_dir_all(root.join(crate::intent::INTENTS_PATH))
                .map_err(|error| Error::io(root.join(crate::intent::INTENTS_PATH), error))?;
        }
        Ok(())
    }

    /// Structured output matching the written configuration or initialization plan.
    pub fn to_json(&self) -> Result<String> {
        match &self.plan {
            Some(plan) => plan.to_json(),
            None => {
                let config = Config::from_yaml(&self.contents)?;
                canonical_json(&config)
            }
        }
    }
}

/// Discover or reconcile initialization, optionally executing explicit takeover.
pub fn initialize(root: &Path, take_over: bool) -> Result<InitResult> {
    let root = root
        .canonicalize()
        .map_err(|error| Error::io(root, error))?;
    let root = root.as_path();
    gix::discover(root)
        .map_err(|_| Error::Validation("intentional init requires a Git repository".to_owned()))?;
    recover_interrupted_takeover(root)?;
    if root.join(CHANGESETS_CONFIG).exists() {
        return changesets_plan(root, take_over);
    }
    if take_over {
        return Err(Error::Validation(
            "--take-over requires an existing .changeset/config.json".to_owned(),
        ));
    }
    ordinary_plan(root)
}

/// Compatibility wrapper for callers performing ordinary initialization.
pub fn discover_config(root: &Path) -> Result<InitResult> {
    initialize(root, false)
}

#[derive(Default)]
struct Discovery {
    config: Config,
    versions: BTreeMap<String, Version>,
    evidence: BTreeSet<PathBuf>,
    workspace_packages: BTreeSet<String>,
    private_packages: BTreeSet<String>,
    npm_dependencies: Vec<NpmDependencyEdge>,
    candidates: Vec<DiscoveryCandidate>,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
enum NpmDependencyKind {
    Dependency,
    Optional,
    Peer,
    Dev,
}

#[derive(Debug, Clone, PartialEq, Eq)]
struct NpmDependencyEdge {
    dependent: String,
    dependency: String,
    kind: NpmDependencyKind,
    range: String,
    manifest: PathBuf,
}

struct ManifestObservation {
    candidate_path: PathBuf,
    native_identity: String,
    private_package: bool,
    projection: CandidateProjectionSuggestion,
    raw_version: Option<String>,
    tag: CandidateTagSuggestion,
    workspace_package: bool,
}

struct ChangesetsSourceSemantics<'a> {
    private_packages: &'a BTreeSet<String>,
    suppress_private_versions: bool,
    npm_dependencies: &'a [NpmDependencyEdge],
    internal_dependency_bump: Bump,
    update_internal_dependents_always: bool,
    only_update_peer_dependents_when_out_of_range: bool,
    preflight_error: Option<String>,
}

fn ordinary_plan(root: &Path) -> Result<InitResult> {
    let previous = load_previous_plan(root)?;
    let had_previous_plan = previous.is_some();
    let configured = if root.join(CONFIG_PATH).is_file() {
        Config::load(root)?
    } else {
        Config::default()
    };
    let mut discovery = discover(root)?;
    reconcile_candidate_resolutions(&mut discovery.candidates, previous.as_ref());
    let mut candidates = unresolved_by_receipts(&configured, discovery.candidates);

    if candidates.is_empty() {
        if configured.release_units.is_empty() {
            return Err(Error::Validation(
                "no supported workspace manifests found".to_owned(),
            ));
        }
        let contents = configured.to_yaml()?;
        let (operations, deletes) = if had_previous_plan {
            (
                vec![format!("delete {INIT_PLAN_PATH}")],
                vec![PathBuf::from(INIT_PLAN_PATH)],
            )
        } else {
            (Vec::new(), Vec::new())
        };
        return Ok(InitResult {
            state: InitState::Success,
            path: PathBuf::from(CONFIG_PATH),
            operations,
            contents,
            plan: None,
            writes: Vec::new(),
            deletes,
            proxy_removals: Vec::new(),
            takeover: false,
            takeover_evidence: None,
        });
    }

    candidates.sort_by(|left, right| left.id.cmp(&right.id));
    let all_resolved = candidates
        .iter()
        .all(|candidate| candidate.resolution.is_some());
    if all_resolved {
        let applied = apply_candidate_resolutions(root, configured, &candidates)?;
        let contents = applied.to_yaml()?;
        return Ok(InitResult {
            state: InitState::Success,
            path: PathBuf::from(CONFIG_PATH),
            operations: vec![
                format!("write {CONFIG_PATH}"),
                format!("create {}", crate::intent::INTENTS_PATH),
                format!("delete {INIT_PLAN_PATH}"),
            ],
            contents: contents.clone(),
            plan: None,
            writes: vec![(PathBuf::from(CONFIG_PATH), contents)],
            deletes: vec![PathBuf::from(INIT_PLAN_PATH)],
            proxy_removals: Vec::new(),
            takeover: false,
            takeover_evidence: None,
        });
    }

    let evidence_paths = candidates
        .iter()
        .flat_map(|candidate| candidate.evidence.iter().map(|item| item.path.clone()))
        .collect::<BTreeSet<_>>();
    let plan = InitPlan {
        schema: INIT_PLAN_SCHEMA.to_owned(),
        state: InitState::NeedsInput,
        source_kind: if root.join(CONFIG_PATH).is_file() {
            "intentional".to_owned()
        } else {
            "workspace".to_owned()
        },
        source_fingerprint: fingerprint(root, &evidence_paths)?,
        inferred_config: configured,
        discovery_candidates: candidates,
        diagnostics: Vec::new(),
        converted_intents: Vec::new(),
        parity: ParityResult {
            status: "equivalent".to_owned(),
            release_units: Vec::new(),
        },
        planned_operations: vec![
            format!("write {CONFIG_PATH}"),
            format!("create {}", crate::intent::INTENTS_PATH),
            format!("delete {INIT_PLAN_PATH}"),
        ],
        post_commit_action: String::new(),
    };
    let contents = plan.to_yaml()?;
    Ok(InitResult {
        state: InitState::NeedsInput,
        path: PathBuf::from(INIT_PLAN_PATH),
        operations: vec![format!("write {INIT_PLAN_PATH}")],
        contents: contents.clone(),
        plan: Some(plan),
        writes: vec![(PathBuf::from(INIT_PLAN_PATH), contents)],
        deletes: Vec::new(),
        proxy_removals: Vec::new(),
        takeover: false,
        takeover_evidence: None,
    })
}

fn reconcile_candidate_resolutions(
    candidates: &mut [DiscoveryCandidate],
    previous: Option<&InitPlan>,
) {
    let Some(previous) = previous else {
        return;
    };
    let old = previous
        .discovery_candidates
        .iter()
        .map(|candidate| (candidate.id.as_str(), candidate))
        .collect::<BTreeMap<_, _>>();
    for candidate in candidates {
        if let Some(previous) = old.get(candidate.id.as_str()) {
            if previous.evidence == candidate.evidence
                && previous.native_identity == candidate.native_identity
                && previous.projection == candidate.projection
                && previous.tag == candidate.tag
            {
                candidate.resolution = previous.resolution.clone();
            }
        }
    }
}

fn unresolved_by_receipts(
    config: &Config,
    candidates: Vec<DiscoveryCandidate>,
) -> Vec<DiscoveryCandidate> {
    let managed = config
        .discovery
        .managed_paths
        .iter()
        .map(|receipt| (&receipt.detector, &receipt.path))
        .collect::<BTreeSet<_>>();
    let excluded = config
        .discovery
        .excluded_paths
        .iter()
        .map(|receipt| ((&receipt.detector, &receipt.path), &receipt.evidence_digest))
        .collect::<BTreeMap<_, _>>();
    candidates
        .into_iter()
        .filter_map(|candidate| {
            if managed.contains(&(&candidate.detector, &candidate.path)) {
                return None;
            }
            if let Some(expected) = excluded.get(&(&candidate.detector, &candidate.path)) {
                let actual = candidate
                    .evidence
                    .iter()
                    .find(|item| item.path == candidate.path)
                    .map(|item| &item.digest);
                if actual == Some(*expected) {
                    return None;
                }
            }
            Some(candidate)
        })
        .collect()
}

fn apply_candidate_resolutions(
    root: &Path,
    mut config: Config,
    candidates: &[DiscoveryCandidate],
) -> Result<Config> {
    let validation_plan = InitPlan {
        schema: INIT_PLAN_SCHEMA.to_owned(),
        state: InitState::NeedsInput,
        source_kind: "workspace".to_owned(),
        source_fingerprint: format!("sha256:{}", "0".repeat(64)),
        inferred_config: config.clone(),
        discovery_candidates: candidates.to_vec(),
        diagnostics: Vec::new(),
        converted_intents: Vec::new(),
        parity: ParityResult {
            status: "equivalent".to_owned(),
            release_units: Vec::new(),
        },
        planned_operations: Vec::new(),
        post_commit_action: String::new(),
    };
    validation_plan.validate()?;

    let resolved_paths = candidates
        .iter()
        .map(|candidate| (candidate.detector.clone(), candidate.path.clone()))
        .collect::<BTreeSet<_>>();
    config.discovery.managed_paths.retain(|receipt| {
        !resolved_paths.contains(&(receipt.detector.clone(), receipt.path.clone()))
    });
    config.discovery.excluded_paths.retain(|receipt| {
        !resolved_paths.contains(&(receipt.detector.clone(), receipt.path.clone()))
    });

    for candidate in candidates {
        let CandidateResolution::Independent { release_unit } = candidate
            .resolution
            .as_ref()
            .expect("all candidate resolutions checked")
        else {
            continue;
        };
        let projection = candidate
            .projection
            .as_ref()
            .map(|_| {
                candidate_projection(candidate, candidate.path.parent().unwrap_or(Path::new("")))
            })
            .transpose()?;
        let path = candidate
            .path
            .parent()
            .filter(|path| !path.as_os_str().is_empty())
            .map(Path::to_path_buf)
            .unwrap_or_else(|| PathBuf::from("."));
        let tag = candidate.tag.as_ref().ok_or_else(|| Error::Validation(format!(
            "discovery candidate {} cannot create an independent release unit without a tag suggestion",
            candidate.id
        )))?;
        config.release_units.insert(
            release_unit.clone(),
            ReleaseUnitConfig {
                path,
                disposition: ReleaseUnitDisposition::Managed,
                projections: projection.into_iter().collect(),
                tags: BTreeMap::from([(
                    tag.id.clone(),
                    TagConfig {
                        role: tag.role,
                        template: tag.template.clone(),
                        require_phase: None,
                        tag_after: Vec::new(),
                    },
                )]),
                depends_on: Vec::new(),
            },
        );
    }
    for candidate in candidates {
        match candidate
            .resolution
            .as_ref()
            .expect("all candidate resolutions checked")
        {
            CandidateResolution::Independent { release_unit } => {
                config.discovery.managed_paths.push(ManagedPathReceipt {
                    detector: candidate.detector.clone(),
                    path: candidate.path.clone(),
                    release_unit: release_unit.clone(),
                });
            }
            CandidateResolution::Projection { release_unit, .. } => {
                let unit = config.release_units.get_mut(release_unit).ok_or_else(|| {
                    Error::Validation(format!(
                        "discovery candidate {} projects onto absent release unit {release_unit}",
                        candidate.id
                    ))
                })?;
                if candidate.projection.is_some() {
                    let projection = candidate_projection(candidate, &unit.path)?;
                    if !unit.projections.iter().any(|existing| {
                        existing.file == projection.file && existing.pointer == projection.pointer
                    }) {
                        unit.projections.push(projection);
                    }
                }
                config.discovery.managed_paths.push(ManagedPathReceipt {
                    detector: candidate.detector.clone(),
                    path: candidate.path.clone(),
                    release_unit: release_unit.clone(),
                });
            }
            CandidateResolution::Excluded => {
                let digest = candidate
                    .evidence
                    .iter()
                    .find(|item| item.path == candidate.path)
                    .expect("candidate path evidence validated")
                    .digest
                    .clone();
                config.discovery.excluded_paths.push(ExcludedPathReceipt {
                    detector: candidate.detector.clone(),
                    path: candidate.path.clone(),
                    evidence_digest: digest,
                });
            }
        }
    }
    config
        .discovery
        .managed_paths
        .sort_by(|a, b| (&a.detector, &a.path).cmp(&(&b.detector, &b.path)));
    config
        .discovery
        .excluded_paths
        .sort_by(|a, b| (&a.detector, &a.path).cmp(&(&b.detector, &b.path)));
    let npm_release_units = config
        .release_units
        .iter()
        .filter(|(_, unit)| {
            unit.projections
                .iter()
                .any(|projection| projection.adapter == Adapter::Npm)
        })
        .map(|(id, _)| id.clone())
        .collect::<BTreeSet<_>>();
    let configured_non_npm_dependencies = config
        .release_units
        .iter()
        .filter(|(_, unit)| {
            unit.projections
                .iter()
                .any(|projection| projection.adapter == Adapter::Npm)
        })
        .map(|(id, unit)| {
            // npm-to-npm edges are manifest-owned. Only edges that an npm
            // manifest cannot natively describe remain authored config.
            let dependencies = unit
                .depends_on
                .iter()
                .filter(|dependency| !npm_release_units.contains(*dependency))
                .cloned()
                .collect::<Vec<_>>();
            (id.clone(), dependencies)
        })
        .collect::<BTreeMap<_, _>>();
    derive_npm_dependencies(root, &mut config)?;
    for (id, dependencies) in configured_non_npm_dependencies {
        if let Some(unit) = config.release_units.get_mut(&id) {
            unit.depends_on.extend(dependencies);
            unit.depends_on.sort();
            unit.depends_on.dedup();
        }
    }
    config.validate()?;
    Ok(config)
}

fn candidate_projection(candidate: &DiscoveryCandidate, unit_path: &Path) -> Result<Projection> {
    let suggestion = candidate.projection.as_ref().ok_or_else(|| {
        Error::Validation(format!(
            "discovery candidate {} has no projection suggestion",
            candidate.id
        ))
    })?;
    let file = if unit_path == Path::new(".") {
        suggestion.path.clone()
    } else {
        suggestion
            .path
            .strip_prefix(unit_path)
            .map_err(|_| {
                Error::Validation(format!(
                    "candidate projection {} is outside release-unit path {}",
                    suggestion.path.display(),
                    unit_path.display()
                ))
            })?
            .to_owned()
    };
    Ok(Projection {
        adapter: suggestion.adapter,
        file,
        mode: suggestion.mode,
        pointer: suggestion.pointer.clone(),
    })
}

fn apply_changesets_candidate_resolutions(
    root: &Path,
    discovery: &mut Discovery,
    candidates: &[DiscoveryCandidate],
) -> Result<BTreeMap<String, String>> {
    let mut removed_release_units = BTreeSet::new();
    let mut identity_map = BTreeMap::new();
    for candidate in candidates {
        match &candidate.resolution {
            None => {}
            Some(CandidateResolution::Projection { release_unit, .. }) => {
                let projection_owner =
                    candidate_projection_owner(&discovery.config, candidate).map(str::to_owned);
                let Some(target) = discovery.config.release_units.get(release_unit) else {
                    return Err(Error::Validation(format!(
                        "Changesets discovery candidate {} projects onto absent release unit {release_unit}",
                        candidate.id
                    )));
                };
                let target_path = target.path.clone();
                if candidate.projection.is_some() {
                    if let Some(owner) = projection_owner.as_deref() {
                        let native_owner = candidate.native_identity.as_deref() == Some(owner);
                        if owner != release_unit && !native_owner {
                            return Err(Error::Validation(format!(
                                "Changesets discovery candidate {} projection is already owned by release unit {owner}, not {release_unit}",
                                candidate.id
                            )));
                        }
                    }
                    let projection = candidate_projection(candidate, &target_path)?;
                    let target = discovery
                        .config
                        .release_units
                        .get_mut(release_unit)
                        .expect("validated target release unit");
                    if let Some(existing) = target.projections.iter().find(|existing| {
                        existing.file == projection.file && existing.pointer == projection.pointer
                    }) {
                        if existing.adapter != projection.adapter
                            || existing.mode != projection.mode
                        {
                            return Err(Error::Validation(format!(
                                "Changesets discovery candidate {} conflicts with existing projection {} on release unit {release_unit}: adapter or mode differs",
                                candidate.id,
                                projection.file.display()
                            )));
                        }
                    } else {
                        target.projections.push(projection);
                    }
                }
                if let Some(native_identity) = &candidate.native_identity {
                    if native_identity != release_unit {
                        if let Some(existing) =
                            identity_map.insert(native_identity.clone(), release_unit.clone())
                        {
                            if existing != *release_unit {
                                return Err(Error::Validation(format!(
                                    "Changesets discovery candidates map native identity {native_identity} to both {existing} and {release_unit}"
                                )));
                            }
                        }
                        if let Some(source) =
                            discovery.config.release_units.get_mut(native_identity)
                        {
                            source.projections.retain(|projection| {
                                root.join(&source.path).join(&projection.file)
                                    != root.join(&candidate.path)
                            });
                            if source.projections.is_empty() {
                                removed_release_units.insert(native_identity.clone());
                            }
                        }
                    }
                }
                discovery
                    .config
                    .discovery
                    .managed_paths
                    .push(ManagedPathReceipt {
                        detector: candidate.detector.clone(),
                        path: candidate.path.clone(),
                        release_unit: release_unit.clone(),
                    });
            }
            Some(CandidateResolution::Excluded) => {
                if let Some(native_identity) = &candidate.native_identity {
                    if let Some(unit) = discovery.config.release_units.get_mut(native_identity) {
                        let unit_path = unit.path.clone();
                        unit.projections.retain(|projection| {
                            let path = if unit_path == Path::new(".") {
                                projection.file.clone()
                            } else {
                                unit_path.join(&projection.file)
                            };
                            path != candidate.path
                        });
                        if unit.projections.is_empty() {
                            removed_release_units.insert(native_identity.clone());
                        }
                    }
                }
                let digest = candidate
                    .evidence
                    .iter()
                    .find(|item| item.path == candidate.path)
                    .expect("candidate path evidence validated")
                    .digest
                    .clone();
                discovery
                    .config
                    .discovery
                    .excluded_paths
                    .push(ExcludedPathReceipt {
                        detector: candidate.detector.clone(),
                        path: candidate.path.clone(),
                        evidence_digest: digest,
                    });
            }
            Some(CandidateResolution::Independent { release_unit }) => {
                return Err(Error::Validation(format!(
                    "Changesets already establishes release unit {release_unit}; candidate {} must project onto it or be excluded",
                    candidate.id
                )));
            }
        }
    }
    for release_unit in &removed_release_units {
        discovery.config.release_units.remove(release_unit);
    }
    for (source, target) in &identity_map {
        if discovery.config.release_units.contains_key(source) {
            return Err(Error::Validation(format!(
                "Changesets discovery candidates leave native identity {source} split between release units {source} and {target}; resolve every projection for that identity consistently"
            )));
        }
        if discovery.workspace_packages.remove(source) {
            discovery.workspace_packages.insert(target.clone());
        }
        if discovery.private_packages.remove(source) {
            discovery.private_packages.insert(target.clone());
        }
        discovery.versions.remove(source);
    }
    for unit in discovery.config.release_units.values_mut() {
        for dependency in &mut unit.depends_on {
            if let Some(target) = identity_map.get(dependency) {
                *dependency = target.clone();
            }
        }
        unit.depends_on
            .retain(|dependency| !removed_release_units.contains(dependency));
        unit.depends_on.sort();
        unit.depends_on.dedup();
    }
    for edge in &mut discovery.npm_dependencies {
        if let Some(target) = identity_map.get(&edge.dependent) {
            edge.dependent = target.clone();
        }
        if let Some(target) = identity_map.get(&edge.dependency) {
            edge.dependency = target.clone();
        }
    }
    discovery.npm_dependencies.retain(|edge| {
        edge.dependent != edge.dependency
            && discovery.config.release_units.contains_key(&edge.dependent)
            && discovery
                .config
                .release_units
                .contains_key(&edge.dependency)
    });
    retain_materialized_npm_dependencies(&mut discovery.config, &mut discovery.npm_dependencies);
    discovery
        .config
        .discovery
        .managed_paths
        .sort_by(|left, right| (&left.detector, &left.path).cmp(&(&right.detector, &right.path)));
    discovery
        .config
        .discovery
        .excluded_paths
        .sort_by(|left, right| (&left.detector, &left.path).cmp(&(&right.detector, &right.path)));
    recompute_resolved_versions(discovery, candidates)?;
    Ok(identity_map)
}

fn recompute_resolved_versions(
    discovery: &mut Discovery,
    candidates: &[DiscoveryCandidate],
) -> Result<()> {
    let mut versions = BTreeMap::<String, BTreeSet<Version>>::new();
    let mut unresolved = BTreeSet::new();
    for candidate in candidates {
        let Some(raw_version) = candidate.raw_version.as_ref() else {
            continue;
        };
        let Some(native_identity) = candidate.native_identity.as_ref() else {
            continue;
        };
        let release_unit = match candidate.resolution.as_ref() {
            Some(CandidateResolution::Projection { release_unit, .. })
            | Some(CandidateResolution::Independent { release_unit }) => release_unit,
            Some(CandidateResolution::Excluded) => continue,
            None => {
                unresolved.insert(native_identity.clone());
                native_identity
            }
        };
        if !discovery.config.release_units.contains_key(release_unit) {
            continue;
        }
        if let Ok(version) = Version::parse(&raw_version.value) {
            versions
                .entry(release_unit.clone())
                .or_default()
                .insert(version);
        }
    }

    discovery.versions.clear();
    for (release_unit, observed) in versions {
        if observed.len() == 1 {
            discovery.versions.insert(
                release_unit,
                observed.into_iter().next().expect("one observed version"),
            );
        } else if !unresolved.contains(&release_unit) {
            return Err(Error::Validation(format!(
                "resolved discovery candidates for release unit {release_unit} disagree on current version: {}",
                observed
                    .into_iter()
                    .map(|version| version.to_string())
                    .collect::<Vec<_>>()
                    .join(", ")
            )));
        }
    }
    Ok(())
}

fn candidate_projection_owner<'a>(
    config: &'a Config,
    candidate: &DiscoveryCandidate,
) -> Option<&'a str> {
    let Some(suggestion) = &candidate.projection else {
        return None;
    };
    config.release_units.iter().find_map(|(id, unit)| {
        unit.projections
            .iter()
            .any(|projection| {
                projection_workspace_path(unit, projection) == suggestion.path
                    && projection.pointer == suggestion.pointer
            })
            .then_some(id.as_str())
    })
}

fn projection_workspace_path(unit: &ReleaseUnitConfig, projection: &Projection) -> PathBuf {
    if unit.path == Path::new(".") {
        projection.file.clone()
    } else {
        unit.path.join(&projection.file)
    }
}

fn changesets_plan(root: &Path, take_over: bool) -> Result<InitResult> {
    let previous = load_previous_plan(root)?;
    let changesets_config_path = root.join(CHANGESETS_CONFIG);
    let changesets_text = std::fs::read_to_string(&changesets_config_path)
        .map_err(|error| Error::io(&changesets_config_path, error))?;
    let changesets: JsonValue = serde_json::from_str(&changesets_text)
        .map_err(|error| Error::Validation(format!("invalid Changesets config: {error}")))?;
    let mut converted_intents = load_changesets_intents(root)?;
    let mut referenced_names = converted_intents
        .iter()
        .flat_map(|intent| intent.release_units.keys().cloned())
        .collect::<BTreeSet<_>>();
    for key in ["ignore", "fixed", "linked"] {
        collect_json_strings(&changesets[key], &mut referenced_names);
    }
    let mut discovery = discover(root)?;
    reconcile_candidate_resolutions(&mut discovery.candidates, previous.as_ref());
    let candidates = discovery.candidates.clone();
    let identity_map = apply_changesets_candidate_resolutions(root, &mut discovery, &candidates)?;
    discovery.config.settings.pre_1_0_bump_mapping = Pre1BumpMapping::Component;
    discovery.config.settings.internal_dependency_bump = changesets["updateInternalDependencies"]
        .as_str()
        .and_then(|value| value.parse().ok())
        .unwrap_or(Bump::Patch);
    discovery.config.fixed = parse_groups(&changesets["fixed"])?;
    discovery.config.linked = parse_groups(&changesets["linked"])?;
    remap_groups(&mut discovery.config.fixed, &identity_map);
    remap_groups(&mut discovery.config.linked, &identity_map);
    remap_converted_intents(&mut converted_intents, &identity_map, &discovery.config)?;

    let mut diagnostics = Vec::new();
    let config_evidence = evidence(root, Path::new(CHANGESETS_CONFIG), Vec::new())?;
    for ignored in changesets["ignore"].as_array().into_iter().flatten() {
        let Some(source_package) = ignored.as_str() else {
            continue;
        };
        diagnostics.push(InitDiagnostic {
            id: format!("ignored-release-unit-disposition:{source_package}"),
            code: "ignored-release-unit-disposition".to_owned(),
            message: format!(
                "Choose whether Changesets-ignored package {source_package} is suspended, excluded, or managed. Selecting managed requires removing it from Changesets ignore before takeover."
            ),
            evidence: vec![config_evidence.clone()],
            choices: vec!["suspended".to_owned(), "excluded".to_owned(), "managed".to_owned()],
            recommended: Some("suspended".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    if let Some((versions_private, tags_private)) =
        changesets_private_package_settings(&changesets["privatePackages"])
    {
        diagnostics.push(InitDiagnostic {
            id: "private-package-versioning".to_owned(),
            code: "private-package-versioning".to_owned(),
            message: if versions_private {
                "Changesets versions private packages; Intentional preserves that behavior because package privacy is independent from version management.".to_owned()
            } else {
                "Changesets suppresses private-package versions; Intentional manages versions independently from publication privacy, so accepting Intentional semantics is a deliberate contract change.".to_owned()
            },
            evidence: vec![config_evidence.clone()],
            choices: if versions_private {
                Vec::new()
            } else {
                vec!["intentional".to_owned()]
            },
            recommended: (!versions_private).then(|| "intentional".to_owned()),
            resolution: None,
            verified: versions_private,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
        if !tags_private {
            diagnostics.push(InitDiagnostic {
                id: "private-package-tagging".to_owned(),
                code: "private-package-tagging".to_owned(),
                message: "Changesets suppresses private-package tags; Intentional creates annotated records for every managed release unit, independently from publication privacy.".to_owned(),
                evidence: vec![config_evidence.clone()],
                choices: vec!["intentional".to_owned()],
                recommended: Some("intentional".to_owned()),
                resolution: None,
                verified: false,
                invalidated_resolution: false,
                supporting_evidence: Vec::new(),
                contradictory_evidence: Vec::new(),
                uncertainty: None,
            });
        }
    }
    if changesets["changelog"] != JsonValue::Bool(false) && !changesets["changelog"].is_null() {
        diagnostics.push(InitDiagnostic {
            id: "changesets-changelog".to_owned(),
            code: "changesets-changelog".to_owned(),
            message: "Intentional renders its contract-defined release-unit changelogs instead of invoking the configured Changesets changelog generator.".to_owned(),
            evidence: vec![config_evidence.clone()],
            choices: vec!["intentional".to_owned()],
            recommended: Some("intentional".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    if changesets["commit"] != JsonValue::Bool(false) && !changesets["commit"].is_null() {
        diagnostics.push(InitDiagnostic {
            id: "changesets-commit".to_owned(),
            code: "changesets-commit".to_owned(),
            message: "Intentional never creates commits; repository orchestration must retain the configured commit behavior externally.".to_owned(),
            evidence: vec![config_evidence.clone()],
            choices: vec!["external".to_owned()],
            recommended: Some("external".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    if changesets["___experimentalUnsafeOptions_WILL_CHANGE_IN_PATCH"]
        ["onlyUpdatePeerDependentsWhenOutOfRange"]
        .as_bool()
        == Some(true)
    {
        diagnostics.push(InitDiagnostic {
            id: "changesets-peer-dependent-policy".to_owned(),
            code: "changesets-peer-dependent-policy".to_owned(),
            message: "Changesets conditionally updates peer dependents from npm ranges; Intentional applies explicit depends-on edges uniformly. Accept Intentional's dependency contract, and resolve any current release divergence shown by parity before takeover.".to_owned(),
            evidence: vec![config_evidence.clone()],
            choices: vec!["intentional".to_owned()],
            recommended: Some("intentional".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    let dev_dependents = discovery
        .npm_dependencies
        .iter()
        .filter(|edge| edge.kind == NpmDependencyKind::Dev)
        .map(|edge| edge.dependent.clone())
        .collect::<BTreeSet<_>>();
    if !dev_dependents.is_empty() {
        let evidence = dev_dependents
            .iter()
            .filter_map(|id| {
                let release_unit = &discovery.config.release_units[id];
                release_unit
                    .projections
                    .iter()
                    .find(|projection| projection.adapter == Adapter::Npm)
                    .map(|projection| release_unit.path.join(&projection.file))
            })
            .map(|path| evidence(root, &path, Vec::new()))
            .collect::<Result<Vec<_>>>()?;
        diagnostics.push(InitDiagnostic {
            id: "changesets-dev-dependency-policy".to_owned(),
            code: "changesets-dev-dependency-policy".to_owned(),
            message: "Changesets propagates releases through internal devDependencies; Intentional reserves depends-on for durable release dependencies. Accept Intentional's dependency contract, and resolve any current release divergence shown by parity before takeover.".to_owned(),
            evidence,
            choices: vec!["intentional".to_owned()],
            recommended: Some("intentional".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    diagnostics.extend(release_tool_proxy_diagnostics(
        root,
        &discovery.candidates,
        &referenced_names,
    )?);
    let mut unmapped_release_units = BTreeSet::new();
    for release_unit in discovery.config.release_units.keys() {
        if referenced_names.contains(release_unit)
            || discovery.workspace_packages.contains(release_unit)
            || identity_map.values().any(|target| target == release_unit)
        {
            continue;
        }
        unmapped_release_units.insert(release_unit.clone());
        let release_unit_config = &discovery.config.release_units[release_unit];
        let manifest = release_unit_config
            .projections
            .first()
            .map(|projection| release_unit_config.path.join(&projection.file))
            .ok_or_else(|| {
                Error::Validation(format!(
                    "discovered release unit {release_unit} has no manifest evidence"
                ))
            })?;
        diagnostics.push(InitDiagnostic {
            id: format!("unmapped-release-unit-disposition:{release_unit}"),
            code: "unmapped-release-unit-disposition".to_owned(),
            message: format!(
                "Choose whether workspace package {release_unit}, which is outside the Changesets release inventory, is excluded, suspended, or managed."
            ),
            evidence: vec![evidence(root, &manifest, Vec::new())?],
            choices: vec!["excluded".to_owned(), "suspended".to_owned(), "managed".to_owned()],
            recommended: Some("excluded".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    let current_integrations = scan_changesets_integrations(root)?;
    for item in &current_integrations {
        diagnostics.push(InitDiagnostic {
            id: format!("repository-integration:{}", item.path.display()),
            code: "repository-integration".to_owned(),
            message: format!(
                "Remove or replace executable Changesets references in {} and rerun init for verification.",
                item.path.display()
            ),
            evidence: vec![item.clone()],
            choices: vec!["removed".to_owned()],
            recommended: Some("removed".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    let integration_paths = current_integrations
        .iter()
        .map(|item| item.path.as_path())
        .collect::<BTreeSet<_>>();
    for item in scan_external_release_evidence(root)?
        .into_iter()
        .filter(|item| !integration_paths.contains(item.path.as_path()))
    {
        diagnostics.push(InitDiagnostic {
            id: format!("external-release-evidence:{}", item.path.display()),
            code: "external-release-evidence".to_owned(),
            message: format!(
                "Keep repository-specific release behavior from {} in the external release executor; Intentional records this file as evidence without interpreting its contents.",
                item.path.display()
            ),
            evidence: vec![item],
            choices: vec!["external".to_owned()],
            recommended: Some("external".to_owned()),
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    reconcile_diagnostics(
        root,
        &mut diagnostics,
        previous.as_ref(),
        &discovery.candidates,
    )?;
    let mut source_config = discovery.config.clone();
    let ignored = changesets["ignore"]
        .as_array()
        .into_iter()
        .flatten()
        .filter_map(JsonValue::as_str)
        .map(str::to_owned)
        .collect::<BTreeSet<_>>();
    let source_excluded = ignored
        .iter()
        .cloned()
        .chain(unmapped_release_units.iter().cloned())
        .collect();
    exclude_release_units(&mut source_config, &source_excluded);
    apply_disposition_resolutions(&mut discovery.config, &diagnostics)?;
    let proxy_removals = apply_proxy_manifest_resolutions(
        &mut discovery.config,
        &diagnostics,
        &discovery.candidates,
    )?;
    retain_materialized_npm_dependencies(&mut discovery.config, &mut discovery.npm_dependencies);
    discovery.config.validate()?;

    let declared: BTreeMap<String, Bump> =
        converted_intents
            .iter()
            .fold(BTreeMap::new(), |mut aggregate, intent| {
                for (id, bump) in &intent.release_units {
                    aggregate
                        .entry(id.clone())
                        .and_modify(|existing| *existing = (*existing).max(*bump))
                        .or_insert(*bump);
                }
                aggregate
            });
    let suppress_private_versions =
        changesets_private_package_settings(&changesets["privatePackages"])
            .is_some_and(|(versions_private, _)| !versions_private);
    let merged_ignored = ignored
        .iter()
        .filter_map(|source| {
            identity_map
                .get(source)
                .map(|target| (source.clone(), target.clone()))
        })
        .collect::<Vec<_>>();
    let merged_ignore_error = (!merged_ignored.is_empty()).then(|| {
        let conflicts = merged_ignored
            .iter()
            .map(|(source, target)| format!("{source} onto {target}"))
            .collect::<Vec<_>>()
            .join(", ");
        format!(
            "Changesets ignore names native package identities that candidate resolutions map onto managed release units ({conflicts}); source parity cannot apply a package-scoped ignore after identities are merged. Remove the ignore entries or revise the candidate resolutions before takeover"
        )
    });
    let mut skipped_release_units = ignored.clone();
    if suppress_private_versions {
        skipped_release_units.extend(discovery.private_packages.iter().cloned());
    }
    skipped_release_units.extend(
        discovery
            .config
            .release_units
            .keys()
            .filter(|id| !discovery.versions.contains_key(*id))
            .cloned(),
    );
    let source_semantics = ChangesetsSourceSemantics {
        private_packages: &discovery.private_packages,
        suppress_private_versions,
        npm_dependencies: &discovery.npm_dependencies,
        internal_dependency_bump: discovery.config.settings.internal_dependency_bump,
        update_internal_dependents_always: changesets
            ["___experimentalUnsafeOptions_WILL_CHANGE_IN_PATCH"]["updateInternalDependents"]
            .as_str()
            == Some("always"),
        only_update_peer_dependents_when_out_of_range: changesets
            ["___experimentalUnsafeOptions_WILL_CHANGE_IN_PATCH"]
            ["onlyUpdatePeerDependentsWhenOutOfRange"]
            .as_bool()
            .unwrap_or(false),
        preflight_error: merged_ignore_error
            .or_else(|| mixed_skipped_changeset(&converted_intents, &skipped_release_units)),
    };
    let parity = parity_result(
        &source_config,
        &discovery.config,
        &discovery.versions,
        &declared,
        &source_semantics,
    )?;
    if let Some(message) = &parity.source_error {
        diagnostics.push(InitDiagnostic {
            id: "changesets-release-invalid".to_owned(),
            code: "changesets-release-invalid".to_owned(),
            message: format!("The source Changesets release is invalid: {message}"),
            evidence: vec![config_evidence.clone()],
            choices: Vec::new(),
            recommended: None,
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
    }
    if let Some(message) = &parity.proposed_error {
        diagnostics.push(InitDiagnostic {
            id: "proposed-release-invalid".to_owned(),
            code: "proposed-release-invalid".to_owned(),
            message: format!("The proposed Intentional release is invalid: {message}"),
            evidence: vec![config_evidence.clone()],
            choices: Vec::new(),
            recommended: None,
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence: Vec::new(),
            contradictory_evidence: Vec::new(),
            uncertainty: None,
        });
        diagnostics.sort_by(|left, right| left.id.cmp(&right.id));
    }
    let unresolved = discovery
        .candidates
        .iter()
        .any(|candidate| candidate.resolution.is_none())
        || diagnostics.iter().any(|diagnostic| {
            !diagnostic.choices.is_empty()
                && (diagnostic.resolution.is_none() || !diagnostic.verified)
        });
    let state = if unresolved || parity.result.status != "equivalent" {
        InitState::NeedsInput
    } else {
        InitState::Ready
    };

    let mut evidence_paths = discovery.evidence;
    evidence_paths.insert(PathBuf::from(CHANGESETS_CONFIG));
    for intent in &converted_intents {
        evidence_paths.insert(intent.source.clone());
    }
    for diagnostic in &diagnostics {
        for item in &diagnostic.evidence {
            evidence_paths.insert(item.path.clone());
        }
    }
    let source_fingerprint = fingerprint(root, &evidence_paths)?;
    let planned_operations = takeover_operations(root, &converted_intents, &proxy_removals);
    let mut plan = InitPlan {
        schema: INIT_PLAN_SCHEMA.to_owned(),
        state,
        source_kind: "changesets".to_owned(),
        source_fingerprint,
        inferred_config: discovery.config,
        discovery_candidates: discovery.candidates,
        diagnostics,
        converted_intents,
        parity: parity.result,
        planned_operations: planned_operations.clone(),
        post_commit_action: "intentional tag --baseline".to_owned(),
    };
    // The state is always recomputed after reading editable resolutions.
    plan.state = state;
    let contents = plan.to_yaml()?;

    if take_over {
        if state != InitState::Ready {
            return Err(Error::Validation(
                "takeover requires a ready initialization plan with verified resolutions and parity"
                    .to_owned(),
            ));
        }
        let mut writes = vec![(PathBuf::from(CONFIG_PATH), plan.inferred_config.to_yaml()?)];
        for intent in &plan.converted_intents {
            writes.push((intent.target.clone(), intent.contents()?));
        }
        let deletes = takeover_deletes(root, &proxy_removals);
        verify_proxy_removal_preconditions(root, &proxy_removals)?;
        verify_takeover_preconditions(root, &writes, &plan.source_fingerprint, &evidence_paths)?;
        let takeover_evidence = Some((plan.source_fingerprint.clone(), evidence_paths));
        return Ok(InitResult {
            state: InitState::Success,
            path: PathBuf::from(CONFIG_PATH),
            contents: plan.inferred_config.to_yaml()?,
            operations: planned_operations,
            plan: Some(plan),
            writes,
            deletes,
            proxy_removals,
            takeover: true,
            takeover_evidence,
        });
    }

    Ok(InitResult {
        state,
        path: PathBuf::from(INIT_PLAN_PATH),
        operations: vec![format!("write {INIT_PLAN_PATH}")],
        contents: contents.clone(),
        plan: Some(plan),
        writes: vec![(PathBuf::from(INIT_PLAN_PATH), contents)],
        deletes: Vec::new(),
        proxy_removals,
        takeover: false,
        takeover_evidence: None,
    })
}

fn discover(root: &Path) -> Result<Discovery> {
    let workspace_paths = workspace_manifest_paths(root)?;
    let manifest_paths = all_manifest_paths(root)?;
    let mut discovery = Discovery {
        config: Config::default(),
        ..Discovery::default()
    };
    let mut observations = Vec::new();
    for path in manifest_paths {
        if let Some(candidate) = devcontainer_candidate(root, &path)? {
            discovery.evidence.insert(candidate.path.clone());
            if let (Some(native_identity), Some(projection), Some(tag)) = (
                candidate.native_identity.clone(),
                candidate.projection.clone(),
                candidate.tag.clone(),
            ) {
                observations.push(ManifestObservation {
                    candidate_path: candidate.path.clone(),
                    native_identity,
                    private_package: false,
                    projection,
                    raw_version: candidate
                        .raw_version
                        .as_ref()
                        .map(|version| version.value.clone()),
                    tag,
                    workspace_package: workspace_paths.contains(&path),
                });
            }
            discovery.candidates.push(candidate);
            continue;
        }
        let Some(adapter) = adapter_for(&path) else {
            continue;
        };
        if !is_project_manifest(&path, adapter)? {
            continue;
        }
        let (id, version) = manifest_identity(&path, adapter)?;
        let relative_manifest = path
            .strip_prefix(root)
            .map_err(|error| Error::Validation(format!("manifest is outside workspace: {error}")))?
            .to_owned();
        let manifest_evidence = evidence(root, &relative_manifest, Vec::new())?;
        let detector = detector_for(adapter).to_owned();
        let candidate = DiscoveryCandidate {
            id: DiscoveryCandidate::stable_id(&detector, &relative_manifest)?,
            detector,
            path: relative_manifest.clone(),
            evidence: vec![manifest_evidence.clone()],
            native_identity: Some(id.clone()),
            raw_version: version.as_ref().map(|value| RawVersionEvidence {
                value: value.clone(),
                evidence: vec![manifest_evidence],
            }),
            projection: Some(CandidateProjectionSuggestion {
                adapter,
                path: relative_manifest.clone(),
                mode: if adapter == Adapter::Go {
                    ProjectionMode::None
                } else {
                    ProjectionMode::Committed
                },
                pointer: None,
            }),
            tag: Some(CandidateTagSuggestion {
                id: "primary".to_owned(),
                role: TagRole::Primary,
                template: "{id}@{version}".to_owned(),
            }),
            diagnostics: Vec::new(),
            resolution: None,
        };
        observations.push(ManifestObservation {
            candidate_path: relative_manifest.clone(),
            native_identity: id,
            private_package: adapter == Adapter::Npm && npm_manifest_is_private(&path)?,
            projection: candidate
                .projection
                .clone()
                .expect("project manifest has projection"),
            raw_version: version,
            tag: candidate.tag.clone().expect("project manifest has tag"),
            workspace_package: workspace_paths.contains(&path),
        });
        discovery.candidates.push(candidate);
        discovery
            .evidence
            .insert(path.strip_prefix(root).unwrap_or(&path).to_owned());
    }
    materialize_discovery_inventory(&mut discovery, observations)?;
    discovery.npm_dependencies = derive_npm_dependencies(root, &mut discovery.config)?;
    discovery
        .candidates
        .sort_by(|left, right| left.path.cmp(&right.path));
    Ok(discovery)
}

fn materialize_discovery_inventory(
    discovery: &mut Discovery,
    observations: Vec<ManifestObservation>,
) -> Result<()> {
    let mut by_identity = BTreeMap::<String, Vec<ManifestObservation>>::new();
    for observation in observations {
        by_identity
            .entry(observation.native_identity.clone())
            .or_default()
            .push(observation);
    }
    for (identity, mut observations) in by_identity {
        observations.sort_by(|left, right| left.candidate_path.cmp(&right.candidate_path));
        let directories = observations
            .iter()
            .map(|observation| {
                observation
                    .candidate_path
                    .parent()
                    .filter(|path| !path.as_os_str().is_empty())
                    .map(Path::to_path_buf)
                    .unwrap_or_else(|| PathBuf::from("."))
            })
            .collect::<BTreeSet<_>>();
        let path = if directories.len() == 1 {
            directories.into_iter().next().expect("one directory")
        } else {
            PathBuf::from(".")
        };
        let projections = observations
            .iter()
            .map(|observation| -> Result<Projection> {
                let file = if path == Path::new(".") {
                    observation.projection.path.clone()
                } else {
                    observation
                        .projection
                        .path
                        .strip_prefix(&path)
                        .map_err(|_| {
                            Error::Validation(format!(
                                "candidate projection {} is outside native identity directory {}",
                                observation.projection.path.display(),
                                path.display()
                            ))
                        })?
                        .to_owned()
                };
                Ok(Projection {
                    adapter: observation.projection.adapter,
                    file,
                    mode: observation.projection.mode,
                    pointer: observation.projection.pointer.clone(),
                })
            })
            .collect::<Result<Vec<_>>>()?;
        let tag = observations
            .first()
            .map(|observation| &observation.tag)
            .expect("identity group is not empty");
        discovery.config.release_units.insert(
            identity.clone(),
            ReleaseUnitConfig {
                path,
                disposition: ReleaseUnitDisposition::Managed,
                projections,
                tags: BTreeMap::from([(
                    tag.id.clone(),
                    TagConfig {
                        role: tag.role,
                        template: tag.template.clone(),
                        require_phase: None,
                        tag_after: Vec::new(),
                    },
                )]),
                depends_on: Vec::new(),
            },
        );
        let versions = observations
            .iter()
            .filter_map(|observation| observation.raw_version.as_deref())
            .filter_map(|version| Version::parse(version).ok())
            .collect::<BTreeSet<_>>();
        if versions.len() == 1 {
            discovery.versions.insert(
                identity.clone(),
                versions.into_iter().next().expect("one version"),
            );
        }
        if observations
            .iter()
            .any(|observation| observation.workspace_package)
        {
            discovery.workspace_packages.insert(identity.clone());
        }
        if observations
            .iter()
            .any(|observation| observation.private_package)
        {
            discovery.private_packages.insert(identity);
        }
    }
    Ok(())
}

fn workspace_manifest_paths(root: &Path) -> Result<BTreeSet<PathBuf>> {
    let mut directories = BTreeSet::new();
    let mut found_workspace = false;
    let pnpm = root.join("pnpm-workspace.yaml");
    if pnpm.exists() {
        found_workspace = true;
        let text = std::fs::read_to_string(&pnpm).map_err(|error| Error::io(&pnpm, error))?;
        let value: serde_yaml::Value = serde_yaml::from_str(&text)?;
        expand_workspace_patterns(
            root,
            value["packages"]
                .as_sequence()
                .into_iter()
                .flatten()
                .filter_map(serde_yaml::Value::as_str),
            &mut directories,
        )?;
    }
    let package_json = root.join("package.json");
    if package_json.exists() {
        let text = std::fs::read_to_string(&package_json)
            .map_err(|error| Error::io(&package_json, error))?;
        let value: JsonValue = serde_json::from_str(&text)
            .map_err(|error| Error::Validation(format!("invalid package.json: {error}")))?;
        let workspaces = value["workspaces"]
            .as_array()
            .or_else(|| value["workspaces"]["packages"].as_array());
        if let Some(workspaces) = workspaces {
            found_workspace = true;
            expand_workspace_patterns(
                root,
                workspaces.iter().filter_map(JsonValue::as_str),
                &mut directories,
            )?;
        }
    }
    let cargo = root.join("Cargo.toml");
    if cargo.exists() {
        let text = std::fs::read_to_string(&cargo).map_err(|error| Error::io(&cargo, error))?;
        let document = text
            .parse::<toml_edit::DocumentMut>()
            .map_err(|error| Error::Validation(format!("invalid Cargo.toml: {error}")))?;
        if let Some(members) = document
            .get("workspace")
            .and_then(|workspace| workspace.get("members"))
            .and_then(toml_edit::Item::as_array)
        {
            found_workspace = true;
            expand_workspace_patterns(
                root,
                members.iter().filter_map(toml_edit::Value::as_str),
                &mut directories,
            )?;
        }
    }
    if !found_workspace {
        directories.insert(root.to_owned());
    }
    let mut paths = BTreeSet::new();
    for directory in directories {
        add_manifests_in_directory(&directory, &mut paths)?;
    }
    paths.retain(|path| !hard_excluded(root, path));
    remove_git_ignored(root, &mut paths)?;
    Ok(paths)
}

fn expand_workspace_pattern(
    root: &Path,
    pattern: &str,
    directories: &mut BTreeSet<PathBuf>,
) -> Result<()> {
    let (excluded, pattern) = pattern
        .strip_prefix('!')
        .map_or((false, pattern), |pattern| (true, pattern));
    let absolute = root.join(pattern).to_string_lossy().to_string();
    for entry in glob(&absolute).map_err(|error| {
        Error::Validation(format!("invalid workspace pattern {pattern}: {error}"))
    })? {
        let path = entry
            .map_err(|error| Error::Validation(format!("workspace pattern failed: {error}")))?;
        if path.is_dir() {
            if excluded {
                directories.remove(&path);
            } else {
                directories.insert(path);
            }
        }
    }
    Ok(())
}

fn expand_workspace_patterns<'a>(
    root: &Path,
    patterns: impl IntoIterator<Item = &'a str>,
    directories: &mut BTreeSet<PathBuf>,
) -> Result<()> {
    let patterns = patterns.into_iter().collect::<Vec<_>>();
    for excluded in [false, true] {
        for pattern in &patterns {
            if pattern.starts_with('!') == excluded {
                expand_workspace_pattern(root, pattern, directories)?;
            }
        }
    }
    Ok(())
}

fn add_manifests_in_directory(directory: &Path, paths: &mut BTreeSet<PathBuf>) -> Result<()> {
    for name in [
        "package.json",
        "Cargo.toml",
        "pubspec.yaml",
        "pyproject.toml",
        "go.mod",
        DEVCONTAINER_FEATURE_MANIFEST,
        DEVCONTAINER_TEMPLATE_MANIFEST,
    ] {
        let path = directory.join(name);
        if path.is_file() {
            paths.insert(path);
        }
    }
    for entry in std::fs::read_dir(directory).map_err(|error| Error::io(directory, error))? {
        let path = entry.map_err(|error| Error::io(directory, error))?.path();
        if path
            .extension()
            .is_some_and(|extension| extension == "csproj")
        {
            paths.insert(path);
        }
    }
    Ok(())
}

fn all_manifest_paths(root: &Path) -> Result<BTreeSet<PathBuf>> {
    let mut paths = WalkDir::new(root)
        .into_iter()
        .filter_entry(|entry| !hard_excluded(root, entry.path()))
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file() && is_discoverable_manifest(entry.path()))
        .map(|entry| entry.into_path())
        .collect();
    remove_git_ignored(root, &mut paths)?;
    Ok(paths)
}

fn hard_excluded(root: &Path, path: &Path) -> bool {
    path.strip_prefix(root)
        .unwrap_or(path)
        .components()
        .filter_map(|component| match component {
            std::path::Component::Normal(value) => value.to_str(),
            _ => None,
        })
        .any(|component| {
            matches!(
                component,
                ".git"
                    | ".intentional"
                    | "node_modules"
                    | "target"
                    | ".pnpm-store"
                    | ".yarn"
                    | ".npm"
                    | ".cache"
                    | ".venv"
                    | "venv"
                    | "__pycache__"
                    | ".tox"
                    | ".nox"
                    | ".pytest_cache"
                    | ".mypy_cache"
                    | ".ruff_cache"
                    | ".dart_tool"
                    | ".pub-cache"
                    | "obj"
            )
        })
}

fn remove_git_ignored(root: &Path, paths: &mut BTreeSet<PathBuf>) -> Result<()> {
    if paths.is_empty() {
        return Ok(());
    }
    let relative_paths = paths
        .iter()
        .map(|path| path.strip_prefix(root).unwrap_or(path).to_owned())
        .collect::<Vec<_>>();
    let mut input = Vec::new();
    for path in &relative_paths {
        input.extend_from_slice(path.to_string_lossy().as_bytes());
        input.push(0);
    }
    let mut child = Command::new("git")
        .args(["check-ignore", "--stdin", "-z"])
        .current_dir(root)
        .stdin(Stdio::piped())
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .spawn()
        .map_err(|error| Error::io(root, error))?;
    let mut stdin = child.stdin.take().expect("piped git check-ignore stdin");
    let writer = std::thread::spawn(move || stdin.write_all(&input));
    let output = child
        .wait_with_output()
        .map_err(|error| Error::io(root, error))?;
    writer
        .join()
        .map_err(|_| Error::Validation("git check-ignore input writer panicked".to_owned()))?
        .map_err(|error| Error::io(root, error))?;
    if !matches!(output.status.code(), Some(0 | 1)) {
        return Err(Error::Validation(format!(
            "git check-ignore failed: {}",
            String::from_utf8_lossy(&output.stderr).trim()
        )));
    }
    let ignored = output
        .stdout
        .split(|byte| *byte == 0)
        .filter(|path| !path.is_empty())
        .map(|path| PathBuf::from(String::from_utf8_lossy(path).into_owned()))
        .collect::<BTreeSet<_>>();
    paths.retain(|path| {
        let relative = path.strip_prefix(root).unwrap_or(path);
        !ignored.contains(relative)
    });
    Ok(())
}

fn detector_for(adapter: Adapter) -> &'static str {
    match adapter {
        Adapter::Npm => "npm-package",
        Adapter::Cargo => "cargo-package",
        Adapter::Go => "go-module",
        Adapter::Python => "python-project",
        Adapter::Msbuild => "msbuild-project",
        Adapter::Pub => "dart-package",
        Adapter::Json | Adapter::Toml | Adapter::Yaml => {
            unreachable!("generic adapters are not discovered")
        }
    }
}

fn devcontainer_detector_for(path: &Path) -> Option<&'static str> {
    match path.file_name()?.to_str()? {
        DEVCONTAINER_FEATURE_MANIFEST => Some("devcontainer-feature"),
        DEVCONTAINER_TEMPLATE_MANIFEST => Some("devcontainer-template"),
        _ => None,
    }
}

fn is_discoverable_manifest(path: &Path) -> bool {
    adapter_for(path).is_some() || devcontainer_detector_for(path).is_some()
}

fn devcontainer_candidate(root: &Path, path: &Path) -> Result<Option<DiscoveryCandidate>> {
    let Some(detector) = devcontainer_detector_for(path) else {
        return Ok(None);
    };
    let relative = path
        .strip_prefix(root)
        .map_err(|error| Error::Validation(format!("manifest is outside workspace: {error}")))?
        .to_owned();
    let bytes = std::fs::read(path).map_err(|error| Error::io(path, error))?;
    let source = SourceEvidence {
        path: relative.clone(),
        digest: sha256_digest(&bytes),
        lines: Vec::new(),
    };
    let mut diagnostics = Vec::new();
    let value = match std::str::from_utf8(&bytes) {
        Ok(text) => serde_json::from_str::<JsonValue>(text).map_err(|error| error.to_string()),
        Err(error) => Err(error.to_string()),
    };
    let (native_identity, raw_version, projection, tag) = match value {
        Ok(value) => {
            let native_identity = non_empty_json_string(&value["id"]);
            if native_identity.is_none() {
                diagnostics.push(extraction_diagnostic(
                    "identity-extraction",
                    "devcontainer-id-unreadable",
                    format!(
                        "{} has no non-empty string id; the detector inspects only id for identity.",
                        relative.display()
                    ),
                    &source,
                ));
            }

            let version = non_empty_json_string(&value["version"]);
            if version.is_none() {
                diagnostics.push(extraction_diagnostic(
                    "version-extraction",
                    "devcontainer-version-unreadable",
                    format!(
                        "{} has no non-empty string version; the detector inspects only version for version evidence.",
                        relative.display()
                    ),
                    &source,
                ));
            }
            let valid_version = version.as_deref().is_some_and(|version| {
                if let Err(error) = Version::parse(version) {
                    diagnostics.push(extraction_diagnostic(
                        "version-semver",
                        "devcontainer-version-not-semver",
                        format!(
                            "{} version {version:?} is not Semantic Versioning 2.0.0: {error}.",
                            relative.display()
                        ),
                        &source,
                    ));
                    false
                } else {
                    true
                }
            });
            let raw_version = version.map(|value| RawVersionEvidence {
                value,
                evidence: vec![source.clone()],
            });
            let projection = valid_version.then(|| CandidateProjectionSuggestion {
                adapter: Adapter::Json,
                path: relative.clone(),
                mode: ProjectionMode::Committed,
                pointer: Some("/version".to_owned()),
            });
            let tag = native_identity.as_ref().map(|_| CandidateTagSuggestion {
                id: "primary".to_owned(),
                role: TagRole::Primary,
                template: "{id}@{version}".to_owned(),
            });
            (native_identity, raw_version, projection, tag)
        }
        Err(error) => {
            diagnostics.push(extraction_diagnostic(
                "manifest-extraction",
                "devcontainer-json-unreadable",
                format!(
                    "{} could not be read as JSON for id and version extraction: {error}.",
                    relative.display()
                ),
                &source,
            ));
            (None, None, None, None)
        }
    };

    Ok(Some(DiscoveryCandidate {
        id: DiscoveryCandidate::stable_id(detector, &relative)?,
        detector: detector.to_owned(),
        path: relative,
        evidence: vec![source],
        native_identity,
        raw_version,
        projection,
        tag,
        diagnostics,
        resolution: None,
    }))
}

fn non_empty_json_string(value: &JsonValue) -> Option<String> {
    value
        .as_str()
        .filter(|value| !value.is_empty())
        .map(str::to_owned)
}

fn extraction_diagnostic(
    id: &str,
    code: &str,
    message: String,
    evidence: &SourceEvidence,
) -> ExtractionDiagnostic {
    ExtractionDiagnostic {
        id: id.to_owned(),
        code: code.to_owned(),
        message,
        evidence: vec![evidence.clone()],
    }
}

fn adapter_for(path: &Path) -> Option<Adapter> {
    let name = path.file_name()?.to_str()?;
    match name {
        "package.json" => Some(Adapter::Npm),
        "Cargo.toml" => Some(Adapter::Cargo),
        "pubspec.yaml" => Some(Adapter::Pub),
        "pyproject.toml" => Some(Adapter::Python),
        "go.mod" => Some(Adapter::Go),
        name if name.ends_with(".csproj") => Some(Adapter::Msbuild),
        _ => None,
    }
}

fn is_project_manifest(path: &Path, adapter: Adapter) -> Result<bool> {
    if adapter != Adapter::Cargo {
        return Ok(true);
    }
    let text = std::fs::read_to_string(path).map_err(|error| Error::io(path, error))?;
    let document = text
        .parse::<toml_edit::DocumentMut>()
        .map_err(|error| Error::Validation(format!("invalid Cargo.toml: {error}")))?;
    Ok(document.get("package").is_some())
}

fn manifest_identity(path: &Path, adapter: Adapter) -> Result<(String, Option<String>)> {
    let text = std::fs::read_to_string(path).map_err(|error| Error::io(path, error))?;
    match adapter {
        Adapter::Npm => {
            let value: JsonValue = serde_json::from_str(&text).map_err(|error| {
                Error::Validation(format!("invalid {}: {error}", path.display()))
            })?;
            Ok((
                required_string(&value["name"], path, "name")?,
                value["version"].as_str().map(str::to_owned),
            ))
        }
        Adapter::Cargo => {
            let document = text.parse::<toml_edit::DocumentMut>().map_err(|error| {
                Error::Validation(format!("invalid {}: {error}", path.display()))
            })?;
            let package = document.get("package").ok_or_else(|| {
                Error::Validation(format!("{} has no package table", path.display()))
            })?;
            let name = package
                .get("name")
                .and_then(toml_edit::Item::as_str)
                .ok_or_else(|| {
                    Error::Validation(format!("{} has no package.name", path.display()))
                })?;
            let version = package
                .get("version")
                .and_then(toml_edit::Item::as_str)
                .map(str::to_owned);
            Ok((name.to_owned(), version))
        }
        Adapter::Pub => {
            let value: serde_yaml::Value = serde_yaml::from_str(&text)?;
            let name = value["name"]
                .as_str()
                .ok_or_else(|| Error::Validation(format!("{} has no name", path.display())))?;
            Ok((
                name.to_owned(),
                value["version"].as_str().map(str::to_owned),
            ))
        }
        Adapter::Python => {
            let document = text.parse::<toml_edit::DocumentMut>().map_err(|error| {
                Error::Validation(format!("invalid {}: {error}", path.display()))
            })?;
            let project = document.get("project").ok_or_else(|| {
                Error::Validation(format!("{} has no project table", path.display()))
            })?;
            let name = project
                .get("name")
                .and_then(toml_edit::Item::as_str)
                .ok_or_else(|| {
                    Error::Validation(format!("{} has no project.name", path.display()))
                })?;
            let version = project
                .get("version")
                .and_then(toml_edit::Item::as_str)
                .map(str::to_owned);
            Ok((name.to_owned(), version))
        }
        Adapter::Go => {
            let name = text
                .lines()
                .find_map(|line| line.trim().strip_prefix("module "))
                .ok_or_else(|| {
                    Error::Validation(format!("{} has no module directive", path.display()))
                })?;
            Ok((name.to_owned(), None))
        }
        Adapter::Msbuild => {
            let name = xml_element(&text, "PackageId")
                .or_else(|| xml_element(&text, "AssemblyName"))
                .or_else(|| {
                    path.file_stem()
                        .and_then(|value| value.to_str())
                        .map(str::to_owned)
                })
                .ok_or_else(|| {
                    Error::Validation(format!("{} has no package identity", path.display()))
                })?;
            Ok((name, xml_element(&text, "Version")))
        }
        Adapter::Json | Adapter::Toml | Adapter::Yaml => {
            unreachable!("generic adapters are not discovered")
        }
    }
}

fn npm_manifest_is_private(path: &Path) -> Result<bool> {
    let text = std::fs::read_to_string(path).map_err(|error| Error::io(path, error))?;
    let value: JsonValue = serde_json::from_str(&text)
        .map_err(|error| Error::Validation(format!("invalid {}: {error}", path.display())))?;
    Ok(value["private"].as_bool() == Some(true))
}

fn required_string(value: &JsonValue, path: &Path, field: &str) -> Result<String> {
    value
        .as_str()
        .map(str::to_owned)
        .ok_or_else(|| Error::Validation(format!("{} has no string {field}", path.display())))
}

fn xml_element(text: &str, name: &str) -> Option<String> {
    let start = format!("<{name}>");
    let end = format!("</{name}>");
    text.split_once(&start)?
        .1
        .split_once(&end)
        .map(|(value, _)| value.trim().to_owned())
}

fn derive_npm_dependencies(root: &Path, config: &mut Config) -> Result<Vec<NpmDependencyEdge>> {
    let ids = config
        .release_units
        .keys()
        .cloned()
        .collect::<BTreeSet<_>>();
    let mut edges = Vec::new();
    for (id, release_unit) in &mut config.release_units {
        let npm_manifests = release_unit
            .projections
            .iter()
            .filter(|projection| projection.adapter == Adapter::Npm)
            .map(|projection| projection_workspace_path(release_unit, projection))
            .collect::<Vec<_>>();
        if npm_manifests.is_empty() {
            continue;
        }
        let mut dependencies = BTreeSet::new();
        for manifest in npm_manifests {
            let path = root.join(&manifest);
            let text = std::fs::read_to_string(&path).map_err(|error| Error::io(&path, error))?;
            let value: JsonValue = serde_json::from_str(&text).map_err(|error| {
                Error::Validation(format!("invalid {}: {error}", path.display()))
            })?;
            for (group, kind) in [
                ("dependencies", NpmDependencyKind::Dependency),
                ("optionalDependencies", NpmDependencyKind::Optional),
                ("peerDependencies", NpmDependencyKind::Peer),
                ("devDependencies", NpmDependencyKind::Dev),
            ] {
                if let Some(entries) = value[group].as_object() {
                    for (dependency, range) in entries {
                        if !ids.contains(dependency) {
                            continue;
                        }
                        if kind != NpmDependencyKind::Dev {
                            dependencies.insert(dependency.clone());
                        }
                        edges.push(NpmDependencyEdge {
                            dependent: id.clone(),
                            dependency: dependency.clone(),
                            kind,
                            range: range.as_str().unwrap_or_default().to_owned(),
                            manifest: manifest.clone(),
                        });
                    }
                }
            }
        }
        release_unit.depends_on = dependencies.into_iter().collect();
    }
    edges.sort_by(|left, right| {
        (
            &left.dependent,
            &left.dependency,
            left.kind as u8,
            &left.range,
            &left.manifest,
        )
            .cmp(&(
                &right.dependent,
                &right.dependency,
                right.kind as u8,
                &right.range,
                &right.manifest,
            ))
    });
    Ok(edges)
}

fn retain_materialized_npm_dependencies(config: &mut Config, edges: &mut Vec<NpmDependencyEdge>) {
    edges.retain(|edge| {
        config
            .release_units
            .get(&edge.dependent)
            .is_some_and(|unit| {
                unit.projections.iter().any(|projection| {
                    projection.adapter == Adapter::Npm
                        && projection_workspace_path(unit, projection) == edge.manifest
                })
            })
            && config.release_units.contains_key(&edge.dependency)
    });
    for (id, unit) in &mut config.release_units {
        unit.depends_on = edges
            .iter()
            .filter(|edge| edge.dependent == *id && edge.kind != NpmDependencyKind::Dev)
            .map(|edge| edge.dependency.clone())
            .collect::<BTreeSet<_>>()
            .into_iter()
            .collect();
    }
}

fn load_changesets_intents(root: &Path) -> Result<Vec<ConvertedIntent>> {
    let directory = root.join(".changeset");
    let mut paths = std::fs::read_dir(&directory)
        .map_err(|error| Error::io(&directory, error))?
        .filter_map(std::result::Result::ok)
        .map(|entry| entry.path())
        .filter(|path| path.extension().is_some_and(|extension| extension == "md"))
        .filter(|path| path.file_name().is_none_or(|name| name != "README.md"))
        .collect::<Vec<_>>();
    paths.sort();
    paths
        .into_iter()
        .map(|path| {
            let text = std::fs::read_to_string(&path).map_err(|error| Error::io(&path, error))?;
            let rest = text.strip_prefix("---\n").ok_or_else(|| {
                Error::Validation(format!("{} has no Changesets frontmatter", path.display()))
            })?;
            let (frontmatter, message) = rest.split_once("\n---\n").ok_or_else(|| {
                Error::Validation(format!(
                    "{} has unterminated Changesets frontmatter",
                    path.display()
                ))
            })?;
            let packages = serde_yaml::from_str(frontmatter)?;
            let id = path
                .file_stem()
                .and_then(|value| value.to_str())
                .ok_or_else(|| {
                    Error::Validation(format!("invalid Changesets filename {}", path.display()))
                })?
                .to_owned();
            Ok(ConvertedIntent {
                target: PathBuf::from(crate::intent::INTENTS_PATH).join(format!("{id}.md")),
                source: path.strip_prefix(root).unwrap_or(&path).to_owned(),
                id,
                release_units: packages,
                message: message.trim().to_owned(),
            })
        })
        .collect()
}

fn parse_groups(value: &JsonValue) -> Result<Vec<Vec<String>>> {
    value
        .as_array()
        .into_iter()
        .flatten()
        .map(|group| {
            group
                .as_array()
                .ok_or_else(|| {
                    Error::Validation("Changesets release group must be an array".to_owned())
                })?
                .iter()
                .map(|member| {
                    member.as_str().map(str::to_owned).ok_or_else(|| {
                        Error::Validation("Changesets group member must be a string".to_owned())
                    })
                })
                .collect()
        })
        .collect()
}

fn collect_json_strings(value: &JsonValue, output: &mut BTreeSet<String>) {
    match value {
        JsonValue::String(value) => {
            output.insert(value.clone());
        }
        JsonValue::Array(values) => {
            for value in values {
                collect_json_strings(value, output);
            }
        }
        _ => {}
    }
}

fn changesets_private_package_settings(value: &JsonValue) -> Option<(bool, bool)> {
    match value {
        JsonValue::Bool(enabled) => Some((*enabled, *enabled)),
        JsonValue::Object(settings) => Some((
            settings
                .get("version")
                .and_then(JsonValue::as_bool)
                .unwrap_or(true),
            settings
                .get("tag")
                .and_then(JsonValue::as_bool)
                .unwrap_or(true),
        )),
        _ => None,
    }
}

fn remap_groups(groups: &mut Vec<Vec<String>>, identity_map: &BTreeMap<String, String>) {
    for group in groups.iter_mut() {
        for release_unit in group.iter_mut() {
            if let Some(target) = identity_map.get(release_unit) {
                *release_unit = target.clone();
            }
        }
        group.sort();
        group.dedup();
    }
    groups.retain(|group| group.len() > 1);
}

fn remap_converted_intents(
    intents: &mut [ConvertedIntent],
    identity_map: &BTreeMap<String, String>,
    config: &Config,
) -> Result<()> {
    for intent in intents {
        let mut release_units = BTreeMap::<String, Bump>::new();
        for (id, bump) in std::mem::take(&mut intent.release_units) {
            let logical_id = identity_map.get(&id).cloned().unwrap_or(id);
            if !config.release_units.contains_key(&logical_id) {
                return Err(Error::Validation(format!(
                    "Changesets intent {} references release unit {logical_id}, which has no Intentional release-unit identity",
                    intent.id
                )));
            }
            release_units
                .entry(logical_id)
                .and_modify(|existing| *existing = (*existing).max(bump))
                .or_insert(bump);
        }
        intent.release_units = release_units;
    }
    Ok(())
}

fn scan_changesets_integrations(root: &Path) -> Result<Vec<SourceEvidence>> {
    let mut findings = Vec::new();
    for entry in WalkDir::new(root)
        .into_iter()
        .filter_entry(|entry| !hard_excluded(root, entry.path()))
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
    {
        let path = entry.path();
        let relative = path.strip_prefix(root).unwrap_or(path);
        if relative.starts_with(".changeset") || relative.starts_with(".intentional") {
            continue;
        }
        let relevant = relative == Path::new("package.json")
            || relative == Path::new("pnpm-lock.yaml")
            || relative.starts_with(".github")
            || relative.starts_with("scripts")
            || relative
                .components()
                .any(|component| component.as_os_str().to_string_lossy().contains("test"));
        if !relevant {
            continue;
        }
        let Ok(text) = std::fs::read_to_string(path) else {
            continue;
        };
        let lines = text
            .lines()
            .enumerate()
            .filter(|(_, line)| line.to_ascii_lowercase().contains("changeset"))
            .map(|(index, _)| index + 1)
            .collect::<Vec<_>>();
        if !lines.is_empty() {
            findings.push(evidence(root, relative, lines)?);
        }
    }
    findings.sort();
    Ok(findings)
}

fn scan_external_release_evidence(root: &Path) -> Result<Vec<SourceEvidence>> {
    let mut findings = Vec::new();
    for entry in WalkDir::new(root)
        .into_iter()
        .filter_entry(|entry| !hard_excluded(root, entry.path()))
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
    {
        let path = entry.path();
        let relative = path.strip_prefix(root).unwrap_or(path);
        let is_release_file = relative.file_name().is_some_and(|name| {
            name.to_string_lossy()
                .to_ascii_lowercase()
                .contains("release")
        });
        if (relative.starts_with("scripts") || relative.starts_with(".github")) && is_release_file {
            findings.push(evidence(root, relative, Vec::new())?);
        }
    }
    findings.sort();
    Ok(findings)
}

fn release_tool_proxy_diagnostics(
    root: &Path,
    candidates: &[DiscoveryCandidate],
    referenced_names: &BTreeSet<String>,
) -> Result<Vec<InitDiagnostic>> {
    let workspace_paths = workspace_manifest_paths(root)?;
    let mut diagnostics = Vec::new();
    for candidate in candidates {
        let Some(native_identity) = candidate.native_identity.as_deref() else {
            continue;
        };
        let Some(projection) = candidate.projection.as_ref() else {
            continue;
        };
        if projection.adapter != Adapter::Npm {
            continue;
        }
        let workspace_member = workspace_paths.contains(&root.join(&candidate.path));
        if !referenced_names.contains(native_identity) && !workspace_member {
            continue;
        }
        let Some(CandidateResolution::Projection { release_unit, .. }) =
            candidate.resolution.as_ref()
        else {
            continue;
        };
        if release_unit == native_identity {
            continue;
        }
        let target_candidates = candidates
            .iter()
            .filter(|target| target.id != candidate.id)
            .filter(|target| {
                target.projection.as_ref().is_some_and(|projection| {
                    projection.adapter != Adapter::Npm
                        && matches!(
                            target.resolution.as_ref(),
                            Some(CandidateResolution::Projection {
                                release_unit: target_release_unit,
                                ..
                            }) if target_release_unit == release_unit
                        )
                })
            })
            .collect::<Vec<_>>();
        if target_candidates.is_empty() {
            continue;
        }

        let mut source_references = changesets_identity_evidence(root, native_identity)?;
        if source_references.is_empty() && workspace_member {
            source_references.push(evidence(root, Path::new(CHANGESETS_CONFIG), Vec::new())?);
            source_references.extend(workspace_declaration_evidence(root)?);
            source_references.sort();
            source_references.dedup();
        }
        if source_references.is_empty() {
            continue;
        }
        let (private, responsibilities) = npm_manifest_responsibilities(root, &candidate.path)?;
        let mut supporting_evidence = candidate.evidence.clone();
        supporting_evidence.extend(source_references);
        for target in &target_candidates {
            supporting_evidence.extend(target.evidence.clone());
        }
        supporting_evidence.sort();
        supporting_evidence.dedup();

        let mut contradictory_evidence = Vec::new();
        if !private || !responsibilities.is_empty() {
            contradictory_evidence.extend(candidate.evidence.clone());
        }
        contradictory_evidence.extend(non_displaced_manifest_references(
            root,
            &candidate.path,
            native_identity,
        )?);
        contradictory_evidence.sort();
        contradictory_evidence.dedup();

        let recommended =
            (private && responsibilities.is_empty() && contradictory_evidence.is_empty())
                .then(|| "remove".to_owned());
        let mut evidence = supporting_evidence.clone();
        evidence.extend(contradictory_evidence.clone());
        evidence.sort();
        evidence.dedup();
        let responsibility_message = if responsibilities.is_empty() {
            "no independent npm responsibility keys were observed".to_owned()
        } else {
            format!(
                "npm responsibility keys were observed: {}",
                responsibilities.join(", ")
            )
        };
        diagnostics.push(InitDiagnostic {
            id: format!("release-tool-proxy-disposition:{}", candidate.id),
            code: "release-tool-proxy-disposition".to_owned(),
            message: format!(
                "Choose whether {} remains an npm projection of {release_unit} or is removed during takeover. Its exact source-tool identity maps to a non-npm projection, and {responsibility_message}.",
                candidate.path.display()
            ),
            evidence,
            choices: vec!["retain".to_owned(), "remove".to_owned()],
            recommended,
            resolution: None,
            verified: false,
            invalidated_resolution: false,
            supporting_evidence,
            contradictory_evidence,
            uncertainty: Some(
                "This is a best-effort structural assessment, not proof that the manifest is disposable. Descriptions, comments, prose, and semantic keyword matches are not evidence."
                    .to_owned(),
            ),
        });
    }
    diagnostics.sort_by(|left, right| left.id.cmp(&right.id));
    Ok(diagnostics)
}

fn npm_manifest_responsibilities(root: &Path, relative: &Path) -> Result<(bool, Vec<String>)> {
    let path = root.join(relative);
    let text = std::fs::read_to_string(&path).map_err(|error| Error::io(&path, error))?;
    let value: JsonValue = serde_json::from_str(&text)
        .map_err(|error| Error::Validation(format!("invalid package.json: {error}")))?;
    let object = value.as_object().ok_or_else(|| {
        Error::Validation(format!("{} must contain a JSON object", relative.display()))
    })?;
    let private = object
        .get("private")
        .and_then(JsonValue::as_bool)
        .unwrap_or(false);
    let responsibility_keys = [
        "bin",
        "browser",
        "bundledDependencies",
        "cpu",
        "dependencies",
        "devDependencies",
        "engines",
        "exports",
        "files",
        "main",
        "module",
        "optionalDependencies",
        "os",
        "peerDependencies",
        "publishConfig",
        "repository",
        "scripts",
        "types",
        "typings",
        "workspaces",
    ];
    let responsibilities = responsibility_keys
        .into_iter()
        .filter(|key| object.get(*key).is_some_and(json_value_has_content))
        .map(str::to_owned)
        .collect();
    Ok((private, responsibilities))
}

fn json_value_has_content(value: &JsonValue) -> bool {
    match value {
        JsonValue::Null => false,
        JsonValue::Bool(value) => *value,
        JsonValue::Number(_) => true,
        JsonValue::String(value) => !value.is_empty(),
        JsonValue::Array(values) => !values.is_empty(),
        JsonValue::Object(values) => !values.is_empty(),
    }
}

fn changesets_identity_evidence(root: &Path, identity: &str) -> Result<Vec<SourceEvidence>> {
    let mut findings = Vec::new();
    let config_path = PathBuf::from(CHANGESETS_CONFIG);
    let config_text = std::fs::read_to_string(root.join(&config_path))
        .map_err(|error| Error::io(root.join(&config_path), error))?;
    let config: JsonValue = serde_json::from_str(&config_text)
        .map_err(|error| Error::Validation(format!("invalid Changesets config: {error}")))?;
    if json_contains_exact_string(&config, identity) {
        findings.push(evidence(root, &config_path, Vec::new())?);
    }
    for entry in WalkDir::new(root.join(".changeset"))
        .min_depth(1)
        .max_depth(1)
        .into_iter()
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
        .filter(|entry| entry.path().extension().and_then(|value| value.to_str()) == Some("md"))
        .filter(|entry| entry.file_name() != "README.md")
    {
        let text = std::fs::read_to_string(entry.path())
            .map_err(|error| Error::io(entry.path(), error))?;
        let Some(frontmatter) = text
            .strip_prefix("---\n")
            .and_then(|text| text.split_once("\n---"))
            .map(|(frontmatter, _)| frontmatter)
        else {
            continue;
        };
        let values: BTreeMap<String, Bump> = serde_yaml::from_str(frontmatter)?;
        if values.contains_key(identity) {
            let relative = entry
                .path()
                .strip_prefix(root)
                .unwrap_or(entry.path())
                .to_owned();
            findings.push(evidence(root, &relative, Vec::new())?);
        }
    }
    findings.sort();
    findings.dedup();
    Ok(findings)
}

fn json_contains_exact_string(value: &JsonValue, expected: &str) -> bool {
    match value {
        JsonValue::String(value) => value == expected,
        JsonValue::Array(values) => values
            .iter()
            .any(|value| json_contains_exact_string(value, expected)),
        JsonValue::Object(values) => values
            .iter()
            .any(|(key, value)| key == expected || json_contains_exact_string(value, expected)),
        JsonValue::Null | JsonValue::Bool(_) | JsonValue::Number(_) => false,
    }
}

fn workspace_declaration_evidence(root: &Path) -> Result<Vec<SourceEvidence>> {
    ["pnpm-workspace.yaml", "package.json", "Cargo.toml"]
        .into_iter()
        .map(PathBuf::from)
        .filter(|path| root.join(path).is_file())
        .map(|path| evidence(root, &path, Vec::new()))
        .collect()
}

fn non_displaced_manifest_references(
    root: &Path,
    candidate_path: &Path,
    native_identity: &str,
) -> Result<Vec<SourceEvidence>> {
    let path_text = candidate_path.to_string_lossy().replace('\\', "/");
    let mut findings = Vec::new();
    let mut paths = WalkDir::new(root)
        .into_iter()
        .filter_entry(|entry| !hard_excluded(root, entry.path()))
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
        .map(|entry| entry.into_path())
        .collect::<BTreeSet<_>>();
    remove_git_ignored(root, &mut paths)?;
    for path in paths {
        let relative = path.strip_prefix(root).unwrap_or(&path);
        if relative == candidate_path
            || relative.starts_with(".changeset")
            || relative.starts_with(".intentional")
            || is_prose_path(relative)
        {
            continue;
        }
        let Ok(text) = std::fs::read_to_string(&path) else {
            continue;
        };
        let lines = text
            .lines()
            .enumerate()
            .filter(|(_, line)| structural_line_references_path(line, &path_text))
            .map(|(index, _)| index + 1)
            .collect::<Vec<_>>();
        let has_dependency_reference = relative.file_name().and_then(|name| name.to_str())
            == Some("package.json")
            && serde_json::from_str::<JsonValue>(&text).is_ok_and(|value| {
                [
                    "dependencies",
                    "devDependencies",
                    "optionalDependencies",
                    "peerDependencies",
                ]
                .iter()
                .any(|key| {
                    value[*key]
                        .as_object()
                        .is_some_and(|dependencies| dependencies.contains_key(native_identity))
                })
            });
        if !lines.is_empty() || has_dependency_reference {
            findings.push(evidence(root, relative, lines)?);
        }
    }
    findings.sort();
    findings.dedup();
    Ok(findings)
}

fn structural_line_references_path(line: &str, path: &str) -> bool {
    let normalized = line.replace('\\', "/");
    let Some(reference_offset) = normalized.find(path) else {
        return false;
    };
    let trimmed = normalized.trim_start();
    if trimmed.starts_with("//")
        || trimmed.starts_with('#')
        || trimmed.starts_with("/*")
        || trimmed.starts_with("<!--")
        || trimmed == "*"
        || trimmed.starts_with("* ")
    {
        return false;
    }
    let before_reference = &normalized[..reference_offset];
    if comment_starts_before_reference(before_reference) {
        return false;
    }
    let Some((field, _)) = trimmed.split_once(':') else {
        return true;
    };
    let field = field
        .trim()
        .trim_matches(|character| matches!(character, '"' | '\''))
        .to_ascii_lowercase();
    !matches!(
        field.as_str(),
        "$comment"
            | "comment"
            | "comments"
            | "description"
            | "message"
            | "note"
            | "notes"
            | "summary"
            | "title"
    )
}

fn comment_starts_before_reference(line: &str) -> bool {
    let bytes = line.as_bytes();
    let mut quote = None;
    let mut escaped = false;
    let mut index = 0;
    while index < bytes.len() {
        let byte = bytes[index];
        if let Some(expected) = quote {
            if escaped {
                escaped = false;
            } else if byte == b'\\' {
                escaped = true;
            } else if byte == expected {
                quote = None;
            }
            index += 1;
            continue;
        }
        if matches!(byte, b'\'' | b'"') {
            quote = Some(byte);
            index += 1;
            continue;
        }
        let previous_is_boundary =
            index == 0 || bytes[index.saturating_sub(1)].is_ascii_whitespace();
        if byte == b'#' && previous_is_boundary {
            return true;
        }
        if bytes[index..].starts_with(b"<!--") {
            return true;
        }
        if bytes[index..].starts_with(b"/*")
            && bytes
                .get(index + 2)
                .is_none_or(|next| next.is_ascii_whitespace())
        {
            return true;
        }
        if bytes[index..].starts_with(b"//")
            && bytes
                .get(index + 2)
                .is_none_or(|next| next.is_ascii_whitespace())
        {
            return true;
        }
        index += 1;
    }
    false
}

fn is_prose_path(path: &Path) -> bool {
    matches!(
        path.extension().and_then(|extension| extension.to_str()),
        Some("md" | "mdx" | "rst" | "txt")
    )
}

fn reconcile_diagnostics(
    root: &Path,
    current: &mut Vec<InitDiagnostic>,
    previous: Option<&InitPlan>,
    candidates: &[DiscoveryCandidate],
) -> Result<()> {
    let Some(previous) = previous else {
        return Ok(());
    };
    let previous_by_id = previous
        .diagnostics
        .iter()
        .map(|diagnostic| (diagnostic.id.as_str(), diagnostic))
        .collect::<BTreeMap<_, _>>();
    for diagnostic in current.iter_mut() {
        let Some(old) = previous_by_id.get(diagnostic.id.as_str()) else {
            continue;
        };
        if old.evidence == diagnostic.evidence {
            diagnostic.resolution = old.resolution.clone();
            if !diagnostic.choices.is_empty() {
                diagnostic.verified = match diagnostic.code.as_str() {
                    "repository-integration" => false,
                    "release-tool-proxy-disposition" => {
                        let candidate = candidates.iter().find(|candidate| {
                            diagnostic.id
                                == format!("release-tool-proxy-disposition:{}", candidate.id)
                        });
                        match (diagnostic.resolution.as_deref(), candidate) {
                            (Some("retain"), Some(_)) => true,
                            (Some("remove"), Some(candidate)) => non_displaced_manifest_references(
                                root,
                                &candidate.path,
                                candidate.native_identity.as_deref().unwrap_or_default(),
                            )?
                            .is_empty(),
                            _ => false,
                        }
                    }
                    _ => diagnostic.resolution.is_some(),
                };
            }
        } else if old.resolution.is_some() {
            diagnostic.invalidated_resolution = true;
        }
    }
    let current_ids = current
        .iter()
        .map(|diagnostic| diagnostic.id.clone())
        .collect::<BTreeSet<_>>();
    for old in &previous.diagnostics {
        if old.code != "repository-integration"
            || current_ids.contains(&old.id)
            || old.resolution.as_deref() != Some("removed")
        {
            continue;
        }
        let Some(path) = old.evidence.first().map(|evidence| evidence.path.clone()) else {
            continue;
        };
        let full = root.join(&path);
        if !full.is_file() {
            continue;
        }
        let text = std::fs::read_to_string(&full).map_err(|error| Error::io(&full, error))?;
        if text.to_ascii_lowercase().contains("changeset") {
            continue;
        }
        current.push(InitDiagnostic {
            id: old.id.clone(),
            code: old.code.clone(),
            message: old.message.clone(),
            evidence: vec![evidence(root, &path, Vec::new())?],
            choices: old.choices.clone(),
            recommended: old.recommended.clone(),
            resolution: old.resolution.clone(),
            verified: true,
            invalidated_resolution: false,
            supporting_evidence: old.supporting_evidence.clone(),
            contradictory_evidence: old.contradictory_evidence.clone(),
            uncertainty: old.uncertainty.clone(),
        });
    }
    current.sort_by(|left, right| left.id.cmp(&right.id));
    Ok(())
}

fn apply_disposition_resolutions(
    config: &mut Config,
    diagnostics: &[InitDiagnostic],
) -> Result<()> {
    let mut excluded = BTreeSet::new();
    for diagnostic in diagnostics.iter().filter(|diagnostic| {
        diagnostic.code == "ignored-release-unit-disposition"
            || diagnostic.code == "unmapped-release-unit-disposition"
    }) {
        let release_unit = diagnostic
            .id
            .split_once(':')
            .map(|(_, release_unit)| release_unit)
            .expect("diagnostic id prefix");
        match diagnostic.resolution.as_deref() {
            Some("suspended") => {
                if let Some(config) = config.release_units.get_mut(release_unit) {
                    config.disposition = ReleaseUnitDisposition::Suspended;
                }
            }
            Some("excluded") => {
                config.release_units.remove(release_unit);
                excluded.insert(release_unit.to_owned());
            }
            Some("managed") | None => {}
            Some(value) => {
                return Err(Error::Validation(format!(
                    "invalid resolution {value} for {}",
                    diagnostic.id
                )))
            }
        }
    }
    exclude_release_units(config, &excluded);
    Ok(())
}

fn apply_proxy_manifest_resolutions(
    config: &mut Config,
    diagnostics: &[InitDiagnostic],
    candidates: &[DiscoveryCandidate],
) -> Result<Vec<ProxyRemoval>> {
    let mut removals = Vec::new();
    for diagnostic in diagnostics
        .iter()
        .filter(|diagnostic| diagnostic.code == "release-tool-proxy-disposition")
    {
        let candidate = candidates
            .iter()
            .find(|candidate| {
                diagnostic.id == format!("release-tool-proxy-disposition:{}", candidate.id)
            })
            .ok_or_else(|| {
                Error::Validation(format!(
                    "{} does not identify a current discovery candidate",
                    diagnostic.id
                ))
            })?;
        match diagnostic.resolution.as_deref() {
            None | Some("retain") => {}
            Some("remove") => {
                let Some(CandidateResolution::Projection { release_unit, .. }) =
                    candidate.resolution.as_ref()
                else {
                    return Err(Error::Validation(format!(
                        "{} can remove only a candidate resolved as a projection",
                        diagnostic.id
                    )));
                };
                let unit = config.release_units.get_mut(release_unit).ok_or_else(|| {
                    Error::Validation(format!(
                        "{} targets absent release unit {release_unit}",
                        diagnostic.id
                    ))
                })?;
                let unit_path = unit.path.clone();
                unit.projections.retain(|projection| {
                    let path = if unit_path == Path::new(".") {
                        projection.file.clone()
                    } else {
                        unit_path.join(&projection.file)
                    };
                    path != candidate.path
                });
                config.discovery.managed_paths.retain(|receipt| {
                    receipt.detector != candidate.detector || receipt.path != candidate.path
                });
                removals.push(ProxyRemoval {
                    path: candidate.path.clone(),
                    native_identity: candidate
                        .native_identity
                        .clone()
                        .expect("proxy diagnostic requires native identity"),
                });
            }
            Some(value) => {
                return Err(Error::Validation(format!(
                    "invalid resolution {value} for {}",
                    diagnostic.id
                )));
            }
        }
    }
    removals.sort_by(|left, right| left.path.cmp(&right.path));
    Ok(removals)
}

fn exclude_release_units(config: &mut Config, excluded: &BTreeSet<String>) {
    for id in excluded {
        config.release_units.remove(id);
    }
    if excluded.is_empty() {
        return;
    }
    for release_unit in config.release_units.values_mut() {
        release_unit.depends_on.retain(|id| !excluded.contains(id));
    }
    for groups in [&mut config.fixed, &mut config.linked] {
        for group in groups.iter_mut() {
            group.retain(|id| !excluded.contains(id));
        }
        groups.retain(|group| group.len() >= 2);
    }
}

fn parity_result(
    source_config: &Config,
    proposed_config: &Config,
    current: &BTreeMap<String, Version>,
    declared: &BTreeMap<String, Bump>,
    source_semantics: &ChangesetsSourceSemantics<'_>,
) -> Result<ParityComputation> {
    let mut source_config = source_config.clone();
    let mut proposed_config = proposed_config.clone();
    let effective = effective_bumps(&proposed_config, declared);
    let non_releasing_without_versions = proposed_config
        .release_units
        .keys()
        .filter(|id| !current.contains_key(*id) && effective[*id] == Bump::None)
        .cloned()
        .collect::<BTreeSet<_>>();
    exclude_release_units(&mut source_config, &non_releasing_without_versions);
    exclude_release_units(&mut proposed_config, &non_releasing_without_versions);
    let excluded_pending = declared
        .keys()
        .filter(|id| !proposed_config.release_units.contains_key(*id))
        .cloned()
        .collect::<Vec<_>>();
    let proposed_preflight_error = (!excluded_pending.is_empty()).then(|| {
        format!(
            "converted intents reference release units excluded from the proposed inventory: {}",
            excluded_pending.join(", ")
        )
    });
    if source_semantics.preflight_error.is_some() || proposed_preflight_error.is_some() {
        return Ok(ParityComputation {
            result: ParityResult {
                status: "blocked".to_owned(),
                release_units: Vec::new(),
            },
            source_error: source_semantics.preflight_error.clone(),
            proposed_error: proposed_preflight_error,
        });
    }
    let missing = source_config
        .release_units
        .keys()
        .chain(proposed_config.release_units.keys())
        .filter(|id| !current.contains_key(*id))
        .cloned()
        .collect::<BTreeSet<_>>();
    if !missing.is_empty() {
        return Ok(ParityComputation {
            result: ParityResult {
                status: "blocked".to_owned(),
                release_units: Vec::new(),
            },
            source_error: None,
            proposed_error: Some(format!(
                "missing current versions for release units: {}",
                missing.into_iter().collect::<Vec<_>>().join(", ")
            )),
        });
    }
    let (source, source_error) =
        match resolve_changesets_source(&source_config, declared, current, source_semantics) {
            Ok(resolved) => (resolved, None),
            Err(Error::Validation(message)) => (BTreeMap::new(), Some(message)),
            Err(error) => return Err(error),
        };
    let (proposed, proposed_error) = match resolve_versions(&proposed_config, declared, current) {
        Ok(resolved) => (resolved, None),
        Err(Error::Validation(message)) => (BTreeMap::new(), Some(message)),
        Err(error) => return Err(error),
    };
    let release_ids = source
        .iter()
        .chain(&proposed)
        .filter(|(_, versions)| versions.bump != Bump::None)
        .map(|(id, _)| id.clone())
        .collect::<BTreeSet<_>>();
    let release_units = release_ids
        .into_iter()
        .map(|release_unit| ParityReleaseUnit {
            current_version: current[&release_unit].to_string(),
            source: parity_release(source.get(&release_unit)),
            proposed: parity_release(proposed.get(&release_unit)),
            release_unit,
        })
        .collect::<Vec<_>>();
    let equivalent = source_error.is_none()
        && proposed_error.is_none()
        && release_units
            .iter()
            .all(|release_unit| release_unit.source == release_unit.proposed);
    Ok(ParityComputation {
        result: ParityResult {
            status: if equivalent { "equivalent" } else { "blocked" }.to_owned(),
            release_units,
        },
        source_error,
        proposed_error,
    })
}

fn mixed_skipped_changeset(
    intents: &[ConvertedIntent],
    skipped_release_units: &BTreeSet<String>,
) -> Option<String> {
    intents.iter().find_map(|intent| {
        let has_skipped = intent
            .release_units
            .keys()
            .any(|id| skipped_release_units.contains(id));
        let has_managed = intent
            .release_units
            .keys()
            .any(|id| !skipped_release_units.contains(id));
        (has_skipped && has_managed).then(|| {
            format!(
                "Changesets intent {} mixes skipped and managed release units; split or revise the source changeset before takeover",
                intent.id
            )
        })
    })
}

struct ParityComputation {
    result: ParityResult,
    source_error: Option<String>,
    proposed_error: Option<String>,
}

fn parity_release(version: Option<&ReleaseUnitVersion>) -> Option<ParityRelease> {
    version
        .filter(|version| version.bump != Bump::None)
        .map(|version| ParityRelease {
            requested_bump: version.bump,
            next_version: version.next.to_string(),
        })
}

/// Compute the source Changesets result without invoking Intentional's resolver.
///
/// This deliberately duplicates the small release-propagation algorithm so the
/// takeover gate compares two computations rather than comparing a result with
/// itself.
fn resolve_changesets_source(
    config: &Config,
    declared: &BTreeMap<String, Bump>,
    current: &BTreeMap<String, Version>,
    semantics: &ChangesetsSourceSemantics<'_>,
) -> Result<BTreeMap<String, ReleaseUnitVersion>> {
    let mut effective = config
        .release_units
        .keys()
        .map(|id| {
            let suppressed =
                semantics.suppress_private_versions && semantics.private_packages.contains(id);
            (
                id.clone(),
                if suppressed {
                    Bump::None
                } else {
                    declared.get(id).copied().unwrap_or(Bump::None)
                },
            )
        })
        .collect::<BTreeMap<_, _>>();
    loop {
        let before = effective.clone();
        for edge in semantics.npm_dependencies {
            if !config.release_units.contains_key(&edge.dependent)
                || !config.release_units.contains_key(&edge.dependency)
                || (semantics.suppress_private_versions
                    && semantics.private_packages.contains(&edge.dependent))
            {
                continue;
            }
            let dependency_bump = effective[&edge.dependency];
            if dependency_bump == Bump::None {
                continue;
            }
            let next = changesets_dependency_next(config, &edge.dependency, &effective, current);
            let in_range = npm_range_satisfies(&edge.range, &current[&edge.dependency], &next)?;
            let required = if edge.kind == NpmDependencyKind::Peer
                && dependency_bump >= Bump::Minor
                && (!semantics.only_update_peer_dependents_when_out_of_range || !in_range)
            {
                Bump::Major
            } else if semantics.update_internal_dependents_always || !in_range {
                semantics.internal_dependency_bump
            } else {
                Bump::None
            };
            if required != Bump::None {
                effective
                    .entry(edge.dependent.clone())
                    .and_modify(|bump| *bump = (*bump).max(required));
            }
        }
        for group in &config.fixed {
            let bump = group
                .iter()
                .map(|id| effective[id])
                .max()
                .unwrap_or_default();
            if bump != Bump::None {
                for id in group {
                    if !semantics.suppress_private_versions
                        || !semantics.private_packages.contains(id)
                    {
                        effective.insert(id.clone(), bump);
                    }
                }
            }
        }
        for group in &config.linked {
            let bump = group
                .iter()
                .map(|id| effective[id])
                .max()
                .unwrap_or_default();
            if bump != Bump::None {
                for id in group {
                    if effective[id] != Bump::None {
                        effective.insert(id.clone(), bump);
                    }
                }
            }
        }
        if effective == before {
            break;
        }
    }

    let mut resolved = config
        .release_units
        .keys()
        .map(|id| {
            let current_version = current.get(id).ok_or_else(|| {
                Error::Validation(format!("missing current version for release unit {id}"))
            })?;
            Ok((
                id.clone(),
                ReleaseUnitVersion::new_with_mapping(
                    current_version.clone(),
                    effective[id],
                    Pre1BumpMapping::Component,
                ),
            ))
        })
        .collect::<Result<BTreeMap<_, _>>>()?;
    for (fixed, groups) in [(true, &config.fixed), (false, &config.linked)] {
        for group in groups {
            let highest_current = group
                .iter()
                .map(|id| &current[id])
                .max()
                .expect("validated release group")
                .clone();
            let highest_bump = group
                .iter()
                .map(|id| effective[id])
                .max()
                .unwrap_or_default();
            let next = bump_version_with_mapping(
                &highest_current,
                highest_bump,
                Pre1BumpMapping::Component,
            );
            for id in group {
                let suppressed =
                    semantics.suppress_private_versions && semantics.private_packages.contains(id);
                let releases = !suppressed
                    && highest_bump != Bump::None
                    && (fixed || effective[id] != Bump::None);
                resolved.insert(
                    id.clone(),
                    ReleaseUnitVersion {
                        current: current[id].clone(),
                        next: if releases {
                            next.clone()
                        } else {
                            current[id].clone()
                        },
                        bump: if releases { highest_bump } else { Bump::None },
                    },
                );
            }
        }
    }
    Ok(resolved)
}

fn changesets_dependency_next(
    config: &Config,
    id: &str,
    effective: &BTreeMap<String, Bump>,
    current: &BTreeMap<String, Version>,
) -> Version {
    for group in config.fixed.iter().chain(&config.linked) {
        if group.iter().any(|member| member == id) && effective[id] != Bump::None {
            let highest_current = group
                .iter()
                .map(|member| &current[member])
                .max()
                .expect("validated group");
            let highest_bump = group
                .iter()
                .map(|member| effective[member])
                .max()
                .unwrap_or_default();
            return bump_version_with_mapping(
                highest_current,
                highest_bump,
                Pre1BumpMapping::Component,
            );
        }
    }
    bump_version_with_mapping(&current[id], effective[id], Pre1BumpMapping::Component)
}

fn npm_range_satisfies(range: &str, current: &Version, next: &Version) -> Result<bool> {
    let normalized = match range.strip_prefix("workspace:") {
        Some("*") => current.to_string(),
        Some("^") => format!("^{current}"),
        Some("~") => format!("~{current}"),
        Some(range) => range.to_owned(),
        None => range.to_owned(),
    };
    let Ok(range) = NodeRange::parse(&normalized) else {
        return Ok(false);
    };
    let next = NodeVersion::parse(next.to_string())
        .map_err(|error| Error::Validation(format!("invalid next npm version: {error}")))?;
    Ok(range.satisfies(&next))
}

fn load_previous_plan(root: &Path) -> Result<Option<InitPlan>> {
    let path = root.join(INIT_PLAN_PATH);
    match std::fs::read_to_string(&path) {
        Ok(text) => {
            let plan: InitPlan = serde_yaml::from_str(&text)?;
            plan.validate()?;
            Ok(Some(plan))
        }
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => Ok(None),
        Err(error) => Err(Error::io(path, error)),
    }
}

fn evidence(root: &Path, relative: &Path, lines: Vec<usize>) -> Result<SourceEvidence> {
    let path = root.join(relative);
    let bytes = std::fs::read(&path).map_err(|error| Error::io(&path, error))?;
    Ok(SourceEvidence {
        path: relative.to_owned(),
        digest: sha256_digest(&bytes),
        lines,
    })
}

fn fingerprint(root: &Path, paths: &BTreeSet<PathBuf>) -> Result<String> {
    let mut source = BTreeMap::new();
    for path in paths {
        if root.join(path).is_file() {
            source.insert(
                path.to_string_lossy().to_string(),
                evidence(root, path, Vec::new())?.digest,
            );
        }
    }
    for path in ["package.json", "pnpm-workspace.yaml", "Cargo.toml"] {
        let path = PathBuf::from(path);
        if root.join(&path).is_file() {
            source.insert(
                path.to_string_lossy().to_string(),
                evidence(root, &path, Vec::new())?.digest,
            );
        }
    }
    for entry in WalkDir::new(root.join(".changeset"))
        .into_iter()
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
    {
        let path = entry
            .path()
            .strip_prefix(root)
            .unwrap_or(entry.path())
            .to_owned();
        source.insert(
            path.to_string_lossy().to_string(),
            evidence(root, &path, Vec::new())?.digest,
        );
    }
    Ok(sha256_digest(canonical_json(&source)?.as_bytes()))
}

fn verify_takeover_preconditions(
    root: &Path,
    writes: &[(PathBuf, String)],
    expected_fingerprint: &str,
    evidence_paths: &BTreeSet<PathBuf>,
) -> Result<()> {
    let actual_fingerprint = fingerprint(root, evidence_paths)?;
    if actual_fingerprint != expected_fingerprint {
        return Err(Error::Validation(
            "initialization plan source evidence became stale; rerun intentional init".to_owned(),
        ));
    }
    for (relative, _) in writes {
        if root.join(relative).exists() {
            return Err(Error::Validation(format!(
                "takeover target {} already exists; resolve the competing Intentional state first",
                relative.display()
            )));
        }
    }
    Ok(())
}

fn takeover_operations(
    root: &Path,
    intents: &[ConvertedIntent],
    proxy_removals: &[ProxyRemoval],
) -> Vec<String> {
    let mut operations = vec![format!("write {CONFIG_PATH}")];
    operations.extend(intents.iter().map(|intent| {
        format!(
            "write {} from {}",
            intent.target.display(),
            intent.source.display()
        )
    }));
    operations.extend(
        takeover_deletes(root, proxy_removals)
            .iter()
            .map(|path| format!("delete {}", path.display())),
    );
    operations.push("after commit: intentional tag --baseline".to_owned());
    operations
}

fn takeover_deletes(root: &Path, proxy_removals: &[ProxyRemoval]) -> Vec<PathBuf> {
    let mut paths = WalkDir::new(root.join(".changeset"))
        .into_iter()
        .filter_map(std::result::Result::ok)
        .filter(|entry| entry.file_type().is_file())
        .map(|entry| {
            entry
                .path()
                .strip_prefix(root)
                .unwrap_or(entry.path())
                .to_owned()
        })
        .collect::<Vec<_>>();
    paths.push(PathBuf::from(INIT_PLAN_PATH));
    paths.extend(proxy_removals.iter().map(|removal| removal.path.clone()));
    paths.sort();
    paths.dedup();
    paths
}

fn verify_proxy_removal_preconditions(root: &Path, removals: &[ProxyRemoval]) -> Result<()> {
    for removal in removals {
        let references =
            non_displaced_manifest_references(root, &removal.path, &removal.native_identity)?;
        if !references.is_empty() {
            return Err(Error::Validation(format!(
                "cannot remove probable release-tool proxy {} while non-source-tool repository references remain in {}",
                removal.path.display(),
                references
                    .iter()
                    .map(|item| item.path.display().to_string())
                    .collect::<Vec<_>>()
                    .join(", ")
            )));
        }
    }
    Ok(())
}

fn apply_takeover_transaction(
    root: &Path,
    writes: &[(PathBuf, String)],
    deletes: &[PathBuf],
) -> Result<()> {
    let transaction = root.join(TRANSACTION_PATH);
    if transaction.exists() {
        recover_interrupted_takeover(root)?;
    }
    let setup = (|| {
        std::fs::create_dir_all(transaction.join("original"))
            .map_err(|error| Error::io(&transaction, error))?;
        let affected = writes
            .iter()
            .map(|(path, _)| path.clone())
            .chain(deletes.iter().cloned())
            .collect::<BTreeSet<_>>();
        for relative in &affected {
            let source = root.join(relative);
            if source.is_file() {
                let backup = transaction.join("original").join(relative);
                if let Some(parent) = backup.parent() {
                    std::fs::create_dir_all(parent).map_err(|error| Error::io(parent, error))?;
                }
                std::fs::copy(&source, &backup).map_err(|error| Error::io(&source, error))?;
            }
        }
        let manifest = serde_yaml::to_string(
            &affected
                .iter()
                .map(|path| path.to_string_lossy().to_string())
                .collect::<Vec<_>>(),
        )?;
        let manifest_path = transaction.join("manifest.yml");
        let manifest_temporary = transaction.join("manifest-tmp.yml");
        std::fs::write(&manifest_temporary, manifest)
            .map_err(|error| Error::io(&manifest_temporary, error))?;
        std::fs::rename(&manifest_temporary, &manifest_path)
            .map_err(|error| Error::io(&manifest_path, error))?;
        Ok::<(), Error>(())
    })();
    match setup {
        Ok(()) => {}
        Err(error) => {
            if transaction.exists() {
                std::fs::remove_dir_all(&transaction)
                    .map_err(|cleanup| Error::io(&transaction, cleanup))?;
            }
            return Err(error);
        }
    }
    let result = (|| {
        for (relative, contents) in writes {
            let path = root.join(relative);
            if let Some(parent) = path.parent() {
                std::fs::create_dir_all(parent).map_err(|error| Error::io(parent, error))?;
            }
            let temporary = transaction.join("staged").join(relative);
            if let Some(parent) = temporary.parent() {
                std::fs::create_dir_all(parent).map_err(|error| Error::io(parent, error))?;
            }
            std::fs::write(&temporary, contents).map_err(|error| Error::io(&temporary, error))?;
            std::fs::rename(&temporary, &path).map_err(|error| Error::io(&path, error))?;
        }
        for relative in deletes {
            let path = root.join(relative);
            if path.is_file() {
                std::fs::remove_file(&path).map_err(|error| Error::io(&path, error))?;
            }
        }
        let changeset_directory = root.join(".changeset");
        if changeset_directory.is_dir()
            && std::fs::read_dir(&changeset_directory)
                .map_err(|error| Error::io(&changeset_directory, error))?
                .next()
                .is_none()
        {
            std::fs::remove_dir(&changeset_directory)
                .map_err(|error| Error::io(&changeset_directory, error))?;
        }
        Ok(())
    })();
    if result.is_err() {
        recover_interrupted_takeover(root)?;
        return result;
    }
    if let Err(error) = write_transaction_state(root, "committed") {
        recover_interrupted_takeover(root)?;
        return Err(error);
    }
    finish_transaction_cleanup(root)
}

fn recover_interrupted_takeover(root: &Path) -> Result<()> {
    let transaction = root.join(TRANSACTION_PATH);
    let state_path = root.join(TRANSACTION_STATE_PATH);
    if state_path.is_file() {
        return finish_transaction_cleanup(root);
    }
    if !transaction.exists() {
        return Ok(());
    }
    let manifest_path = transaction.join("manifest.yml");
    if !manifest_path.is_file() {
        return std::fs::remove_dir_all(&transaction)
            .map_err(|error| Error::io(&transaction, error));
    }
    let manifest = std::fs::read_to_string(&manifest_path)
        .map_err(|error| Error::io(&manifest_path, error))?;
    let affected: Vec<String> = serde_yaml::from_str(&manifest)?;
    for relative in affected {
        let relative = PathBuf::from(relative);
        let target = root.join(&relative);
        let backup = transaction.join("original").join(&relative);
        if backup.is_file() {
            if let Some(parent) = target.parent() {
                std::fs::create_dir_all(parent).map_err(|error| Error::io(parent, error))?;
            }
            std::fs::copy(&backup, &target).map_err(|error| Error::io(&target, error))?;
        } else if target.is_file() {
            std::fs::remove_file(&target).map_err(|error| Error::io(&target, error))?;
        }
    }
    write_transaction_state(root, "rolled-back")?;
    finish_transaction_cleanup(root)
}

fn write_transaction_state(root: &Path, state: &str) -> Result<()> {
    let path = root.join(TRANSACTION_STATE_PATH);
    let temporary = root.join(".intentional/.takeover-state-tmp");
    std::fs::write(&temporary, state).map_err(|error| Error::io(&temporary, error))?;
    std::fs::rename(&temporary, &path).map_err(|error| Error::io(&path, error))
}

fn finish_transaction_cleanup(root: &Path) -> Result<()> {
    let transaction = root.join(TRANSACTION_PATH);
    if transaction.exists() {
        std::fs::remove_dir_all(&transaction).map_err(|error| Error::io(&transaction, error))?;
    }
    for path in [
        root.join(TRANSACTION_STATE_PATH),
        root.join(".intentional/.takeover-state-tmp"),
    ] {
        if path.is_file() {
            std::fs::remove_file(&path).map_err(|error| Error::io(&path, error))?;
        }
    }
    Ok(())
}

fn annotate_choice_lines(yaml: &str) -> String {
    let comments = BTreeMap::from([
        ("suspended", "configured, but releases are blocked"),
        ("excluded", "outside Intentional's release-unit inventory"),
        ("managed", "configured and eligible for release"),
        (
            "removed",
            "reference removed or replaced and verified from the file",
        ),
        (
            "external",
            "publication sequencing remains with the external executor",
        ),
        ("intentional", "Intentional's contract owns this behavior"),
    ]);
    let mut output = String::new();
    let mut choices_indent = None;
    for line in yaml.lines() {
        let indent = line.len() - line.trim_start().len();
        if line.trim() == "choices:" {
            choices_indent = Some(indent);
            output.push_str(line);
            output.push('\n');
            continue;
        }
        if let Some(base) = choices_indent {
            if let Some(value) = line.trim().strip_prefix("- ") {
                if let Some(comment) = comments.get(value) {
                    output.push_str(line);
                    output.push_str(" # ");
                    output.push_str(comment);
                    output.push('\n');
                    continue;
                }
            } else if indent <= base {
                choices_indent = None;
            }
        }
        output.push_str(line);
        output.push('\n');
    }
    output
}

#[cfg(test)]
mod tests {
    use super::*;

    const DIGEST: &str = "sha256:0000000000000000000000000000000000000000000000000000000000000000";

    fn candidate(path: &str, resolution: Option<CandidateResolution>) -> DiscoveryCandidate {
        let path = PathBuf::from(path);
        let evidence = SourceEvidence {
            path: path.clone(),
            digest: DIGEST.to_owned(),
            lines: vec![1],
        };
        DiscoveryCandidate {
            id: DiscoveryCandidate::stable_id("sample-detector", &path).expect("stable id"),
            detector: "sample-detector".to_owned(),
            path: path.clone(),
            evidence: vec![evidence.clone()],
            native_identity: Some("sample-native-id".to_owned()),
            raw_version: Some(RawVersionEvidence {
                value: "raw-version-text".to_owned(),
                evidence: vec![evidence.clone()],
            }),
            projection: Some(CandidateProjectionSuggestion {
                adapter: Adapter::Npm,
                path,
                mode: ProjectionMode::Committed,
                pointer: None,
            }),
            tag: Some(CandidateTagSuggestion {
                id: "primary".to_owned(),
                role: TagRole::Primary,
                template: "{id}@{version}".to_owned(),
            }),
            diagnostics: vec![ExtractionDiagnostic {
                id: "sample-diagnostic".to_owned(),
                code: "sample-extraction".to_owned(),
                message: "Sample extraction evidence is incomplete.".to_owned(),
                evidence: vec![evidence],
            }],
            resolution,
        }
    }

    fn candidate_plan(candidates: Vec<DiscoveryCandidate>) -> InitPlan {
        let config = Config::from_yaml(
            "contract: contract-1\nrelease-units:\n  configured:\n    path: configured\n    tags:\n      primary: { role: primary, template: '{id}@{version}' }\n",
        )
        .expect("candidate test config");
        InitPlan {
            schema: INIT_PLAN_SCHEMA.to_owned(),
            state: InitState::NeedsInput,
            source_kind: "changesets".to_owned(),
            source_fingerprint: DIGEST.to_owned(),
            inferred_config: config,
            discovery_candidates: candidates,
            diagnostics: Vec::new(),
            converted_intents: Vec::new(),
            parity: ParityResult {
                status: "equivalent".to_owned(),
                release_units: Vec::new(),
            },
            planned_operations: Vec::new(),
            post_commit_action: "intentional tag --baseline".to_owned(),
        }
    }

    #[test]
    fn candidate_resolution_uses_only_documented_kebab_case_fields() {
        let independent: CandidateResolution =
            serde_yaml::from_str("kind: independent\nrelease-unit: sample-library\n")
                .expect("documented independent resolution");
        assert_eq!(
            independent,
            CandidateResolution::Independent {
                release_unit: "sample-library".to_owned(),
            }
        );

        let projection: CandidateResolution = serde_yaml::from_str(
            "kind: projection\nrelease-unit: sample-library\ntarget-candidate: candidate:1234\n",
        )
        .expect("documented projection resolution");
        assert_eq!(
            projection,
            CandidateResolution::Projection {
                release_unit: "sample-library".to_owned(),
                target_candidate: Some("candidate:1234".to_owned()),
            }
        );
        let rendered = serde_yaml::to_string(&projection).expect("canonical resolution YAML");
        assert!(rendered.contains("release-unit: sample-library"));
        assert!(rendered.contains("target-candidate: candidate:1234"));
        assert!(!rendered.contains("release_unit"));
        assert!(!rendered.contains("target_candidate"));

        for undocumented in [
            "kind: independent\nrelease_unit: sample-library\n",
            "kind: projection\nrelease-unit: sample-library\ntarget_candidate: candidate:1234\n",
        ] {
            serde_yaml::from_str::<CandidateResolution>(undocumented)
                .expect_err("undocumented snake-case field");
        }
    }

    #[test]
    fn recognizes_supported_manifests() {
        assert_eq!(adapter_for(Path::new("package.json")), Some(Adapter::Npm));
        assert_eq!(
            adapter_for(Path::new("module.csproj")),
            Some(Adapter::Msbuild)
        );
        assert_eq!(adapter_for(Path::new("README.md")), None);
    }

    #[test]
    fn choice_rendering_is_compact_and_explained() {
        let yaml = "choices:\n- suspended\n- excluded\nresolution: null\n";
        let rendered = annotate_choice_lines(yaml);
        assert!(rendered.contains("- suspended # configured, but releases are blocked"));
        assert!(rendered.contains("- excluded # outside Intentional's release-unit inventory"));
    }

    #[test]
    fn proxy_reference_detection_ignores_prose_and_comments() {
        let path = "examples/sample.json";
        assert!(!structural_line_references_path(
            r#""description": "See examples/sample.json""#,
            path
        ));
        assert!(!structural_line_references_path(
            "note: examples/sample.json",
            path
        ));
        assert!(!structural_line_references_path(
            "// load examples/sample.json",
            path
        ));
        assert!(!structural_line_references_path(
            "const enabled = true; // load examples/sample.json",
            path
        ));
        assert!(!structural_line_references_path(
            "/* load examples/sample.json */",
            path
        ));
        assert!(structural_line_references_path(
            "run: curl https://registry.invalid && use examples/sample.json",
            path
        ));
        assert!(structural_line_references_path(
            r##"run: "curl https://registry.invalid/#fragment && use examples/sample.json""##,
            path
        ));
        assert!(structural_line_references_path(
            r#"const manifest = "examples/sample.json";"#,
            path
        ));
    }

    #[test]
    fn npm_dependency_evidence_follows_the_materialized_projection_path() {
        struct TestDirectory(PathBuf);
        impl Drop for TestDirectory {
            fn drop(&mut self) {
                let _ = std::fs::remove_dir_all(&self.0);
            }
        }

        let root = TestDirectory(std::env::temp_dir().join(format!(
            "intentional-init-{}-{}",
            std::process::id(),
            std::time::SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .expect("system time")
                .as_nanos()
        )));
        for directory in ["base", "duplicates/alpha", "duplicates/beta"] {
            std::fs::create_dir_all(root.0.join(directory)).expect("create fixture directory");
        }
        std::fs::write(
            root.0.join("base/package.json"),
            r#"{"name":"sample-base","version":"1.0.0"}"#,
        )
        .expect("write base manifest");
        std::fs::write(
            root.0.join("duplicates/alpha/package.json"),
            r#"{"name":"sample-duplicate","version":"1.0.0"}"#,
        )
        .expect("write first duplicate");
        std::fs::write(
            root.0.join("duplicates/beta/package.json"),
            r#"{"name":"sample-duplicate","version":"1.0.0","dependencies":{"sample-base":"^1.0.0"}}"#,
        )
        .expect("write second duplicate");
        let mut config = Config::from_yaml(
            r#"contract: contract-1
release-units:
  sample-base:
    path: base
    projections:
      - { adapter: npm, file: package.json, mode: committed }
    tags:
      primary: { role: primary, template: '{id}@{version}' }
  sample-duplicate:
    path: .
    projections:
      - { adapter: npm, file: duplicates/alpha/package.json, mode: committed }
      - { adapter: npm, file: duplicates/beta/package.json, mode: committed }
    tags:
      primary: { role: primary, template: '{id}@{version}' }
"#,
        )
        .expect("fixture config");

        let mut edges = derive_npm_dependencies(&root.0, &mut config).expect("dependency evidence");
        assert_eq!(edges.len(), 1);
        assert_eq!(edges[0].manifest, Path::new("duplicates/beta/package.json"));
        assert_eq!(
            config.release_units["sample-duplicate"].depends_on,
            vec!["sample-base"]
        );

        config
            .release_units
            .get_mut("sample-duplicate")
            .expect("duplicate unit")
            .projections
            .retain(|projection| projection.file != Path::new("duplicates/beta/package.json"));
        retain_materialized_npm_dependencies(&mut config, &mut edges);
        assert!(edges.is_empty());
        assert!(config.release_units["sample-duplicate"]
            .depends_on
            .is_empty());

        let duplicate = config
            .release_units
            .get_mut("sample-duplicate")
            .expect("duplicate unit");
        duplicate.projections.clear();
        duplicate.depends_on = vec!["sample-base".to_owned()];
        retain_materialized_npm_dependencies(&mut config, &mut edges);
        assert!(config.release_units["sample-duplicate"]
            .depends_on
            .is_empty());
    }

    #[test]
    fn candidate_identity_and_detector_results_are_stable() {
        let first = candidate(
            "examples/first.json",
            Some(CandidateResolution::Independent {
                release_unit: "sample-unit".to_owned(),
            }),
        );
        let second = candidate("examples/second.json", Some(CandidateResolution::Excluded));
        assert_eq!(
            first.id,
            DiscoveryCandidate::stable_id("sample-detector", Path::new("examples/first.json"))
                .expect("same identity")
        );
        assert_ne!(first.id, second.id);
        assert_ne!(
            first.id,
            DiscoveryCandidate::stable_id("other-detector", Path::new("examples/first.json"))
                .expect("different detector")
        );
        assert!(DiscoveryCandidate::stable_id(
            "-invalid-detector",
            Path::new("examples/first.json")
        )
        .is_err());

        let result = DetectorResult {
            detector: "sample-detector".to_owned(),
            candidates: vec![second.clone(), first.clone()],
        };
        let ordered = result.into_candidates().expect("detector result valid");
        assert!(ordered[0].path < ordered[1].path);

        let mut tampered = first.clone();
        tampered.id = format!("candidate:{}", "0".repeat(64));
        assert!(candidate_plan(vec![tampered])
            .validate()
            .expect_err("tampered candidate id rejected")
            .to_string()
            .contains("does not match detector"));

        let foreign = DetectorResult {
            detector: "other-detector".to_owned(),
            candidates: vec![first.clone()],
        };
        assert!(foreign
            .validate()
            .expect_err("foreign detector candidate rejected")
            .to_string()
            .contains("returned candidate owned by"));

        let yaml = candidate_plan(vec![first, second])
            .to_yaml()
            .expect("candidate plan serializes");
        assert!(yaml.contains("kind: independent"));
        assert!(yaml.contains("kind: excluded"));
        assert!(yaml.contains("raw-version:"));
        assert!(yaml.contains("diagnostics:"));
    }

    #[test]
    fn changesets_projection_dedup_rejects_adapter_or_mode_conflicts() {
        for (adapter, mode) in [
            (Adapter::Cargo, ProjectionMode::Committed),
            (Adapter::Npm, ProjectionMode::Injected),
        ] {
            let mut config = candidate_plan(Vec::new()).inferred_config;
            let release_unit = config
                .release_units
                .get_mut("configured")
                .expect("configured release unit");
            release_unit.path = PathBuf::from("examples");
            release_unit.projections = vec![Projection {
                adapter: Adapter::Npm,
                file: PathBuf::from("sample.json"),
                mode: ProjectionMode::Committed,
                pointer: None,
            }];
            let mut candidate = candidate(
                "examples/sample.json",
                Some(CandidateResolution::Projection {
                    release_unit: "configured".to_owned(),
                    target_candidate: None,
                }),
            );
            let suggestion = candidate
                .projection
                .as_mut()
                .expect("projection suggestion");
            suggestion.adapter = adapter;
            suggestion.mode = mode;
            let mut discovery = Discovery {
                config,
                ..Discovery::default()
            };

            let error = apply_changesets_candidate_resolutions(
                Path::new("."),
                &mut discovery,
                &[candidate],
            )
            .expect_err("same target with different semantics rejected");
            assert!(error
                .to_string()
                .contains("conflicts with existing projection"));
        }
    }

    #[test]
    fn resolved_candidates_reject_genuine_version_conflicts() {
        let mut first = candidate(
            "examples/first.json",
            Some(CandidateResolution::Projection {
                release_unit: "configured".to_owned(),
                target_candidate: None,
            }),
        );
        first.raw_version.as_mut().expect("first version").value = "1.0.0".to_owned();
        let mut second = candidate(
            "examples/second.json",
            Some(CandidateResolution::Projection {
                release_unit: "configured".to_owned(),
                target_candidate: None,
            }),
        );
        second.raw_version.as_mut().expect("second version").value = "2.0.0".to_owned();
        let mut discovery = Discovery {
            config: candidate_plan(Vec::new()).inferred_config,
            ..Discovery::default()
        };

        let error = recompute_resolved_versions(&mut discovery, &[first, second])
            .expect_err("resolved version conflict");
        assert!(error
            .to_string()
            .contains("disagree on current version: 1.0.0, 2.0.0"));
    }

    #[test]
    fn changesets_projection_rejects_an_unrelated_existing_owner() {
        let config = Config::from_yaml(
            r#"contract: contract-1
release-units:
  alpha:
    path: examples
    tags:
      primary: { role: primary, template: '{id}@{version}' }
  gamma:
    path: examples
    projections:
      - adapter: json
        file: shared.json
        mode: committed
        pointer: /version
    tags:
      primary: { role: primary, template: 'gamma@{version}' }
"#,
        )
        .expect("unrelated-owner config");
        let mut candidate = candidate(
            "examples/shared.json",
            Some(CandidateResolution::Projection {
                release_unit: "alpha".to_owned(),
                target_candidate: None,
            }),
        );
        candidate.projection = Some(CandidateProjectionSuggestion {
            adapter: Adapter::Json,
            path: candidate.path.clone(),
            mode: ProjectionMode::Committed,
            pointer: Some("/version".to_owned()),
        });
        let candidate_id = candidate.id.clone();
        let mut discovery = Discovery {
            config,
            ..Discovery::default()
        };

        let error =
            apply_changesets_candidate_resolutions(Path::new("."), &mut discovery, &[candidate])
                .expect_err("unrelated projection ownership rejected");
        assert_eq!(
            error.to_string(),
            format!(
                "validation failed: Changesets discovery candidate {candidate_id} projection is already owned by release unit gamma, not alpha"
            )
        );
    }

    #[test]
    fn rejects_plan_without_required_discovery_candidates() {
        let yaml = candidate_plan(Vec::new())
            .to_yaml()
            .expect("complete plan serializes");
        assert!(yaml.contains("discovery-candidates: []"));
        let incomplete = yaml.replace("discovery-candidates: []\n", "");
        let error = serde_yaml::from_str::<InitPlan>(&incomplete)
            .expect_err("missing discovery candidate collection rejected");
        assert!(error
            .to_string()
            .contains("missing field `discovery-candidates`"));
    }

    #[test]
    fn empty_inferred_config_obeys_its_published_schema_shape() {
        let mut plan = candidate_plan(vec![candidate("examples/sample.json", None)]);
        plan.inferred_config = Config::default();
        plan.validate().expect("schema-compatible empty config");

        plan.inferred_config
            .discovery
            .excluded_paths
            .push(ExcludedPathReceipt {
                detector: "sample-detector".to_owned(),
                path: PathBuf::from("examples/sample.json"),
                evidence_digest: DIGEST.to_owned(),
            });
        assert!(plan
            .validate()
            .expect_err("discovery is forbidden on an empty inferred config")
            .to_string()
            .contains("may only contain schema, contract, settings, and release-units"));

        plan.inferred_config.discovery.excluded_paths.clear();
        plan.inferred_config.schema = Some("https://example.invalid/config.yml".to_owned());
        assert!(plan
            .validate()
            .expect_err("foreign schema is forbidden on an empty inferred config")
            .to_string()
            .contains("schema must be"));
    }

    #[test]
    fn candidate_tag_templates_use_the_shared_contract() {
        for template in ["v{version}", "{version}-{version}", "{id}-{id}@{version}"] {
            let mut invalid = candidate("examples/template.json", None);
            invalid.tag.as_mut().expect("tag suggestion").template = template.to_owned();
            assert!(candidate_plan(vec![invalid])
                .validate()
                .expect_err("invalid candidate tag template rejected")
                .to_string()
                .contains("tag template"));
        }
    }

    #[test]
    fn published_init_schema_carries_candidate_resolution_variants() {
        let schema: serde_yaml::Value =
            serde_yaml::from_str(include_str!("../../../schemas/init-plan.yml"))
                .expect("initialization-plan schema parses");
        assert!(schema["required"]
            .as_sequence()
            .expect("required plan fields")
            .iter()
            .any(|field| field.as_str() == Some("discovery-candidates")));
        let variants = schema["$defs"]["candidate-resolution"]["oneOf"]
            .as_sequence()
            .expect("candidate resolution variants");
        assert_eq!(variants.len(), 3);
        let kinds = variants
            .iter()
            .map(|variant| {
                variant["properties"]["kind"]["const"]
                    .as_str()
                    .expect("resolution kind")
            })
            .collect::<BTreeSet<_>>();
        assert_eq!(
            kinds,
            BTreeSet::from(["excluded", "independent", "projection"])
        );
        assert_eq!(
            schema["$defs"]["discovery-candidate"]["properties"]["tag"]["properties"]["template"]
                ["pattern"]
                .as_str(),
            Some(
                r"^(?![\s\S]*v\{version\})(?![\s\S]*\{version\}[\s\S]*\{version\})(?![\s\S]*\{id\}[\s\S]*\{id\})(?=[\s\S]*\{version\})[\s\S]*$"
            )
        );
    }

    #[test]
    fn accepts_configured_and_same_plan_projection_targets() {
        let configured = candidate(
            "examples/configured.json",
            Some(CandidateResolution::Projection {
                release_unit: "configured".to_owned(),
                target_candidate: None,
            }),
        );
        let independent = candidate(
            "examples/independent.json",
            Some(CandidateResolution::Independent {
                release_unit: "planned".to_owned(),
            }),
        );
        let projection = candidate(
            "examples/projection.json",
            Some(CandidateResolution::Projection {
                release_unit: "planned".to_owned(),
                target_candidate: Some(independent.id.clone()),
            }),
        );
        candidate_plan(vec![configured, independent, projection])
            .validate()
            .expect("both projection target kinds accepted");
    }

    #[test]
    fn changesets_materializes_any_unrepresented_candidate_projection_once() {
        let config = candidate_plan(Vec::new()).inferred_config;
        let mut generic = candidate(
            "configured/metadata.json",
            Some(CandidateResolution::Projection {
                release_unit: "configured".to_owned(),
                target_candidate: None,
            }),
        );
        generic.projection = Some(CandidateProjectionSuggestion {
            adapter: Adapter::Json,
            path: generic.path.clone(),
            mode: ProjectionMode::Committed,
            pointer: Some("/version".to_owned()),
        });

        let mut discovery = Discovery {
            config,
            ..Discovery::default()
        };
        apply_changesets_candidate_resolutions(
            Path::new("."),
            &mut discovery,
            std::slice::from_ref(&generic),
        )
        .expect("generic projection materialized");
        assert_eq!(
            discovery.config.release_units["configured"]
                .projections
                .len(),
            1
        );
        assert_eq!(
            discovery.config.release_units["configured"].projections[0]
                .pointer
                .as_deref(),
            Some("/version")
        );

        apply_changesets_candidate_resolutions(
            Path::new("."),
            &mut discovery,
            std::slice::from_ref(&generic),
        )
        .expect("represented projection not duplicated");
        assert_eq!(
            discovery.config.release_units["configured"]
                .projections
                .len(),
            1
        );
    }

    #[test]
    fn rejects_duplicate_creators_and_absent_projection_targets() {
        let first = candidate(
            "examples/first.json",
            Some(CandidateResolution::Independent {
                release_unit: "duplicate".to_owned(),
            }),
        );
        let second = candidate(
            "examples/second.json",
            Some(CandidateResolution::Independent {
                release_unit: "duplicate".to_owned(),
            }),
        );
        assert!(candidate_plan(vec![first, second])
            .validate()
            .expect_err("duplicate creators rejected")
            .to_string()
            .contains("duplicate creator"));

        let absent = candidate(
            "examples/absent.json",
            Some(CandidateResolution::Projection {
                release_unit: "missing".to_owned(),
                target_candidate: None,
            }),
        );
        assert!(candidate_plan(vec![absent])
            .validate()
            .expect_err("absent configured target rejected")
            .to_string()
            .contains("absent configured release unit"));
    }

    #[test]
    fn rejects_projection_cycles_and_release_unit_mismatches() {
        let mut first = candidate("examples/first.json", None);
        let mut second = candidate("examples/second.json", None);
        first.resolution = Some(CandidateResolution::Projection {
            release_unit: "planned".to_owned(),
            target_candidate: Some(second.id.clone()),
        });
        second.resolution = Some(CandidateResolution::Projection {
            release_unit: "planned".to_owned(),
            target_candidate: Some(first.id.clone()),
        });
        assert!(candidate_plan(vec![first, second])
            .validate()
            .expect_err("candidate cycle rejected")
            .to_string()
            .contains("projection cycle"));

        let independent = candidate(
            "examples/independent.json",
            Some(CandidateResolution::Independent {
                release_unit: "planned".to_owned(),
            }),
        );
        let mismatched = candidate(
            "examples/mismatched.json",
            Some(CandidateResolution::Projection {
                release_unit: "other".to_owned(),
                target_candidate: Some(independent.id.clone()),
            }),
        );
        assert!(candidate_plan(vec![independent, mismatched])
            .validate()
            .expect_err("mismatched target rejected")
            .to_string()
            .contains("target"));

        let independent = candidate(
            "examples/independent.json",
            Some(CandidateResolution::Independent {
                release_unit: "planned".to_owned(),
            }),
        );
        let intermediate = candidate(
            "examples/intermediate.json",
            Some(CandidateResolution::Projection {
                release_unit: "planned".to_owned(),
                target_candidate: Some(independent.id.clone()),
            }),
        );
        let chained = candidate(
            "examples/chained.json",
            Some(CandidateResolution::Projection {
                release_unit: "planned".to_owned(),
                target_candidate: Some(intermediate.id.clone()),
            }),
        );
        assert!(candidate_plan(vec![independent, intermediate, chained])
            .validate()
            .expect_err("projection chain rejected")
            .to_string()
            .contains("not an independent creator"));
    }
}