fallow-api 3.35.0

//! Builds the public mutation envelopes from the plan and the schedule.

use std::collections::BTreeMap;
use std::fmt::Write as _;

use fallow_engine::module_graph::ExportTestReach;
use fallow_engine::mutation::{MutantDisposition, MutationPlan, PlannedMutant, PruneReason};
use fallow_output::{
    MutantLocation, MutantResult, MutantStatus, MutantTestReach, MutationBaselineFailure,
    MutationCompletion, MutationFunctionResult, MutationIncompleteReason, MutationPlanCountsOutput,
    MutationPlanDisposition, MutationPlanFile, MutationPlanMutant, MutationReport,
    MutationRunIssue, MutationSkippedFile, MutationStatusCounts, MutationSummary, TestReachClass,
};
use fallow_types::envelope::ToolVersion;
use rustc_hash::FxHashSet;

use super::scheduler::ScheduleOutcome;
use crate::ProgrammaticError;

/// The kebab-case name of a serde enum value.
fn kebab<T: serde::Serialize>(value: &T) -> String {
    serde_json::to_value(value)
        .ok()
        .and_then(|value| value.as_str().map(str::to_owned))
        .unwrap_or_default()
}

pub fn tool_version() -> ToolVersion {
    ToolVersion(env!("CARGO_PKG_VERSION").to_owned())
}

fn location(mutant: &PlannedMutant) -> MutantLocation {
    MutantLocation {
        mutant_id: mutant.mutant.id.as_str().to_owned(),
        file: mutant.file.clone(),
        line: mutant.mutant.line,
        column: mutant.mutant.column + 1,
        span: mutant.mutant.span,
        operator: mutant.mutant.operator.as_str().to_owned(),
        function: mutant
            .function
            .as_ref()
            .and_then(|function| function.name.clone()),
        function_line: mutant.function.as_ref().map(|function| function.line),
        rank: mutant.rank,
        change: Some(fallow_output::MutantChange {
            from: mutant.mutant.change.from.to_owned(),
            to: mutant.mutant.change.to.to_owned(),
        }),
    }
}

fn prune_reason(mutant: &PlannedMutant) -> Option<String> {
    match mutant.disposition {
        MutantDisposition::Pruned(reason) => Some(kebab::<PruneReason>(&reason)),
        _ => None,
    }
}

/// The public test reach of a plan mutant.
fn test_reach(mutant: &PlannedMutant) -> Option<MutantTestReach> {
    let reach = mutant.test_reach.as_ref()?;
    Some(MutantTestReach {
        reach: match reach.reach {
            ExportTestReach::Direct => TestReachClass::Direct,
            ExportTestReach::Transitive => TestReachClass::Transitive,
            ExportTestReach::MockedOnly => TestReachClass::MockedOnly,
            ExportTestReach::None => TestReachClass::None,
            ExportTestReach::NoneFile => TestReachClass::NoneFile,
        },
        export_name: reach.export_name.clone(),
        tests: reach.tests.clone(),
        mocked_targets: reach.mocked_targets.clone(),
    })
}

/// The skipped files of a plan.
pub fn skipped_files(plan: &MutationPlan) -> Vec<MutationSkippedFile> {
    plan.skipped_files
        .iter()
        .map(|file| MutationSkippedFile {
            path: file.path.clone(),
            reason: kebab(&file.reason),
        })
        .collect()
}

/// The plan mutants as public plan entries.
pub fn plan_mutants(plan: &MutationPlan) -> Vec<MutationPlanMutant> {
    plan.mutants
        .iter()
        .map(|mutant| MutationPlanMutant {
            location: location(mutant),
            disposition: match mutant.disposition {
                MutantDisposition::Planned => MutationPlanDisposition::Planned,
                MutantDisposition::Pending => MutationPlanDisposition::Pending,
                MutantDisposition::NoCoverage => MutationPlanDisposition::NoCoverage,
                MutantDisposition::Pruned(_) => MutationPlanDisposition::Pruned,
            },
            prune_reason: prune_reason(mutant),
            test_reach: (mutant.disposition == MutantDisposition::NoCoverage)
                .then(|| test_reach(mutant))
                .flatten(),
        })
        .collect()
}

/// The plan totals.
pub const fn plan_counts(plan: &MutationPlan) -> MutationPlanCountsOutput {
    MutationPlanCountsOutput {
        total: plan.counts.total,
        planned: plan.counts.planned,
        pending: plan.counts.pending,
        no_coverage: plan.counts.no_coverage,
        pruned_dead_code: plan.counts.pruned.dead_code,
        pruned_generated: plan.counts.pruned.generated,
        pruned_side_effect_sink: plan.counts.pruned.side_effect_sink,
        pruned_framework_config: plan.counts.pruned.framework_config,
    }
}

