"""P4 robustness suite: crash points, fault injection, concurrency invariants.

VCS-agnostic black-box harness. Subjects are driven only through their CLIs;

every invariant is judged by an independent reader (stdlib SQLite for Oak's

committed graph, ``oakbench.oak_sqlite_reader`` for Oak committed trees, the

real Git plumbing as the Git oracle), never by the binary under test alone.

See suites/robustness/README.md for the case catalog and classification.

"""

from __future__ import annotations

import sys

from pathlib import Path

SUITE_ROOT = Path(__file__).resolve().parents[1]

REPO_ROOT = SUITE_ROOT.parents[1]

_SCRIPTS = REPO_ROOT / "scripts"

if str(_SCRIPTS) not in sys.path:

    sys.path.insert(0, str(_SCRIPTS))

SUITE_VERSION = "p4-robustness-2026-09-29.2"  # .2: evidence-based env fault_fired, git lock rule

# Case classification vocabulary (row field ``classification``).

HELD = "held"

VIOLATED = "violated"

UNSUPPORTED = "unsupported"

HARNESS_ERROR = "harness_error"

# The injected fault never took effect (the kill landed after the operation had

# already exited, the disk was not actually short of the op's need, ...). The

# row records a clean run, so it is never evidence that an invariant held.

FAULT_NOT_FIRED = "fault_not_fired"

CLASSIFICATIONS = (HELD, VIOLATED, UNSUPPORTED, HARNESS_ERROR, FAULT_NOT_FIRED)

# Known Oak bugs a violation maps to (subject_kind, family prefix, operations, invariant) -> feedback id.

# Rows whose violations match carry ``known_bugs``; unmatched violations are new findings.

KNOWN_BUGS = (

    ("oak", "crash_", ("switch", "pull_ff", "pull_diverged"), "worktree_not_torn", "fb-535"),

    # same defect reached through an I/O error instead of a kill: a pull that fails midway

    # leaves its partial output presented as user changes

    ("oak", "env_", ("pull_ff",), "worktree_not_torn", "fb-535"),

    ("oak", "fault_proxy", ("pull_ff", "pull_diverged", "clone"), "worktree_not_torn", "fb-535"),

    ("oak", "conc_same_branch", ("concurrent.push",), "no_lost_acknowledged_write", "fb-534"),

    ("oak", "env_fsync_load", ("concurrent.push",), "no_lost_acknowledged_write", "fb-534"),

)

def known_bugs(subject_kind: str, scenario: str, operation: str, violations: list) -> list:

    """Feedback ids of known bugs matched by a row's violations (sorted, unique)."""

    found = set()

    for kind, prefix, ops, invariant, bug in KNOWN_BUGS:

        if kind == subject_kind and scenario.startswith(prefix) and operation in ops and invariant in violations:

            found.add(bug)

    return sorted(found)