/// The plan files, with no source text.
pub fn plan_files(plan: &MutationPlan) -> Vec<MutationPlanFile> {
    plan.files
        .iter()
        .map(|file| MutationPlanFile {
            path: file.path.clone(),
            source_sha256: file.source_sha256.clone(),
            static_test_files: file.static_test_files.clone(),
        })
        .collect()
}

/// The result of each plan mutant: the plan disposition, or the scheduler
/// outcome of a planned mutant. A planned mutant with no outcome is
/// `pending`. A pending mutant that the dry run never covered is
/// `no_coverage`. A pending mutant that took the place of an uncovered
/// planned mutant has the outcome of its run. A statically `no_coverage`
/// mutant with an outcome is a static map miss, and the outcome of the
/// dry-run map wins. Each `no_coverage`
/// result gets the test reach of its plan mutant.
pub fn mutant_results(plan: &MutationPlan, outcome: Option<&ScheduleOutcome>) -> Vec<MutantResult> {
    plan.mutants
        .iter()
        .map(|mutant| {
            let mut result = mutant_result(mutant, outcome);
            if result.status == MutantStatus::NoCoverage {
                result.test_reach = test_reach(mutant);
            }
            result
        })
        .collect()
}

fn mutant_result(mutant: &PlannedMutant, outcome: Option<&ScheduleOutcome>) -> MutantResult {
    let base = MutantResult {
        location: location(mutant),
        status: MutantStatus::Pending,
        prune_reason: prune_reason(mutant),
        killed_by: None,
        covering_tests: Vec::new(),
        static_mutant: false,
        duration_ms: None,
        test_reach: None,
        retried: false,
        attempts: Vec::new(),
        cached: false,
        type_error_codes: Vec::new(),
    };
    let scheduled = outcome.and_then(|outcome| outcome.results.get(mutant.mutant.id.as_str()));
    match (mutant.disposition, scheduled) {
        (MutantDisposition::Pruned(_), _) => MutantResult {
            status: MutantStatus::Pruned,
            ..base
        },
        (
            MutantDisposition::Planned | MutantDisposition::Pending | MutantDisposition::NoCoverage,
            Some(result),
        ) => MutantResult {
            status: result.status,
            killed_by: result.killed_by.clone(),
            covering_tests: result.covering_tests.clone(),
            static_mutant: result.static_mutant,
            duration_ms: result.duration_ms,
            retried: result.retried,
            attempts: result.attempts.clone(),
            cached: result.cached,
            ..base
        },
        (MutantDisposition::NoCoverage, None) => MutantResult {
            status: MutantStatus::NoCoverage,
            ..base
        },
        (MutantDisposition::Planned | MutantDisposition::Pending, _) => base,
    }
}

/// The totals of `results`.
pub fn summary(results: &[MutantResult]) -> MutationSummary {
    MutationSummary::from_results(results)
}

/// A function group: the file, then the first line and span of the function.
/// Code outside each function has no line and no span, so it sorts first.
type FunctionKey = (String, Option<u32>, Option<(u32, u32)>);

/// The results per enclosing function, by file, then line. Code outside each
/// function comes first in its file.
pub fn function_results(
    plan: &MutationPlan,
    results: &[MutantResult],
) -> Vec<MutationFunctionResult> {
    let mut groups: BTreeMap<FunctionKey, MutationFunctionResult> = BTreeMap::new();
    for (mutant, result) in plan.mutants.iter().zip(results) {
        let function = mutant.function.as_ref();
        let key = (
            mutant.file.clone(),
            function.map(|function| function.line),
            function.map(|function| function.span),
        );
        let group = groups.entry(key).or_insert_with(|| MutationFunctionResult {
            file: mutant.file.clone(),
            name: function.and_then(|function| function.name.clone()),
            line: function.map(|function| function.line),
            end_line: function.map(|function| function.end_line),
            in_diff: function.is_some_and(|function| function.in_diff),
            cyclomatic: function.and_then(|function| function.cyclomatic),
            counts: MutationStatusCounts::default(),
            score: None,
            survived: Vec::new(),
        });
        group.counts.add(result.status);
        if result.status == MutantStatus::Survived {
            group.survived.push(result.location.mutant_id.clone());
        }
    }
    groups
        .into_values()
        .map(|mut group| {
            group.score = group.counts.score();
            group
        })
        .collect()
}

/// The facts that decide the completion of a run.
pub struct CompletionFacts<'a> {
    pub plan: &'a MutationPlan,
    pub results: &'a [MutantResult],
    pub baseline_failures: &'a [MutationBaselineFailure],
    pub worktree_changed: bool,
    /// The end-of-run worktree check failed.
    pub worktree_unchecked: bool,
    /// The time budget ended before each survivor and timeout got its retry.
    pub unretried: bool,
    /// The `path_map` keys that the runner did not load in the dry run.
    pub unloaded_paths: &'a [String],
    /// The static test files that the runner does not list.
    pub undiscovered_test_files: &'a [String],
    /// The type check of the survivors failed.
    pub typecheck_failed: bool,
    /// The pending mutants that the scheduler ran in the place of an
    /// uncovered planned mutant.
    pub promoted: &'a [String],
}

/// The completion: `partial` when a planned mutant has no final status or a
/// fact makes the survivor list inconclusive.
pub fn completion(facts: &CompletionFacts<'_>) -> MutationCompletion {
    let mut reasons = Vec::new();
    if facts
        .results
        .iter()
        .any(|result| result.status == MutantStatus::RuntimeError)
    {
        reasons.push(MutationIncompleteReason::RuntimeError);
    }
    let promoted: FxHashSet<&str> = facts.promoted.iter().map(String::as_str).collect();
    let mut limit_pending = false;
    let mut budget_pending = false;
    for (mutant, result) in facts.plan.mutants.iter().zip(facts.results) {
        if result.status != MutantStatus::Pending {
            continue;
        }
        if is_scheduled(mutant, &promoted) {
            budget_pending = true;
        } else if mutant.disposition == MutantDisposition::Pending {
            limit_pending = true;
        }
    }
    if limit_pending {
        reasons.push(MutationIncompleteReason::MutantLimit);
    }
    if budget_pending || facts.unretried {
        reasons.push(MutationIncompleteReason::TimeBudget);
    }
    if !facts.plan.skipped_files.is_empty() {
        reasons.push(MutationIncompleteReason::SkippedFiles);
    }
    if has_unloaded_reached_file(facts.plan, facts.unloaded_paths, &promoted) {
        reasons.push(MutationIncompleteReason::UnloadedFiles);
    }
    if !facts.undiscovered_test_files.is_empty() {
        reasons.push(MutationIncompleteReason::TestFilesNotDiscovered);
    }
    if !facts.baseline_failures.is_empty() {
        reasons.push(MutationIncompleteReason::BaselineFailure);
    }
    if facts.worktree_changed {
        reasons.push(MutationIncompleteReason::WorktreeChanged);
    }
    if facts.worktree_unchecked {
        reasons.push(MutationIncompleteReason::WorktreeUnchecked);
    }
    if facts.typecheck_failed {
        reasons.push(MutationIncompleteReason::TypecheckFailed);
    }
    MutationCompletion::from_reasons(reasons)
}

/// True when the scheduler gave `mutant` a place inside the `--max-mutants`
/// limit: a planned mutant, or a pending mutant in the place of an uncovered
/// planned mutant.
fn is_scheduled(mutant: &PlannedMutant, promoted: &FxHashSet<&str>) -> bool {
    match mutant.disposition {
        MutantDisposition::Planned => true,
        MutantDisposition::Pending => promoted.contains(mutant.mutant.id.as_str()),
        MutantDisposition::NoCoverage | MutantDisposition::Pruned(_) => false,
    }
}

/// True when the runner did not load a file that has a scheduled mutant and a
/// static test file. The static map says that a dry-run test loads such a
/// file, so its `no_coverage` mutants are a load fault (`protocol.md`
/// section 6), not a fact. A file that no static test reaches stays a fact.
fn has_unloaded_reached_file(
    plan: &MutationPlan,
    unloaded_paths: &[String],
    promoted: &FxHashSet<&str>,
) -> bool {
    if unloaded_paths.is_empty() {
        return false;
    }
    let unloaded: FxHashSet<&str> = unloaded_paths.iter().map(String::as_str).collect();
    plan.files.iter().any(|file| {
        unloaded.contains(file.path.as_str())
            && !file.static_test_files.is_empty()
            && plan
                .mutants
                .iter()
                .any(|mutant| mutant.file == file.path && is_scheduled(mutant, promoted))
    })
}

/// The error of a run in which no mutant got a test result while tests
/// failed with no active mutant.
///
/// A mutant has a test result when it is `killed`, `timeout`, `survived` or
/// `flaky`. Such a run measured nothing, because the failed tests could not
/// detect a mutant. The error fires only when each other mutant is final
/// (`no_coverage`, `runtime_error`, `compile_error`, `equivalent` or
/// `pruned`). A `pending` mutant means that the time budget or
/// `--max-mutants` stopped the run, so the baseline failure is not the cause.
/// A run without a baseline failure and with only `no_coverage` mutants is a
/// fact about the tests and gets no error. The error has exit code 2 and the
/// code `FALLOW_MUTATION_BASELINE_FAILED`, the same as a dry run that fails
/// outside each test file. It names the first failure and the first line of
/// its message.
#[must_use]
pub fn baseline_blocked_run_error(report: &MutationReport) -> Option<ProgrammaticError> {
    let counts = &report.summary.counts;
    if has_test_result(counts) || counts.pending > 0 {
        return None;
    }
    let first = report.baseline_failures.first()?;
    let name = first
        .test_id
        .as_deref()
        .or(first.file.as_deref())
        .unwrap_or("a test file");
    let mut message = format!(
        "no mutant has a test result, because the test suite fails with no active mutant: {name}"
    );
    if let Some(line) = first.message.as_deref().and_then(first_message_line) {
        message.push_str(": ");
        message.push_str(line);
    }
    let others = report.baseline_failures.len() - 1;
    if others > 0 {
        let noun = if others == 1 { "failure" } else { "failures" };
        let _ = write!(
            message,
            " ({others} more {noun}, see `baseline_failures` in the JSON report)"
        );
    }
    Some(
        ProgrammaticError::new(message, 2)
            .with_code("FALLOW_MUTATION_BASELINE_FAILED")
            .with_help(
                "run the tests with the runner directly and make them pass, for example with the environment variables that the package test script sets, then run fallow mutation again",
            ),
    )
}

/// True when a mutant got a test result: `killed`, `timeout`, `survived` or
/// `flaky`.
const fn has_test_result(counts: &MutationStatusCounts) -> bool {
    counts.killed + counts.timeout + counts.survived + counts.flaky > 0
}

/// The first line of a failure message that has text, trimmed.
fn first_message_line(message: &str) -> Option<&str> {
    message.lines().map(str::trim).find(|line| !line.is_empty())
}

/// The public baseline failures of a schedule.
pub fn baseline_failures(outcome: Option<&ScheduleOutcome>) -> Vec<MutationBaselineFailure> {
    outcome
        .map(|outcome| {
            outcome
                .baseline_failures
                .iter()
                .map(|failure| MutationBaselineFailure {
                    file: failure.file.clone(),
                    test_id: failure.test_id.clone(),
                    message: failure.message.clone(),
                    mutant_ids: failure.mutant_ids.clone(),
                })
                .collect()
        })
        .unwrap_or_default()
}

/// The public issues of a schedule.
pub fn issues(outcome: Option<&ScheduleOutcome>) -> Vec<MutationRunIssue> {
    outcome
        .map(|outcome| {
            outcome
                .issues
                .iter()
                .map(|issue| MutationRunIssue {
                    code: issue.code.to_owned(),
                    message: issue.message.clone(),
                    mutant_id: issue.mutant_id.clone(),
                    stderr_tail: issue.stderr_tail.clone(),
                })
                .collect()
        })
        .unwrap_or_default()
}

#[cfg(test)]
mod tests {
    use super::super::scheduler::{MutantOutcome, ScheduleTimings};
    use super::*;
    use fallow_engine::mutation::{
        FunctionFacts, Mutant, MutantChange, MutantId, MutationPlanCounts, Operator, PlannedFile,
        PruneCounts, SkipReason, SkippedFile,
    };
    use fallow_output::MutationCompletionStatus;
    use rustc_hash::FxHashMap;

    fn function(name: &str, line: u32) -> FunctionFacts {
        FunctionFacts {
            name: Some(name.to_owned()),
            span: (line * 100, line * 100 + 50),
            line,
            end_line: line + 3,
            cyclomatic: Some(2),
            in_diff: true,
        }
    }

    fn planned(
        id: &str,
        rank: Option<u32>,
        disposition: MutantDisposition,
        function: Option<FunctionFacts>,
    ) -> PlannedMutant {
        PlannedMutant {
            mutant: Mutant {
                id: MutantId(id.to_owned()),
                operator: Operator::ArithmeticOperator,
                span: (10, 15),
                line: 2,
                column: 9,
                original: "a + b".to_owned(),
                replacement: "a - b".to_owned(),
                enclosing_function: None,
                change: MutantChange::new("+", "-"),
            },
            file: "src/a.ts".to_owned(),
            rank,
            disposition,
            function,
            test_reach: Some(fallow_engine::mutation::MutantTestReach {
                reach: ExportTestReach::MockedOnly,
                export_name: Some("add".to_owned()),
                tests: vec!["test/a.test.ts".to_owned()],
                mocked_targets: vec!["src/a.ts".to_owned()],
            }),
        }
    }

    fn plan(mutants: Vec<PlannedMutant>, pending: usize) -> MutationPlan {
        MutationPlan {
            files: vec![PlannedFile {
                path: "src/a.ts".to_owned(),
                source_sha256: "ab".repeat(32),
                instrumented_code: "SECRET SOURCE".to_owned(),
                static_test_files: vec!["test/a.test.ts".to_owned()],
            }],
            counts: MutationPlanCounts {
                total: mutants.len(),
                pending,
                pruned: PruneCounts::default(),
                ..MutationPlanCounts::default()
            },
            mutants,
            test_files: vec!["test/a.test.ts".to_owned()],
            reach_files: Vec::new(),
            test_file_reach: BTreeMap::new(),
            support_files: Vec::new(),
            no_test_files: false,
            framework_config_checked: false,
            skipped_files: Vec::new(),
            unmatched_paths: Vec::new(),
        }
    }

    fn outcome(results: &[(&str, MutantStatus)]) -> ScheduleOutcome {
        ScheduleOutcome {
            ready: None,
            results: results
                .iter()
                .map(|(id, status)| {
                    (
                        (*id).to_owned(),
                        MutantOutcome {
                            status: *status,
                            killed_by: (*status == MutantStatus::Killed)
                                .then(|| "test/a.test.ts::t1".to_owned()),
                            covering_tests: vec!["test/a.test.ts::t1".to_owned()],
                            static_mutant: false,
                            duration_ms: Some(4),
                            retried: matches!(
                                *status,
                                MutantStatus::Survived | MutantStatus::Timeout
                            ),
                            attempts: Vec::new(),
                            cached: false,
                        },
                    )
                })
                .collect::<FxHashMap<_, _>>(),
            baseline_failures: Vec::new(),
            unloaded_paths: Vec::new(),
            undiscovered_test_files: Vec::new(),
            issues: Vec::new(),
            unretried: Vec::new(),
            timings: ScheduleTimings::default(),
            workers: 1,
            cache_keys: FxHashMap::default(),
            promoted: Vec::new(),
        }
    }

    #[test]
    fn a_pending_mutant_that_the_dry_run_never_hit_is_no_coverage() {
        let plan = plan(
            vec![
                planned("m1", Some(1), MutantDisposition::Planned, None),
                planned("m2", Some(2), MutantDisposition::Pending, None),
                planned("m3", Some(3), MutantDisposition::Pending, None),
            ],
            2,
        );
        let mut outcome = outcome(&[
            ("m1", MutantStatus::Killed),
            ("m3", MutantStatus::NoCoverage),
        ]);
        if let Some(result) = outcome.results.get_mut("m3") {
            result.covering_tests.clear();
        }
        let results = mutant_results(&plan, Some(&outcome));
        let statuses: Vec<MutantStatus> = results.iter().map(|result| result.status).collect();
        assert_eq!(
            statuses,
            vec![
                MutantStatus::Killed,
                MutantStatus::Pending,
                MutantStatus::NoCoverage,
            ]
        );
        let summary = summary(&results);
        assert_eq!(summary.coverage, Some(2.0 / 3.0));
    }

    #[test]
    fn a_promoted_pending_mutant_reports_its_run_and_the_limit_cuts_nothing() {
        let plan = plan(
            vec![
                planned("m1", Some(1), MutantDisposition::Planned, None),
                planned("m2", Some(2), MutantDisposition::Pending, None),
                planned("m3", Some(3), MutantDisposition::Pending, None),
            ],
            2,
        );
        let reasons = |m2: MutantStatus| {
            let mut outcome = outcome(&[
                ("m1", MutantStatus::NoCoverage),
                ("m2", m2),
                ("m3", MutantStatus::NoCoverage),
            ]);
            outcome.promoted = vec!["m2".to_owned()];
            let results = mutant_results(&plan, Some(&outcome));
            let statuses: Vec<MutantStatus> = results.iter().map(|result| result.status).collect();
            assert_eq!(
                statuses,
                vec![MutantStatus::NoCoverage, m2, MutantStatus::NoCoverage]
            );
            completion(&CompletionFacts {
                plan: &plan,
                results: &results,
                baseline_failures: &[],
                worktree_changed: false,
                worktree_unchecked: false,
                unretried: false,
                unloaded_paths: &[],
                undiscovered_test_files: &[],
                typecheck_failed: false,
                promoted: &outcome.promoted,
            })
            .reasons
        };
        assert_eq!(
            reasons(MutantStatus::Killed),
            Vec::<MutationIncompleteReason>::new(),
            "each covered mutant ran, so the limit cut nothing"
        );
        assert_eq!(
            reasons(MutantStatus::Pending),
            vec![MutationIncompleteReason::TimeBudget],
            "a promoted mutant that did not run before the deadline is a time budget miss"
        );
    }

    #[test]
    fn only_a_no_coverage_mutant_carries_its_test_reach() {
        let plan = plan(
            vec![
                planned("m1", Some(1), MutantDisposition::Planned, None),
                planned("m2", Some(2), MutantDisposition::Pending, None),
                planned("m3", None, MutantDisposition::NoCoverage, None),
                planned("m4", Some(3), MutantDisposition::Pending, None),
            ],
            2,
        );
        let mut outcome = outcome(&[
            ("m1", MutantStatus::Killed),
            ("m2", MutantStatus::NoCoverage),
        ]);
        if let Some(result) = outcome.results.get_mut("m2") {
            result.covering_tests.clear();
        }
        let reach = |results: &[MutantResult]| -> Vec<(MutantStatus, Option<TestReachClass>)> {
            results
                .iter()
                .map(|result| {
                    (
                        result.status,
                        result.test_reach.as_ref().map(|reach| reach.reach),
                    )
                })
                .collect()
        };
        let results = mutant_results(&plan, Some(&outcome));
        let mocked = Some(TestReachClass::MockedOnly);
        assert_eq!(
            reach(&results),
            vec![
                (MutantStatus::Killed, None),
                (MutantStatus::NoCoverage, mocked),
                (MutantStatus::NoCoverage, mocked),
                (MutantStatus::Pending, None),
            ]
        );
        let entry = results[2].test_reach.as_ref().expect("a test reach");
        assert_eq!(entry.export_name.as_deref(), Some("add"));
        assert_eq!(entry.mocked_targets, vec!["src/a.ts"]);
        let value = serde_json::to_value(&results[2]).expect("serializes");
        assert_eq!(value["test_reach"]["reach"], "mocked-only");
        assert!(serde_json::to_value(&results[0]).expect("serializes")["test_reach"].is_null());

        let entries = plan_mutants(&plan);
        let plan_reach: Vec<Option<TestReachClass>> = entries
            .iter()
            .map(|entry| entry.test_reach.as_ref().map(|reach| reach.reach))
            .collect();
        assert_eq!(plan_reach, vec![None, None, mocked, None]);
    }

    #[test]
    fn plan_dispositions_and_schedule_outcomes_merge_into_one_status_each() {
        let plan = plan(
            vec![
                planned(
                    "m1",
                    Some(1),
                    MutantDisposition::Planned,
                    Some(function("add", 1)),
                ),
                planned(
                    "m2",
                    Some(2),
                    MutantDisposition::Planned,
                    Some(function("add", 1)),
                ),
                planned("m3", Some(3), MutantDisposition::Planned, None),
                planned("m4", Some(4), MutantDisposition::Pending, None),
                planned(
                    "m5",
                    None,
                    MutantDisposition::NoCoverage,
                    Some(function("sub", 9)),
                ),
                planned(
                    "m6",
                    None,
                    MutantDisposition::Pruned(PruneReason::SideEffectSink),
                    Some(function("sub", 9)),
                ),
            ],
            1,
        );
        let outcome = outcome(&[("m1", MutantStatus::Killed), ("m2", MutantStatus::Survived)]);
        let results = mutant_results(&plan, Some(&outcome));
        let statuses: Vec<MutantStatus> = results.iter().map(|result| result.status).collect();
        assert_eq!(
            statuses,
            vec![
                MutantStatus::Killed,
                MutantStatus::Survived,
                MutantStatus::Pending,
                MutantStatus::Pending,
                MutantStatus::NoCoverage,
                MutantStatus::Pruned,
            ]
        );
        assert_eq!(results[0].killed_by.as_deref(), Some("test/a.test.ts::t1"));
        assert_eq!(results[0].location.column, 10, "the column is 1-based");
        assert_eq!(results[5].prune_reason.as_deref(), Some("side-effect-sink"));
        assert_eq!(
            results
                .iter()
                .map(|result| result.retried)
                .collect::<Vec<_>>(),
            vec![false, true, false, false, false, false],
            "only the retried survivor carries the flag"
        );

        let summary = summary(&results);
        assert_eq!(summary.counts.total, 6);
        assert_eq!(
            summary.score,
            Some(0.5),
            "killed / (killed + survived); no_coverage stays out"
        );
        assert_eq!(
            summary.coverage,
            Some(0.8),
            "covered / (covered + no_coverage); the pending mutants count as covered"
        );

        let completion = completion(&CompletionFacts {
            plan: &plan,
            results: &results,
            baseline_failures: &[],
            worktree_changed: false,
            worktree_unchecked: false,
            unretried: false,
            unloaded_paths: &[],
            undiscovered_test_files: &[],
            typecheck_failed: false,
            promoted: &[],
        });
        assert_eq!(
            completion.reasons,
            vec![
                MutationIncompleteReason::MutantLimit,
                MutationIncompleteReason::TimeBudget
            ],
            "m3 is planned with no outcome, m4 is after the limit"
        );
    }

    #[test]
    fn functions_roll_up_by_file_and_span_with_their_survivors() {
        let plan = plan(
            vec![
                planned(
                    "m1",
                    Some(1),
                    MutantDisposition::Planned,
                    Some(function("add", 1)),
                ),
                planned(
                    "m2",
                    Some(2),
                    MutantDisposition::Planned,
                    Some(function("add", 1)),
                ),
                planned("m3", Some(3), MutantDisposition::Planned, None),
                planned(
                    "m4",
                    Some(4),
                    MutantDisposition::Planned,
                    Some(function("sub", 9)),
                ),
            ],
            0,
        );
        let outcome = outcome(&[
            ("m1", MutantStatus::Killed),
            ("m2", MutantStatus::Survived),
            ("m3", MutantStatus::Timeout),
            ("m4", MutantStatus::Survived),
        ]);
        let results = mutant_results(&plan, Some(&outcome));
        let functions = function_results(&plan, &results);
        type Shape<'a> = (
            Option<&'a str>,
            Option<u32>,
            usize,
            Option<f64>,
            Vec<&'a str>,
        );
        let shape: Vec<Shape<'_>> = functions
            .iter()
            .map(|function| {
                (
                    function.name.as_deref(),
                    function.line,
                    function.counts.total,
                    function.score,
                    function.survived.iter().map(String::as_str).collect(),
                )
            })
            .collect();
        assert_eq!(
            shape,
            vec![
                (None, None, 1, Some(1.0), vec![]),
                (Some("add"), Some(1), 2, Some(0.5), vec!["m2"]),
                (Some("sub"), Some(9), 1, Some(0.0), vec!["m4"]),
            ]
        );
        assert!(functions[1].in_diff);
        assert_eq!(functions[1].end_line, Some(4));
        assert_eq!(
            completion(&CompletionFacts {
                plan: &plan,
                results: &results,
                baseline_failures: &[],
                worktree_changed: false,
                worktree_unchecked: false,
                unretried: false,
                unloaded_paths: &[],
                undiscovered_test_files: &[],
                typecheck_failed: false,
                promoted: &[],
            })
            .reasons,
            Vec::<MutationIncompleteReason>::new()
        );
    }

    #[test]
    fn runtime_errors_skipped_files_baseline_failures_and_worktree_changes_make_a_run_partial() {
        let mut plan = plan(
            vec![planned("m1", Some(1), MutantDisposition::Planned, None)],
            0,
        );
        plan.skipped_files.push(SkippedFile {
            path: "src/big.ts".to_owned(),
            reason: SkipReason::NotAnalyzed,
        });
        let outcome = outcome(&[("m1", MutantStatus::RuntimeError)]);
        let results = mutant_results(&plan, Some(&outcome));
        let failure = MutationBaselineFailure {
            file: Some("test/a.test.ts".to_owned()),
            test_id: None,
            message: Some("boom".to_owned()),
            mutant_ids: Vec::new(),
        };
        let completion = completion(&CompletionFacts {
            plan: &plan,
            results: &results,
            baseline_failures: &[failure],
            worktree_changed: true,
            worktree_unchecked: false,
            unretried: false,
            unloaded_paths: &[],
            undiscovered_test_files: &[],
            typecheck_failed: false,
            promoted: &[],
        });
        assert_eq!(
            completion.reasons,
            vec![
                MutationIncompleteReason::RuntimeError,
                MutationIncompleteReason::SkippedFiles,
                MutationIncompleteReason::BaselineFailure,
                MutationIncompleteReason::WorktreeChanged,
            ]
        );
        assert_eq!(skipped_files(&plan)[0].reason, "not-analyzed");
    }

    #[test]
    fn an_unretried_mutant_and_an_unchecked_worktree_make_a_run_partial() {
        let plan = plan(
            vec![planned("m1", Some(1), MutantDisposition::Planned, None)],
            0,
        );
        let outcome = outcome(&[("m1", MutantStatus::Survived)]);
        let results = mutant_results(&plan, Some(&outcome));
        let completion = completion(&CompletionFacts {
            plan: &plan,
            results: &results,
            baseline_failures: &[],
            worktree_changed: false,
            worktree_unchecked: true,
            unretried: true,
            unloaded_paths: &[],
            undiscovered_test_files: &[],
            typecheck_failed: false,
            promoted: &[],
        });
        assert_eq!(
            completion.reasons,
            vec![
                MutationIncompleteReason::TimeBudget,
                MutationIncompleteReason::WorktreeUnchecked,
            ]
        );
    }

    #[test]
    fn an_unloaded_file_that_a_dry_run_test_reaches_makes_a_run_partial() {
        let mut plan = plan(
            vec![planned("m1", Some(1), MutantDisposition::Planned, None)],
            0,
        );
        plan.files.push(PlannedFile {
            path: "src/b.ts".to_owned(),
            source_sha256: "cd".repeat(32),
            instrumented_code: String::new(),
            static_test_files: Vec::new(),
        });
        let results = mutant_results(&plan, Some(&outcome(&[("m1", MutantStatus::NoCoverage)])));
        let reasons = |unloaded: &[String]| {
            completion(&CompletionFacts {
                plan: &plan,
                results: &results,
                baseline_failures: &[],
                worktree_changed: false,
                worktree_unchecked: false,
                unretried: false,
                unloaded_paths: unloaded,
                undiscovered_test_files: &[],
                typecheck_failed: false,
                promoted: &[],
            })
            .reasons
        };
        assert_eq!(
            reasons(&["src/a.ts".to_owned()]),
            vec![MutationIncompleteReason::UnloadedFiles],
            "a static test reaches src/a.ts, so the runner had to load it"
        );
        assert_eq!(
            reasons(&["src/b.ts".to_owned()]),
            Vec::new(),
            "no static test reaches src/b.ts, so it is a fact, not a fault"
        );
    }

    #[test]
    fn a_static_test_file_that_the_runner_does_not_list_makes_a_run_partial() {
        let plan = plan(
            vec![planned("m1", Some(1), MutantDisposition::Planned, None)],
            0,
        );
        let results = mutant_results(&plan, Some(&outcome(&[("m1", MutantStatus::Survived)])));
        let completion_with = |undiscovered: &[String]| {
            completion(&CompletionFacts {
                plan: &plan,
                results: &results,
                baseline_failures: &[],
                worktree_changed: false,
                worktree_unchecked: false,
                unretried: false,
                unloaded_paths: &[],
                undiscovered_test_files: undiscovered,
                typecheck_failed: false,
                promoted: &[],
            })
        };
        let partial = completion_with(&["test/integration.test.ts".to_owned()]);
        assert_eq!(partial.status, MutationCompletionStatus::Partial);
        assert_eq!(
            partial.reasons,
            vec![MutationIncompleteReason::TestFilesNotDiscovered],
            "a test that never ran can kill the survivor, so the survivor list is not conclusive"
        );
        assert_eq!(
            completion_with(&[]).status,
            MutationCompletionStatus::Complete
        );
    }

    #[test]
    fn a_static_map_miss_takes_the_schedule_outcome() {
        let plan = plan(
            vec![
                planned("m1", None, MutantDisposition::NoCoverage, None),
                planned("m2", None, MutantDisposition::NoCoverage, None),
            ],
            0,
        );
        let results = mutant_results(&plan, Some(&outcome(&[("m1", MutantStatus::Killed)])));
        assert_eq!(results[0].status, MutantStatus::Killed);
        assert_eq!(results[0].killed_by.as_deref(), Some("test/a.test.ts::t1"));
        assert_eq!(results[1].status, MutantStatus::NoCoverage);
    }

    #[test]
    fn a_cached_result_is_marked_in_the_report_and_counts_like_a_run() {
        let plan = plan(
            vec![
                planned("m1", Some(1), MutantDisposition::Planned, None),
                planned("m2", Some(2), MutantDisposition::Planned, None),
            ],
            0,
        );
        let mut outcome = outcome(&[("m1", MutantStatus::Killed), ("m2", MutantStatus::Survived)]);
        if let Some(result) = outcome.results.get_mut("m1") {
            result.cached = true;
        }
        let results = mutant_results(&plan, Some(&outcome));
        assert!(results[0].cached);
        assert!(!results[1].cached);
        assert_eq!(summary(&results).score, Some(0.5));
    }

    #[test]
    fn plan_output_parts_carry_no_source_text() {
        let plan = plan(
            vec![planned(
                "m1",
                Some(1),
                MutantDisposition::Pruned(PruneReason::FrameworkConfig),
                None,
            )],
            0,
        );
        let files = serde_json::to_string(&plan_files(&plan)).expect("json");
        let mutants = serde_json::to_string(&plan_mutants(&plan)).expect("json");
        assert!(
            mutants.contains(r#""change":{"from":"+","to":"-"}"#),
            "{mutants}"
        );
        for text in [&files, &mutants] {
            assert!(!text.contains("SECRET SOURCE"));
            assert!(!text.contains("a + b"));
            assert!(!text.contains("a - b"));
        }
        assert!(mutants.contains(r#""disposition":"pruned""#), "{mutants}");
        assert!(
            mutants.contains(r#""prune_reason":"framework-config""#),
            "{mutants}"
        );
        assert!(files.contains("test/a.test.ts"), "{files}");
    }

    #[test]
    fn results_carry_the_change_without_project_text() {
        let mut logical = planned("m1", Some(1), MutantDisposition::Planned, None);
        logical.mutant.operator = Operator::LogicalOperator;
        logical.mutant.original = "??".to_owned();
        logical.mutant.replacement = "&&".to_owned();
        logical.mutant.change = MutantChange::new("??", "&&");
        let mut string = planned("m2", Some(2), MutantDisposition::Planned, None);
        string.mutant.operator = Operator::StringLiteral;
        string.mutant.original = "\"SECRET SOURCE\"".to_owned();
        string.mutant.replacement = "\"\"".to_owned();
        string.mutant.change = MutantChange::new(MutantChange::STRING, "\"\"");
        let plan = plan(vec![logical, string], 2);
        let value = serde_json::to_value(mutant_results(&plan, None)).expect("json");
        assert_eq!(
            value[0]["change"],
            serde_json::json!({"from": "??", "to": "&&"})
        );
        assert_eq!(
            value[1]["change"],
            serde_json::json!({"from": "<string>", "to": "\"\""})
        );
        assert!(!value.to_string().contains("SECRET SOURCE"), "{value}");
    }
}