rto-graph 1.14.0

//! Ordered, append-only schema migrations.
//!
//! Each [`Migration`] has a monotonically increasing `version` and a body of
//! SQL. On [`apply`], every migration **not already recorded** in
//! `schema_migrations` is run — in ascending version order, each in its own
//! transaction — and then recorded. Applying twice is a no-op, so opening a
//! store is idempotent.
//!
//! **The rule is set membership, not `> MAX(version)` — do not "optimise" it
//! back.** Comparing against the highest recorded version silently skips a
//! *lower*-numbered migration forever, and the store keeps opening cleanly while
//! reporting a schema it does not have:
//!
//! Two branches develop in parallel. One adds migration 12, the other 13. A
//! store opened by the migration-13 build is stamped 13. When the migration-12
//! build later opens that same store, `12 > 13` is false, so **migration 12 is
//! never applied — permanently**. The store opens happily, `schema_version()`
//! answers, and every query touching migration 12's column fails at run time
//! with `no such column`. Reproduced against a real `graph.db`: `sync` died on
//! `no such column: worktree` while `schema_migrations` still read
//! `1..11, 13` — the issue #330 tree stamp, silently absent forever.
//!
//! Nothing could catch it. CI always starts from a *fresh* store, where the two
//! rules agree; the divergence exists only in a store that met the branches in
//! the wrong order. Both branches were independently correct. Set membership
//! removes the ordering dependency entirely, so the merge order of two branches
//! that each add a migration is a preference rather than a permanent trap.
//!
//! **Never edit the SQL of a shipped migration; always append a new one.**

use std::collections::BTreeSet;

use rusqlite::Connection;

/// A single schema migration.
pub(crate) struct Migration {
    /// Monotonic version; the first migration is `1`.
    pub version: u32,
    /// SQL executed as a batch when this migration is applied.
    pub sql: &'static str,
}

/// Migration 1: the initial provenance-tagged node/edge schema.
const M0001_INITIAL: &str = "
CREATE TABLE nodes (
    id         INTEGER PRIMARY KEY,
    key        TEXT NOT NULL UNIQUE,
    kind       TEXT NOT NULL,
    name       TEXT NOT NULL,
    path       TEXT,
    lang       TEXT,
    blob_hash  TEXT,
    span_start INTEGER,
    span_end   INTEGER,
    meta       TEXT NOT NULL DEFAULT 'null'
);
CREATE TABLE edges (
    id         INTEGER PRIMARY KEY,
    src        INTEGER NOT NULL REFERENCES nodes(id),
    dst        INTEGER NOT NULL REFERENCES nodes(id),
    kind       TEXT NOT NULL,
    provenance TEXT NOT NULL CHECK (provenance IN ('derived','authored','inferred')),
    confidence REAL,
    src_ref    TEXT,
    -- A confidence score is present exactly when the edge is inferred,
    -- and when present it lies in [0.0, 1.0]. (Rust `Edge::is_valid` is the
    -- primary guard and also rejects NaN/inf; this is defence in depth.)
    CHECK ((provenance = 'inferred') = (confidence IS NOT NULL)),
    CHECK (confidence IS NULL OR (confidence >= 0.0 AND confidence <= 1.0))
);
CREATE INDEX idx_nodes_kind ON nodes(kind);
CREATE INDEX idx_edges_src ON edges(src);
CREATE INDEX idx_edges_dst ON edges(dst);
CREATE INDEX idx_edges_provenance ON edges(provenance);
";

/// Migration 2: single-row table recording the last synced `HEAD` tree id, so
/// an unchanged tree can be detected as a no-op.
const M0002_SYNC_STATE: &str = "
CREATE TABLE sync_state (
    id   INTEGER PRIMARY KEY CHECK (id = 0),
    tree TEXT NOT NULL
);
";

/// Migration 3: make edges a set — unique by `(src, dst, kind, provenance)`.
/// The graph is a set of relationships, not a multiset, and this makes
/// re-applying a fact set (e.g. the authored layer on top of an unchanged
/// derived graph) idempotent instead of duplicating edges.
const M0003_EDGE_UNIQUE: &str = "
DELETE FROM edges WHERE id NOT IN (
    SELECT MIN(id) FROM edges GROUP BY src, dst, kind, provenance
);
CREATE UNIQUE INDEX idx_edges_unique ON edges(src, dst, kind, provenance);
";

/// Migration 4: durable import layers. `sync`'s full rebuild wipes `nodes`/
/// `edges`, so facts applied by an `import` (Graphify, lat.md, …) would be lost
/// on the next code-changing sync. Persist each import's `FactSet` here, keyed by
/// its `src_ref`, so `build_graph` can re-apply it after every rebuild. This
/// table is never touched by `rebuild`, so imported knowledge is durable.
const M0004_IMPORTS: &str = "
CREATE TABLE imports (
    src_ref     TEXT PRIMARY KEY,
    facts       TEXT NOT NULL,
    imported_at TEXT NOT NULL DEFAULT (datetime('now'))
);
";

/// Migration 5: the per-node context cache. Each row holds a node's assembled
/// context bundle (`json`) and a `fingerprint` derived from the node's own
/// content **and** its one-hop neighbourhood, so a change to the node or any
/// neighbour invalidates the entry (a cache miss on next read). Like `imports`,
/// this table is *not* touched by `rebuild`, so cached context survives a
/// code-changing sync and is invalidated only by fingerprint — a stale entry for
/// a deleted node is pruned on refresh.
const M0005_NODE_CONTEXT: &str = "
CREATE TABLE node_context (
    key         TEXT PRIMARY KEY,
    fingerprint TEXT NOT NULL,
    json        TEXT NOT NULL
);
";

/// Migration 6: tag each node with the layer that produced it, mirroring
/// `edges.provenance`. `sync` owns the *derived* layer; `check`/`import` own the
/// *authored*/*inferred* layers. Back-filling `'derived'` is correct for the
/// derived majority (extraction). Authored/import rows are re-tagged with their
/// true provenance on the next build: `check` re-applies ADR/blueprint facts
/// (now tagged authored), and `reapply_imports` re-upserts import nodes, which
/// the store repairs to non-derived on load (an import node is never derived), so
/// a legacy persisted import layer — whose serialized nodes predate this column —
/// is not left mislabelled. A future incremental `sync` uses the tag to delete/
/// replace only derived nodes for changed paths, leaving other layers intact.
const M0006_NODE_PROVENANCE: &str = "
ALTER TABLE nodes ADD COLUMN provenance TEXT NOT NULL DEFAULT 'derived'
    CHECK (provenance IN ('derived','authored','inferred'));
CREATE INDEX idx_nodes_provenance ON nodes(provenance);
";

/// Migration 7: record the extraction *identity* alongside the synced tree.
/// Extraction output depends on more than (path, bytes) — the extractor code
/// version (`EXTRACT_VERSION`) and its environment (installed image models,
/// ingestion toggles; see `Extractor::env_tag`), the same components the content
/// cache keys on. The incremental
/// committed `sync` reconstructs unchanged paths' facts from the store (extracted
/// under the *previous* env), so it is only sound when the env is unchanged;
/// otherwise it must fall back to a full re-extraction. Persisting the env lets
/// `sync` detect that. Nullable: a legacy row (or a non-committed sync) leaves it
/// `NULL`, which reads as \"unknown\" and forces the safe full path.
const M0007_SYNC_ENV: &str = "
ALTER TABLE sync_state ADD COLUMN env TEXT;
";

/// Migration 8: the analyzer-findings artifact store (ADR-0012).
///
/// Analyzer output (`cargo-audit`, `semgrep`, successors) is asserted by an
/// external tool at a point in time, against rules and an advisory database that
/// change independently of the source tree. That is a *fourth* production model,
/// not one of the graph's three provenance classes, so it gets its own tables and
/// never touches `nodes`/`edges` — which keeps `export_factset` (and the published
/// `GraphArtifact`) a pure function of the tree, and keeps findings off the
/// `authored` relevance boost in `search`.
///
/// An **analysis run** records the execution plus everything needed to reproduce
/// or distrust it. `layer` is `security:<analyzer>:<worktree-id>` and is UNIQUE:
/// exactly one run is live per layer, and a re-ingest replaces it wholesale, so a
/// finding that has been fixed disappears rather than lingering. The UNIQUE index
/// is also the entry point for "list live findings for this worktree/analyzer";
/// `idx_analysis_runs_analyzer` serves the same question across worktrees.
///
/// `ingested_at` is written for humans and **never read** — matching how
/// `imports.imported_at` already behaves; no ordering or policy depends on a clock.
///
/// A **finding** belongs to a run and carries a stable identity key so the same
/// issue is recognisable across runs. The analyzer id lives on the run, not
/// repeated on every finding row. `ON DELETE CASCADE` is defence in depth only —
/// `Store::replace_findings_layer` deletes the owned rows explicitly, because the
/// established import path deletes edges but *not* obsolete owned nodes and that
/// gap must not be inherited here.
const M0008_FINDINGS: &str = "
CREATE TABLE analysis_runs (
    id                       INTEGER PRIMARY KEY,
    layer                    TEXT NOT NULL UNIQUE,
    analyzer                 TEXT NOT NULL,
    analyzer_version         TEXT NOT NULL,
    runner                   TEXT NOT NULL CHECK (runner IN ('ingested','subprocess','sandboxed')),
    isolation                TEXT NOT NULL CHECK (isolation IN ('ingested','microvm','none')),
    image_digest             TEXT,
    rules_digest             TEXT,
    advisory_db_digest       TEXT,
    advisory_db_published_at TEXT,
    command_policy           TEXT NOT NULL,
    source_commit            TEXT,
    source_tree              TEXT,
    source_lockfile_blob     TEXT,
    started_at               TEXT NOT NULL,
    ended_at                 TEXT NOT NULL,
    exit_status              INTEGER NOT NULL,
    report_digest            TEXT NOT NULL,
    ingested_at              TEXT NOT NULL DEFAULT (datetime('now'))
);
CREATE INDEX idx_analysis_runs_analyzer ON analysis_runs(analyzer);
CREATE TABLE findings (
    id         INTEGER PRIMARY KEY,
    run_id     INTEGER NOT NULL REFERENCES analysis_runs(id) ON DELETE CASCADE,
    key        TEXT NOT NULL,
    rule       TEXT NOT NULL,
    severity   TEXT NOT NULL,
    title      TEXT NOT NULL,
    message    TEXT NOT NULL,
    path       TEXT,
    span_start INTEGER,
    span_end   INTEGER,
    meta       TEXT NOT NULL DEFAULT 'null',
    -- A span is present as a pair or not at all, and never runs backwards.
    CHECK ((span_start IS NULL) = (span_end IS NULL)),
    CHECK (span_start IS NULL OR span_end >= span_start)
);
CREATE UNIQUE INDEX idx_findings_run_key ON findings(run_id, key);
CREATE INDEX idx_findings_run_severity ON findings(run_id, severity);
";

/// Migration 9: the generated-media-content artifact store (ADR-0015).
///
/// An ASR transcript or a VLM description is **generated**, not decoded: asked to
/// transcribe digital silence a model returns fluent invented prose, and the same
/// blob under a different model, quantisation or sampling yields different
/// "facts". That is not a deterministic pure function of `(path, blob id, bytes)`,
/// so it is not a `derived` fact and must not be stored as one — it gets its own
/// table here and never touches `nodes`/`edges`, exactly as analyzer findings do
/// in migration 8. OCR stays on the derived path: it decodes text that is
/// actually present, so it has no row here and `kind` has no token for it.
///
/// **Keyed by `(blob_id, producer)`**, and that UNIQUE index is the whole design:
/// the producer column is a rendered identity over the model, its digest, its
/// quantisation, the projector digest, the prompt and the sampling parameters, so
/// re-describing a blob with a better model inserts a **new row beside the old
/// one** rather than overwriting it. You can compare the two, and you can drop
/// one producer's output wholesale without touching the graph.
///
/// The identity components are stored as columns rather than folded only into
/// `producer`, because a record must be legible — and distrustable — on its own:
/// `media status` reports which model said what, and a row whose evidence lived
/// only inside an opaque token could not answer that.
///
/// `produced_at` is written by `SQLite`, as `imports.imported_at` and
/// `analysis_runs.ingested_at` already are. Unlike those two it *is* read, but
/// only for display; no ordering or policy depends on a clock.
///
/// Records are **not** touched by `rebuild` (which deletes only `edges` and
/// `nodes`), following the `imports` precedent: they are expensive to reproduce —
/// a 715 MB projector load per blob, issue #301 — and are not derivable from
/// source alone.
const M0009_MEDIA_CONTENT: &str = "
CREATE TABLE media_content (
    id            INTEGER PRIMARY KEY,
    blob_id       TEXT NOT NULL,
    path          TEXT NOT NULL,
    kind          TEXT NOT NULL CHECK (kind IN ('audio','vision')),
    producer      TEXT NOT NULL,
    model         TEXT NOT NULL,
    model_digest  TEXT NOT NULL,
    quantisation  TEXT NOT NULL,
    mmproj_digest TEXT NOT NULL,
    prompt        TEXT NOT NULL,
    temperature   REAL NOT NULL,
    max_tokens    INTEGER NOT NULL,
    tool_version  TEXT NOT NULL,
    generation    INTEGER NOT NULL,
    produced_at   TEXT NOT NULL DEFAULT (datetime('now')),
    text          TEXT NOT NULL,
    confidence    REAL,
    -- A confidence signal, when a runtime exposes one, is a probability. It is
    -- **not** the score an `inferred` edge carries and must never be read as one.
    CHECK (confidence IS NULL OR (confidence >= 0.0 AND confidence <= 1.0))
);
CREATE UNIQUE INDEX idx_media_content_blob_producer ON media_content(blob_id, producer);
CREATE INDEX idx_media_content_producer ON media_content(producer);
CREATE INDEX idx_media_content_kind ON media_content(kind);
";

/// Migration 10: record the **pre-generation gate**'s refusals (ADR-0015).
///
/// A blob the gate refuses — digital silence, a flat-colour image — gets a
/// `media_content` row like any other, but one carrying the *measurement* that
/// refused it instead of generated text. Without it a skip would be an
/// indistinguishable hole, and an operator could not tell **not generated** from
/// **generated nothing**; recording an invisible skip would be its own small lie
/// in an ADR about not lying.
///
/// The table is rebuilt rather than `ALTER`ed because the point of the three new
/// columns is a constraint `ALTER TABLE` cannot add: **a skip carries a
/// measurement and no text, and a generated row is the exact converse**. That is
/// the invariant the whole change rests on — a gated blob must not put text
/// anywhere — and it belongs in the schema, not only in the Rust type that
/// happens to write it today. `text` stays `NOT NULL`, so a skip stores `''`,
/// which the `CHECK` requires.
///
/// The rebuild copies every existing row with all three columns `NULL` (every
/// pre-existing record was generated, by construction — the gate did not exist),
/// then drops the old table. Dropping it takes its indexes with it, so the three
/// are recreated verbatim below.
const M0010_MEDIA_GATE: &str = "
CREATE TABLE media_content_v2 (
    id             INTEGER PRIMARY KEY,
    blob_id        TEXT NOT NULL,
    path           TEXT NOT NULL,
    kind           TEXT NOT NULL CHECK (kind IN ('audio','vision')),
    producer       TEXT NOT NULL,
    model          TEXT NOT NULL,
    model_digest   TEXT NOT NULL,
    quantisation   TEXT NOT NULL,
    mmproj_digest  TEXT NOT NULL,
    prompt         TEXT NOT NULL,
    temperature    REAL NOT NULL,
    max_tokens     INTEGER NOT NULL,
    tool_version   TEXT NOT NULL,
    generation     INTEGER NOT NULL,
    produced_at    TEXT NOT NULL DEFAULT (datetime('now')),
    text           TEXT NOT NULL,
    confidence     REAL,
    skip_reason    TEXT CHECK (skip_reason IS NULL OR skip_reason IN ('silence','uniform')),
    skip_value     REAL,
    skip_threshold REAL,
    -- A confidence signal, when a runtime exposes one, is a probability. It is
    -- **not** the score an `inferred` edge carries and must never be read as one.
    CHECK (confidence IS NULL OR (confidence >= 0.0 AND confidence <= 1.0)),
    -- The two outcomes, and nothing in between. Either the model ran (no skip
    -- columns at all), or the gate refused the blob before it did — in which
    -- case the measurement is complete AND the row holds no generated text.
    --
    -- All three skip columns are named in BOTH branches, so they stand or fall
    -- together. `skip_reason` in particular must be named in the second branch:
    -- it is the discriminant the Rust decoder reads, so a row with a value and a
    -- threshold but no reason would come back as *generated content that happens
    -- to be empty* — the exact confusion this constraint exists to prevent.
    CHECK (
        (skip_reason IS NULL AND skip_value IS NULL AND skip_threshold IS NULL)
        OR (skip_reason IS NOT NULL AND skip_value IS NOT NULL
            AND skip_threshold IS NOT NULL AND text = '')
    )
);
INSERT INTO media_content_v2 (
    id, blob_id, path, kind, producer, model, model_digest, quantisation, mmproj_digest,
    prompt, temperature, max_tokens, tool_version, generation, produced_at, text, confidence
) SELECT
    id, blob_id, path, kind, producer, model, model_digest, quantisation, mmproj_digest,
    prompt, temperature, max_tokens, tool_version, generation, produced_at, text, confidence
FROM media_content;
DROP TABLE media_content;
ALTER TABLE media_content_v2 RENAME TO media_content;
CREATE UNIQUE INDEX idx_media_content_blob_producer ON media_content(blob_id, producer);
CREATE INDEX idx_media_content_producer ON media_content(producer);
CREATE INDEX idx_media_content_kind ON media_content(kind);
";

/// Migration 11: the episodic agent-memory artifact store (ADR-0013).
///
/// What a session *learned* — a lesson, an approach that failed, a decision, a
/// recurring failure pattern, a task outcome — has **no generating function**.
/// It cannot be re-derived from `(path, blob id, bytes)` at any price, so it is
/// not a `derived` fact; it was not written into a reviewed file, so it is not
/// `authored` either. It gets its own table here and never touches
/// `nodes`/`edges`, exactly as analyzer findings (migration 8) and generated
/// media content (migration 9) do. `EXTRACT_VERSION` is unchanged: memory is not
/// extraction output.
///
/// This is the **episodic** tier only — durable and never auto-evicted, modelling
/// what `imports` models. `rebuild` deletes only `edges` and `nodes`, so these
/// rows survive a code-changing sync by construction and are removed only by an
/// explicit `roteiro memory forget`. The bounded, evictable cache tier the ADR
/// pairs with it is a separate table in a later migration, deliberately split so
/// eviction policy can change without touching durable memory.
///
/// **`id` is the ordering key, and `AUTOINCREMENT` is load-bearing.** A plain
/// `INTEGER PRIMARY KEY` is the rowid, and `SQLite` reuses the largest deleted
/// rowid — so forgetting the newest record would hand its number to the next
/// write, making the "monotonic generation" non-monotone *and* silently
/// re-pointing any `superseded_by` that referenced it at an unrelated record.
/// `AUTOINCREMENT` never reuses an id, at the cost of one `sqlite_sequence` row.
///
/// **No column here is ranked on wall-clock.** `created_at` is written for humans
/// and never read, exactly as `imports.imported_at` behaves — the store is
/// per-repo and shared across worktrees and branches, so concurrent checkouts
/// produce non-monotone times, and `datetime('now')` ties on intra-second writes.
/// `superseded_at` is the same kind of value: display, never policy. The logical
/// fact of supersession is `superseded_by`, which is an id, which is a generation.
///
/// **The anchor is `(anchor_key, anchor_blob)`, never a span.** A span is byte
/// offsets and shifts on any edit above it; a node key plus the blob hash captured
/// when the record was written is stable, and is what lets a read say *the anchor
/// vanished* (no such node) apart from *the code changed underneath* (a different
/// blob). Anchor state is **computed on read and never stored**, and a record
/// whose anchor drifted is kept and marked — never pruned. That is a deliberate
/// departure from the authored layer's prune rule: a lesson about deleted code is
/// often the most valuable one there is.
///
/// **The anchor is also the scope test** (ADR-0013 §*Scope*). A record applies to
/// the tree in front of you when its anchor resolves there with the same blob —
/// which is what "the association is merged in the same format" means — or when
/// it has no anchor at all, a general lesson that applies everywhere. Anything
/// else does not apply *here* and is kept, marked. Hence `scope` is a namespace
/// and not a branch label: applicability is a question about the tree, not about
/// the branch a record was written on, so no branch bookkeeping exists anywhere in
/// this schema.
///
/// Two constraints exist to make half-states unrepresentable, in the spirit of
/// migration 10's outcome CHECK:
///
/// * `superseded_by` and `superseded_at` stand or fall **together**. A row with a
///   timestamp and no successor would be a record dropped from live listing with
///   no auditable reason — supersession inferred rather than recorded, which is
///   the one thing ADR-0013 rules out.
/// * `anchor_blob`/`anchor_path` require an `anchor_key`. A blob hash with no node
///   key names nothing and can never be checked for drift.
const M0011_AGENT_MEMORY: &str = "
CREATE TABLE agent_memory (
    id            INTEGER PRIMARY KEY AUTOINCREMENT,
    -- A coarse NAMESPACE — which repo or project a record belongs to in a
    -- multi-repo workspace. **Not a branch label, and never to be repurposed as
    -- one.** Whether a record applies to the tree in front of you is decided by
    -- resolving its anchor below, not by where it was written: see ADR-0013
    -- §Scope. Nothing keys off this column but an exact-match filter.
    scope         TEXT NOT NULL,
    kind          TEXT NOT NULL
                  CHECK (kind IN ('lesson','attempt','decision','pattern','outcome')),
    anchor_key    TEXT,
    anchor_blob   TEXT,
    anchor_path   TEXT,
    body          TEXT NOT NULL,
    confidence    REAL,
    tree          TEXT,
    created_at    TEXT NOT NULL DEFAULT (datetime('now')),
    superseded_by INTEGER REFERENCES agent_memory(id),
    superseded_at TEXT,
    -- A scope and a body that are present but empty are corrupt writes, not
    -- minimal ones: an empty memory records nothing and can never be recalled.
    CHECK (scope <> ''),
    CHECK (body <> ''),
    -- A self-reported confidence, when a caller offers one, is a probability. It
    -- is **not** the score an `inferred` edge carries and must never be read as
    -- one: no memory record is a graph fact.
    CHECK (confidence IS NULL OR (confidence >= 0.0 AND confidence <= 1.0)),
    -- Anchor evidence without an anchor key names nothing.
    CHECK (anchor_blob IS NULL OR anchor_key IS NOT NULL),
    CHECK (anchor_path IS NULL OR anchor_key IS NOT NULL),
    -- Supersession is recorded, never inferred: the successor and the moment
    -- stand or fall together, and nothing supersedes itself.
    CHECK ((superseded_by IS NULL) = (superseded_at IS NULL)),
    CHECK (superseded_by IS NULL OR superseded_by <> id)
);
CREATE INDEX idx_mem_anchor ON agent_memory(anchor_key);
CREATE INDEX idx_mem_live ON agent_memory(scope, superseded_by, id DESC);
";

/// Migration 12: record **which working tree** the graph was assembled from
/// (issue #330).
///
/// `graph.db` is an assembled view of *one* tree. Nothing in the store said which
/// one, so a store that came to describe a different tree — restored from a
/// backup, copied with a `.git` directory, or reached after a layout change that
/// moved it under the shared common git dir — would answer confidently about the
/// wrong tree. `sync` would report "up to date" against a state id it had no
/// business trusting, and `check` would validate a tree nobody was looking at.
/// Stamping the tree lets the sync engine notice and rebuild instead of guessing.
///
/// **Why this is a stamp and not a split.** The obvious alternative — give every
/// worktree its own database — is deliberately *not* what happens, and must not
/// be introduced later by accident. `findings`, `media_content`, `agent_memory`
/// and `imports` all live inside this same `graph.db`, and ADR-0013 v1.1 depends
/// on that store being **shared**: the scope rule (a memory applies wherever its
/// anchor resolves, with no branch bookkeeping) was demonstrated with ONE row in
/// ONE store giving opposite verdicts on two branches. Splitting the database per
/// worktree would silently reintroduce exactly the branch-scoping that ADR
/// rejected — a change that needs the ADR **amended**, not merely extended.
///
/// Note the distinction the codebase already draws and this preserves:
/// [`crate::ObjectCache`] is content-addressed by blob id, so sharing it across
/// worktrees under the *common* git dir is correct and valuable — extraction done
/// in one worktree is reusable in all of them. The assembled graph is not
/// content-addressed, so sharing *it* would mean last-writer-wins. The two are
/// stored differently on purpose.
///
/// Nullable, following the `env` precedent (migration 7): a legacy row reads as
/// "unknown", which is adopted rather than treated as a mismatch — an existing
/// store is not rebuilt merely for predating this column.
const M0012_SYNC_WORKTREE: &str = "
ALTER TABLE sync_state ADD COLUMN worktree TEXT;
";

/// Migration 13: the **transient cache tier** (ADR-0013, the second half of the
/// two-tier store; build plan Stage 25) — the opposite of migration 11 in every
/// rule, because it holds the opposite kind of knowledge.
///
/// `agent_memory` above is episodic: it has **no generating function**, so
/// evicting it is data loss and it is never swept. Everything in `agent_cache` is
/// **re-derivable by definition** — a context bundle, an embedding, a query result
/// over current code — and `build_context` is *proven* to reconstruct identically
/// (`context.rs` asserts `built == cached`). So eviction here costs cycles, never
/// information, which is exactly what licenses a bound on this table and forbids
/// one on that one.
///
/// **Bounded by bytes, not by rows**, porting `rto-llama`'s in-memory `ModelCache`
/// (`llama.rs:120-137`, pinned by `budget_evicts_oldest_until_it_fits`) to disk
/// rather than inventing a policy: entries vary hugely in size, and bytes are what
/// actually constrain `.git/roteiro/`. `bytes` is the row's own payload size,
/// computed at write, so the sweep can order and total without reading `json`.
///
/// **`generation`, `last_used` and `hits` are the persisted access tracking that
/// no table in this schema has ever carried.** `ModelCache` tracks recency by the
/// order of an in-memory `Vec`, which does not survive a process; `node_context`
/// (migration 5) has no timestamp, no hit counter and no TTL at all. So the signal
/// has to be introduced here, with the table that needs it.
///
/// **Neither is a clock**, for the reason ADR-0013 §3 gives: the store is per-repo
/// and shared across worktrees, so wall-clock is non-monotone across concurrent
/// checkouts and `datetime('now')` ties on intra-second writes. Both are logical
/// counters drawn from `agent_cache_clock` below, which is the only reason that
/// single-row table exists:
///
/// * `ticks` advances on **every cache access**, so `last_used` is a strict total
///   order over accesses — the durable equivalent of `ModelCache`'s list position,
///   with no ties for the sweep to break arbitrarily.
/// * `generation` advances **once per sweep**. A row written since the last sweep
///   is in the current generation, and — if its anchor is still valid — is never
///   evicted by that sweep, so a session's own just-written work cannot be thrown
///   away by the maintenance pass that follows it.
///
/// **The anchor is the same anchor, and the same rule.** `(anchor_key,
/// anchor_blob)` resolves against `nodes` on read exactly as `agent_memory`'s does,
/// yielding the same `AnchorState`, and `AnchorState::applies` is the whole
/// validity test — here it supplies the `anchor_valid ASC` half of the eviction
/// order, so a row whose code moved out from under it goes before a row that still
/// describes the tree. There is deliberately no second rule and no scope term.
const M0013_AGENT_CACHE: &str = "
CREATE TABLE agent_cache (
    key         TEXT PRIMARY KEY,
    -- The content-addressed freshness witness, on `node_context`'s terms: a
    -- reader compares it with the fingerprint the current graph yields and treats
    -- a mismatch as a miss. Eviction is a *capacity* policy and is orthogonal to
    -- this one — the house idiom for staleness stays key/fingerprint invalidation.
    fingerprint TEXT NOT NULL,
    json        TEXT NOT NULL,
    -- The row's own payload size, so the sweep can order and total by bytes
    -- without reading every `json` in the tier.
    bytes       INTEGER NOT NULL,
    -- The sweep generation this row was written in (see `agent_cache_clock`).
    generation  INTEGER NOT NULL,
    -- The access tick this row was last read or written at. Strictly increasing,
    -- never a wall-clock: this is `ModelCache`'s list position, made durable.
    last_used   INTEGER NOT NULL,
    hits        INTEGER NOT NULL DEFAULT 0,
    anchor_key  TEXT,
    anchor_blob TEXT,
    -- Half-states, refused on migration 10's and 11's precedent.
    CHECK (key <> ''),
    CHECK (bytes >= 0),
    CHECK (generation >= 0),
    CHECK (last_used >= 0),
    CHECK (hits >= 0),
    -- Anchor evidence without an anchor key names nothing and can never be
    -- checked for drift — the same constraint `agent_memory` carries.
    CHECK (anchor_blob IS NULL OR anchor_key IS NOT NULL)
);
-- The eviction order, as an index: least-recently-used first.
CREATE INDEX idx_cache_evict ON agent_cache(last_used);
CREATE INDEX idx_cache_anchor ON agent_cache(anchor_key);

-- The logical clock the two counters above are drawn from. A single row, on
-- `sync_state`'s precedent (migration 2), because there is exactly one of it.
CREATE TABLE agent_cache_clock (
    id         INTEGER PRIMARY KEY CHECK (id = 0),
    ticks      INTEGER NOT NULL DEFAULT 0 CHECK (ticks >= 0),
    generation INTEGER NOT NULL DEFAULT 0 CHECK (generation >= 0)
);
INSERT INTO agent_cache_clock (id) VALUES (0);
";

/// The ordered list of all migrations. Append only.
pub(crate) const MIGRATIONS: &[Migration] = &[
    Migration {
        version: 1,
        sql: M0001_INITIAL,
    },
    Migration {
        version: 2,
        sql: M0002_SYNC_STATE,
    },
    Migration {
        version: 3,
        sql: M0003_EDGE_UNIQUE,
    },
    Migration {
        version: 4,
        sql: M0004_IMPORTS,
    },
    Migration {
        version: 5,
        sql: M0005_NODE_CONTEXT,
    },
    Migration {
        version: 6,
        sql: M0006_NODE_PROVENANCE,
    },
    Migration {
        version: 7,
        sql: M0007_SYNC_ENV,
    },
    Migration {
        version: 8,
        sql: M0008_FINDINGS,
    },
    Migration {
        version: 9,
        sql: M0009_MEDIA_CONTENT,
    },
    Migration {
        version: 10,
        sql: M0010_MEDIA_GATE,
    },
    Migration {
        version: 11,
        sql: M0011_AGENT_MEMORY,
    },
    Migration {
        version: 12,
        sql: M0012_SYNC_WORKTREE,
    },
    Migration {
        version: 13,
        sql: M0013_AGENT_CACHE,
    },
];

/// [`MIGRATIONS`] is in **strictly ascending** version order, checked at compile
/// time so a misordered or duplicated entry cannot be built, let alone shipped.
///
/// [`apply`] selects migrations by set membership, so it no longer *derives*
/// ordering from a `>` comparison — it inherits it from this slice. That makes
/// the slice's order load-bearing: a later migration may depend on an earlier
/// one's tables, so running them out of order would fail (or, worse, succeed
/// against a shape nobody intended). A `#[test]` would catch that too, but only
/// if someone runs it; this fails the build.
const _: () = {
    let mut i = 1;
    while i < MIGRATIONS.len() {
        assert!(
            MIGRATIONS[i - 1].version < MIGRATIONS[i].version,
            "MIGRATIONS must be in strictly ascending version order, with no \
             duplicates: `apply` runs them in slice order and a later migration \
             may depend on an earlier one"
        );
        i += 1;
    }
};

/// The highest migration version known to this build.
///
/// This is the **binary's** half of the store/binary comparison that
/// [`crate::Store::schema_ahead`] makes: a property of the compiled slice, never
/// of any store.
pub(crate) fn latest_version() -> u32 {
    // The slice is strictly ascending (checked above), so the last is the max.
    match MIGRATIONS.last() {
        Some(m) => m.version,
        None => 0,
    }
}

/// Every migration version recorded as applied in `schema_migrations`.
///
/// A `BTreeSet` rather than a `HashSet`: membership is what [`apply`] needs, but
/// an ordered set also makes [`crate::Store::schema_version`]'s contiguity walk
/// and any debugging dump deterministic, at no cost for a set this small.
fn applied_versions(conn: &Connection) -> rusqlite::Result<BTreeSet<u32>> {
    let mut stmt = conn.prepare("SELECT version FROM schema_migrations")?;
    let rows = stmt.query_map([], |r| r.get::<_, i64>(0))?;
    let mut applied = BTreeSet::new();
    for row in rows {
        // A negative or oversized version cannot match any `u32` migration, so
        // it is simply not in the set — never a panic on a hand-edited store.
        if let Ok(v) = u32::try_from(row?) {
            applied.insert(v);
        }
    }
    Ok(applied)
}

/// Apply every migration **not already recorded** as applied, in ascending
/// version order. Idempotent.
///
/// Selection is by set membership, deliberately *not* `version > MAX(recorded)`
/// — see the module documentation for the failure that rule causes and why no
/// gate could see it. The practical consequence is that a store missing a
/// lower-numbered migration is **repaired** on the next open rather than
/// carrying the gap forever.
///
/// Ordering comes from [`MIGRATIONS`] itself, which is compile-time checked to
/// be strictly ascending; the applied set is only ever consulted for membership,
/// never iterated to drive the work.
pub(crate) fn apply(conn: &mut Connection) -> rusqlite::Result<()> {
    conn.execute_batch(
        "CREATE TABLE IF NOT EXISTS schema_migrations (
            version    INTEGER PRIMARY KEY,
            applied_at TEXT NOT NULL DEFAULT (datetime('now'))
        );",
    )?;
    let applied = applied_versions(conn)?;
    // Iterating MIGRATIONS (ascending) rather than the set keeps ordering a
    // property of the slice; each version appears once, so the set never needs
    // re-reading mid-loop.
    for m in MIGRATIONS {
        if !applied.contains(&m.version) {
            let tx = conn.transaction()?;
            tx.execute_batch(m.sql)?;
            tx.execute(
                "INSERT INTO schema_migrations (version) VALUES (?1)",
                [m.version],
            )?;
            tx.commit()?;
        }
    }
    Ok(())
}

/// The highest version `v` such that every migration `1..=v` is recorded as
/// applied — the schema the store can actually be relied on to have.
///
/// **Not `MAX(version)`.** With gaps possible ([`apply`]), the maximum is
/// precisely the wrong answer: a store recorded as `1..11, 13` has none of
/// migration 12's schema, yet `MAX` would report 13 — a higher number than the
/// truth, and the kind of confident wrong answer this whole area exists to stop.
/// The contiguous prefix reports 11, which is what the store really provides.
///
/// A version *above* this build's newest is still counted when it is contiguous
/// (a `1..=13` store reports 13 to a build that knows 12), because this describes
/// the **store**, not the binary reading it.
fn contiguous_version(applied: &BTreeSet<u32>) -> u32 {
    let mut v = 0;
    while applied.contains(&(v + 1)) {
        v += 1;
    }
    v
}

/// The schema version `conn`'s store provides — see
/// [`crate::Store::schema_version`], which this backs.
///
/// Returns 0 when `schema_migrations` does not exist yet (a database opened
/// outside [`apply`]), rather than erroring: "no migrations applied" is the
/// honest reading of a store with no migration table.
pub(crate) fn store_version(conn: &Connection) -> rusqlite::Result<u32> {
    match applied_versions(conn) {
        Ok(applied) => Ok(contiguous_version(&applied)),
        Err(rusqlite::Error::SqliteFailure(_, Some(ref msg))) if msg.contains("no such table") => {
            Ok(0)
        }
        Err(e) => Err(e),
    }
}

/// Every version recorded in `conn`'s store that this build has **never heard
/// of** — ascending, and empty for any store this build is level with or ahead
/// of. Backs [`crate::Store::schema_ahead`].
///
/// The predicate is set difference against [`MIGRATIONS`], deliberately *not* a
/// comparison against [`store_version`]. Those differ, and only one of them
/// answers the question a write guard is asking:
///
/// - [`store_version`] is the highest **gap-free** version — a floor, the schema
///   a *reader* may rely on. For a store recorded `1..=13, 15` read by a build
///   that knows 13, it reports 13, so a `> store_version` test sees nothing
///   wrong even though migration 15's schema is sitting in the file and a newer
///   build plainly wrote the graph. That is precisely the silent downgrade this
///   exists to stop, surviving the check meant to catch it.
/// - The set difference is a ceiling: *has anything newer than me touched this
///   store?* It reports `[15]`, which is the truth.
///
/// The two situations stay separate, which is why neither message is confusing.
/// A **gap** (a store missing a lower migration this build knows) is repaired by
/// [`apply`] on the very same open, so it never reaches here. What remains can
/// only be a version no build of this vintage could have written.
///
/// Returns an empty list when `schema_migrations` does not exist, matching
/// [`store_version`]: a store with no migration table is behind every build, not
/// ahead of one.
pub(crate) fn versions_ahead_of_build(conn: &Connection) -> rusqlite::Result<Vec<u32>> {
    let latest = latest_version();
    match applied_versions(conn) {
        Ok(applied) => Ok(applied.range(latest.saturating_add(1)..).copied().collect()),
        Err(rusqlite::Error::SqliteFailure(_, Some(ref msg))) if msg.contains("no such table") => {
            Ok(Vec::new())
        }
        Err(e) => Err(e),
    }
}

#[cfg(test)]
mod tests {
    use super::{MIGRATIONS, apply, latest_version};
    use rusqlite::Connection;

    fn recorded_versions(conn: &Connection) -> Vec<u32> {
        let mut stmt = conn
            .prepare("SELECT version FROM schema_migrations ORDER BY version")
            .expect("prepare");
        stmt.query_map([], |r| r.get::<_, u32>(0))
            .expect("query")
            .collect::<Result<Vec<_>, _>>()
            .expect("collect")
    }

    /// Seed a store as a build that knew `skip + 1 ..= through` — but **not**
    /// `skip` — would have left it: every migration except `skip` applied and
    /// recorded, plus a `future` version recorded as though a higher-numbered
    /// migration from another branch had run.
    ///
    /// Written from the *store's* perspective rather than the list's: the
    /// migrations are replayed as SQL against a real database, so this is what
    /// is actually on disk after two branches meet in the wrong order, not a
    /// rearrangement of the code's own data.
    ///
    /// Returns `None` when omitting `skip` leaves a store the remaining
    /// migrations cannot be applied to — migration 2 creates `sync_state`, which
    /// 7 and 12 then `ALTER`, so "everything except 2" is not a state that can
    /// exist. That is the honest boundary of the scenario: a store can only lack
    /// a migration whose *successors it applied* did not depend on it.
    /// `future` records a version this build does *not* carry, for gaps where no
    /// real higher migration exists above `skip`; pass `None` when [`MIGRATIONS`]
    /// already supplies one, which since migration 13 landed it does for the case
    /// that actually matters. It must not name a version in [`MIGRATIONS`] — that
    /// one is applied and recorded by the loop above, and re-recording it would
    /// collide on the primary key.
    fn store_missing_migration(skip: u32, future: Option<u32>) -> Option<Connection> {
        let conn = Connection::open_in_memory().expect("open");
        conn.execute_batch(
            "CREATE TABLE IF NOT EXISTS schema_migrations (
                version    INTEGER PRIMARY KEY,
                applied_at TEXT NOT NULL DEFAULT (datetime('now'))
            );",
        )
        .expect("bootstrap");
        for m in MIGRATIONS.iter().filter(|m| m.version != skip) {
            // A failure here means a later migration depends on the skipped one,
            // so this gap is unreachable rather than untested.
            conn.execute_batch(m.sql).ok()?;
            conn.execute(
                "INSERT INTO schema_migrations (version) VALUES (?1)",
                [m.version],
            )
            .expect("record");
        }
        if let Some(future) = future {
            assert!(
                !MIGRATIONS.iter().any(|m| m.version == future),
                "`future` must be a version this build does not carry; {future} is \
                 in MIGRATIONS and was already recorded above"
            );
            // Another branch's migration: recorded, its SQL unknown to this build.
            conn.execute(
                "INSERT INTO schema_migrations (version) VALUES (?1)",
                [future],
            )
            .expect("record future");
        }
        Some(conn)
    }

    /// Whether `table` has a column named `column`.
    fn has_column(conn: &Connection, table: &str, column: &str) -> bool {
        let mut stmt = conn
            .prepare(&format!("PRAGMA table_info({table})"))
            .expect("prepare");
        stmt.query_map([], |r| r.get::<_, String>(1))
            .expect("query")
            .filter_map(Result::ok)
            .any(|c| c == column)
    }

    /// **The regression.** A store that met a higher-numbered migration from
    /// another branch before a lower-numbered one from this branch must have the
    /// missing migration applied on the next open — not skipped forever.
    ///
    /// Under the old `version > MAX(recorded)` rule this is unrecoverable: the
    /// store is stamped 13, `12 > 13` is false, and migration 12 never runs
    /// again. Reproduced against a real `graph.db`, where it surfaced as `sync`
    /// failing on `no such column: worktree` while the store reported a schema it
    /// did not have. No gate could see it, because CI always starts fresh.
    ///
    /// Both migrations here are **real**: 12 is this branch's tree stamp and 13
    /// is `feat/stage25-memory-recall`'s cache tier, merged into `main` while 12
    /// was still outstanding. Every store a current-`main` build has opened is in
    /// exactly this state, so nothing about the scenario is simulated.
    #[test]
    fn a_migration_skipped_below_a_higher_one_is_still_applied() {
        // Migration 12 added `sync_state.worktree` (the issue #330 tree stamp).
        // No synthetic `future` is needed: MIGRATIONS itself now carries 13,
        // which the seed applies and records while leaving 12 out.
        let skipped = 12;
        let higher = 13;
        let mut conn = store_missing_migration(skipped, None).expect("12 is omissible");

        // Precondition: exactly the damaged state, and the column really is gone.
        assert!(
            !recorded_versions(&conn).contains(&skipped),
            "seeded store must be missing migration {skipped}"
        );
        assert!(
            recorded_versions(&conn).contains(&higher),
            "seeded store must carry the other branch's higher version"
        );
        assert!(
            !has_column(&conn, "sync_state", "worktree"),
            "the skipped migration's column must be absent to begin with"
        );

        apply(&mut conn).expect("apply must repair the gap");

        // The missing migration ran…
        assert!(
            recorded_versions(&conn).contains(&skipped),
            "migration {skipped} must be recorded after the repair, not skipped \
             forever because a higher version was already stamped"
        );
        // …and its schema is really there, which is what the caller depends on.
        assert!(
            has_column(&conn, "sync_state", "worktree"),
            "the repaired migration's column must exist — a recorded version \
             without its schema is the same silent wrong answer in a new costume"
        );
        // The other branch's migration is preserved, never re-run or discarded —
        // and its tables are intact, clock row and all, so the repair healed the
        // gap without disturbing what stage25 put there.
        assert!(
            recorded_versions(&conn).contains(&higher),
            "another branch's recorded migration must survive the repair"
        );
        let clock: (i64, i64) = conn
            .query_row(
                "SELECT ticks, generation FROM agent_cache_clock WHERE id = 0",
                [],
                |r| Ok((r.get(0)?, r.get(1)?)),
            )
            .expect("migration 13's seeded clock row must survive");
        assert_eq!(clock, (0, 0), "the seeded clock row is untouched");
        // Repairing twice changes nothing.
        let after = recorded_versions(&conn);
        apply(&mut conn).expect("second apply");
        assert_eq!(after, recorded_versions(&conn), "repair is idempotent");
    }

    /// The repair is not special-cased to the newest migration: **every** gap
    /// that a store can actually hold is repaired, wherever it sits. Which
    /// version is missing depends only on which branch a store met first, so
    /// nothing may depend on it being the last one.
    ///
    /// Gaps the schema makes unreachable (a migration its successors `ALTER`)
    /// are skipped rather than asserted, and the count of real cases is checked
    /// so this cannot quietly degrade into a test that exercises nothing.
    #[test]
    fn every_reachable_gap_is_repaired_wherever_it_sits() {
        let mut repaired = 0;
        for m in MIGRATIONS {
            let Some(mut conn) = store_missing_migration(m.version, Some(latest_version() + 1))
            else {
                continue; // a later migration depends on this one
            };
            apply(&mut conn).unwrap_or_else(|e| panic!("repair {}: {e}", m.version));
            assert!(
                recorded_versions(&conn).contains(&m.version),
                "migration {} must be repaired, not skipped because a higher \
                 version was already recorded",
                m.version
            );
            repaired += 1;
        }
        assert!(
            repaired >= 2,
            "expected several omissible migrations, exercised {repaired}"
        );
    }

    /// `schema_version()` reports the highest **gap-free** version, so it cannot
    /// claim a schema the store does not have while a gap exists.
    #[test]
    fn the_reported_version_stops_below_a_gap_rather_than_overstating_it() {
        let conn = store_missing_migration(12, None).expect("12 is omissible");
        assert_eq!(
            super::store_version(&conn).expect("version"),
            11,
            "with 12 missing, the store provides 11 — reporting 13 (the maximum \
             recorded) would name a schema that is not there"
        );

        // Once repaired, it reports the full contiguous run including the other
        // branch's version: this describes the store, not the binary.
        let mut conn = conn;
        apply(&mut conn).expect("repair");
        assert_eq!(
            super::store_version(&conn).expect("version"),
            13,
            "1..=13 contiguous after the repair"
        );

        // A store with nothing recorded is version 0, not an error.
        let empty = Connection::open_in_memory().expect("open");
        empty
            .execute_batch(
                "CREATE TABLE schema_migrations (
                    version INTEGER PRIMARY KEY,
                    applied_at TEXT NOT NULL DEFAULT (datetime('now')));",
            )
            .expect("bootstrap");
        assert_eq!(super::store_version(&empty).expect("version"), 0);

        // So is a database that has never been through `apply` at all.
        let bare = Connection::open_in_memory().expect("open");
        assert_eq!(
            super::store_version(&bare).expect("version"),
            0,
            "no migration table reads as `no migrations applied`, not an error"
        );
    }

    /// `MIGRATIONS` is strictly ascending with no duplicates. The build already
    /// enforces this (`const _`), so this test documents the invariant and keeps
    /// it visible in the suite — `apply` inherits its ordering from the slice.
    #[test]
    fn migrations_are_strictly_ascending_and_unique() {
        let versions: Vec<u32> = MIGRATIONS.iter().map(|m| m.version).collect();
        let mut sorted = versions.clone();
        sorted.sort_unstable();
        sorted.dedup();
        assert_eq!(versions, sorted, "must be ascending with no duplicates");
        assert_eq!(
            versions.first().copied(),
            Some(1),
            "versions start at 1, which `schema_version`'s contiguity walk assumes"
        );
    }

    #[test]
    fn apply_is_idempotent() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("first apply");
        let after_first = recorded_versions(&conn);
        apply(&mut conn).expect("second apply");
        let after_second = recorded_versions(&conn);

        assert_eq!(after_first, after_second, "re-applying must not add rows");
        assert_eq!(
            after_second.last().copied(),
            Some(latest_version()),
            "schema should be at the latest version"
        );
    }

    /// An existing store must gain the newest migration's tables without
    /// disturbing what it already holds. Migration discipline is append-only, so
    /// this is the shape every future migration has to satisfy: apply the
    /// previously shipped set, put data in, apply the rest, and find the data
    /// untouched.
    ///
    /// Written against [`latest_version`] rather than a hard-coded number, so the
    /// next migration is covered by this test the moment it is appended instead of
    /// leaving the newest one — the only untested one — unchecked.
    #[test]
    fn a_later_migration_is_additive_on_a_populated_store() {
        let mut conn = Connection::open_in_memory().expect("open");
        conn.execute_batch(
            "CREATE TABLE IF NOT EXISTS schema_migrations (
                version    INTEGER PRIMARY KEY,
                applied_at TEXT NOT NULL DEFAULT (datetime('now'))
            );",
        )
        .expect("bootstrap");
        for m in MIGRATIONS
            .iter()
            .take_while(|m| m.version < latest_version())
        {
            conn.execute_batch(m.sql).expect("legacy migration");
            conn.execute(
                "INSERT INTO schema_migrations (version) VALUES (?1)",
                [m.version],
            )
            .expect("record");
        }
        conn.execute(
            "INSERT INTO nodes (key, kind, name) VALUES ('sym:rust:a.rs#main', 'fn', 'main')",
            [],
        )
        .expect("seed node");

        apply(&mut conn).expect("upgrade");

        assert_eq!(
            recorded_versions(&conn).last().copied(),
            Some(latest_version())
        );
        let nodes: i64 = conn
            .query_row("SELECT COUNT(*) FROM nodes", [], |r| r.get(0))
            .expect("count");
        assert_eq!(nodes, 1, "an upgrade must not disturb existing rows");
        for table in ["findings", "media_content", "agent_memory"] {
            let rows: i64 = conn
                .query_row(&format!("SELECT COUNT(*) FROM {table}"), [], |r| r.get(0))
                .expect("count");
            assert_eq!(rows, 0, "{table} starts empty");
        }
    }

    /// Insert one `media_content` row with the given outcome columns, returning
    /// whether `SQLite` accepted it. `blob` keys the row, so each attempt needs
    /// its own (the table is UNIQUE on `(blob_id, producer)`).
    fn insert_outcome(
        conn: &Connection,
        blob: &str,
        text: &str,
        skip_reason: Option<&str>,
        skip_value: Option<f64>,
        skip_threshold: Option<f64>,
    ) -> bool {
        conn.execute(
            "INSERT INTO media_content (
                 blob_id, path, kind, producer, model, model_digest, quantisation,
                 mmproj_digest, prompt, temperature, max_tokens, tool_version, generation,
                 text, skip_reason, skip_value, skip_threshold
             ) VALUES (
                 ?1, 'assets/clip.wav', 'audio', 'media:audio:m:0', 'm', 'd', 'Q4_K_M',
                 'p', 'prompt', 0.0, 512, '9.9.9', 1, ?2, ?3, ?4, ?5
             )",
            rusqlite::params![blob, text, skip_reason, skip_value, skip_threshold],
        )
        .is_ok()
    }

    /// **The outcome constraint has to bite.** A `media_content` row is either a
    /// generated description or a recorded gate refusal, and migration 10 exists
    /// to make anything between the two unrepresentable *in the schema* — not
    /// only in the Rust type that writes it today.
    ///
    /// The case that motivated tightening it is the first rejection below: a row
    /// with a measurement but **no reason**. `skip_reason` is the discriminant
    /// the decoder reads, so such a row comes back as generated content that
    /// happens to be empty — a silent lie of exactly the kind ADR-0015 exists to
    /// stop, arrived at through a `NULL` rather than through any code path.
    #[test]
    fn the_media_outcome_constraint_admits_only_the_two_real_outcomes() {
        /// `(name, text, reason, value, threshold)` for a shape that must be
        /// refused.
        type Rejected = (
            &'static str,
            &'static str,
            Option<&'static str>,
            Option<f64>,
            Option<f64>,
        );

        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");

        // The two legitimate shapes insert.
        assert!(
            insert_outcome(&conn, "blob-generated", "a transcript", None, None, None),
            "a generated record carries text and no measurement",
        );
        assert!(
            insert_outcome(
                &conn,
                "blob-skipped",
                "",
                Some("silence"),
                Some(0.0),
                Some(1e-4)
            ),
            "a gated skip carries a complete measurement and no text",
        );

        let rejected: [Rejected; 6] = [
            // The hole this test was written for: a measurement with no reason
            // reads back as an empty *generated* record.
            (
                "value-and-threshold-but-no-reason",
                "",
                None,
                Some(0.0),
                Some(1e-4),
            ),
            (
                "reason-with-no-value",
                "",
                Some("silence"),
                None,
                Some(1e-4),
            ),
            (
                "reason-with-no-threshold",
                "",
                Some("silence"),
                Some(0.0),
                None,
            ),
            ("value-alone", "", None, Some(0.0), None),
            ("threshold-alone", "", None, None, Some(1e-4)),
            // A skip that also claims text: the other half of the exclusion.
            (
                "a-skip-that-also-has-text",
                "a transcript",
                Some("silence"),
                Some(0.0),
                Some(1e-4),
            ),
        ];
        for (name, text, reason, value, threshold) in rejected {
            assert!(
                !insert_outcome(&conn, name, text, reason, value, threshold),
                "`{name}` must be rejected by the outcome CHECK, not stored",
            );
        }

        // Only the two accepted rows are there.
        let stored: i64 = conn
            .query_row("SELECT COUNT(*) FROM media_content", [], |r| r.get(0))
            .expect("count");
        assert_eq!(stored, 2, "no refused shape may have slipped through");
    }

    /// ADR-0015 adds an artifact store, **not** a provenance class. The three
    /// tokens `nodes`/`edges` accept are a published contract, and migration 9
    /// must leave them exactly as migration 1 and 6 defined them — so the check
    /// is that the constraints still bite, on a store at the latest version.
    #[test]
    fn the_media_migration_leaves_the_provenance_vocabulary_alone() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");

        // The three legitimate node provenances still insert…
        for provenance in ["derived", "authored", "inferred"] {
            conn.execute(
                "INSERT INTO nodes (key, kind, name, provenance) VALUES (?1, 'fn', 'n', ?2)",
                [provenance, provenance],
            )
            .unwrap_or_else(|e| panic!("{provenance} must remain a valid node provenance: {e}"));
        }
        // …and nothing else does, on either table. A `generated` provenance is
        // precisely the thing this ADR declined to add.
        for rejected in ["generated", "media", ""] {
            assert!(
                conn.execute(
                    "INSERT INTO nodes (key, kind, name, provenance) VALUES (?1, 'fn', 'n', ?2)",
                    [&format!("bad-{rejected}"), rejected],
                )
                .is_err(),
                "{rejected:?} must not be an accepted node provenance"
            );
            assert!(
                conn.execute(
                    "INSERT INTO edges (src, dst, kind, provenance) VALUES (1, 1, 'calls', ?1)",
                    [rejected],
                )
                .is_err(),
                "{rejected:?} must not be an accepted edge provenance"
            );
        }

        // And the media table has no provenance column to borrow one from.
        let columns: Vec<String> = {
            let mut stmt = conn
                .prepare("SELECT name FROM pragma_table_info('media_content')")
                .expect("prepare");
            stmt.query_map([], |r| r.get::<_, String>(0))
                .expect("query")
                .collect::<Result<_, _>>()
                .expect("collect")
        };
        assert!(
            !columns.iter().any(|c| c == "provenance"),
            "generated content must not carry a provenance class: {columns:?}"
        );
    }

    /// `(blob, producer)` is the identity, and the schema — not just the Rust —
    /// enforces it: the same blob described by a *different* producer is a second
    /// row, while the same producer twice is refused outright.
    #[test]
    fn media_content_is_unique_per_blob_and_producer() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let insert = |producer: &str, kind: &str| {
            conn.execute(
                "INSERT INTO media_content (
                     blob_id, path, kind, producer, model, model_digest, quantisation,
                     mmproj_digest, prompt, temperature, max_tokens, tool_version, generation, text
                 ) VALUES ('blob1', 'a.wav', ?2, ?1, 'm', 'd', 'Q4', 'p', 'say', 0.0, 8, '1.0', 1, 't')",
                [producer, kind],
            )
        };
        assert!(insert("media:audio:m:1", "audio").is_ok());
        assert!(
            insert("media:audio:m:1", "audio").is_err(),
            "the same producer must not describe one blob twice"
        );
        assert!(
            insert("media:audio:m:2", "audio").is_ok(),
            "a different producer is a new record, not a mutation"
        );
        assert!(
            insert("media:vision:m:3", "ocr").is_err(),
            "`ocr` is not a generative modality and has no token"
        );
    }

    /// The `analysis_runs` CHECK constraints are the last line of defence for the
    /// stored vocabulary: a runner kind or isolation label outside the known set
    /// is a corrupt write, not a new feature.
    #[test]
    fn findings_schema_rejects_unknown_runner_and_isolation_tokens() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let insert = |runner: &str, isolation: &str| {
            conn.execute(
                "INSERT INTO analysis_runs (
                     layer, analyzer, analyzer_version, runner, isolation, command_policy,
                     started_at, ended_at, exit_status, report_digest
                 ) VALUES ('security:a:b', 'a', '1', ?1, ?2, '{}', 's', 'e', 0, 'd')",
                [runner, isolation],
            )
        };
        assert!(insert("ingested", "ingested").is_ok());
        assert!(insert("teleported", "ingested").is_err());
        assert!(insert("ingested", "airgapped").is_err());
    }

    /// Insert one `agent_memory` row with the given columns, returning whether
    /// `SQLite` accepted it.
    fn insert_memory(conn: &Connection, scope: &str, kind: &str, body: &str) -> bool {
        conn.execute(
            "INSERT INTO agent_memory (scope, kind, body) VALUES (?1, ?2, ?3)",
            [scope, kind, body],
        )
        .is_ok()
    }

    /// **The stored vocabulary has to bite.** A memory `kind` outside the five
    /// ADR-0013 names is a corrupt write, not a new feature — the same rule the
    /// `analysis_runs` runner/isolation tokens live under. An empty scope or body
    /// is likewise refused: a memory that records nothing can never be recalled,
    /// and storing it would only make `memory list` lie about how much is there.
    #[test]
    fn agent_memory_constrains_its_vocabulary_scope_and_body() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");

        for kind in ["lesson", "attempt", "decision", "pattern", "outcome"] {
            assert!(
                insert_memory(&conn, "repo", kind, "a body"),
                "`{kind}` must remain a valid memory kind",
            );
        }
        for kind in ["note", "Lesson", "lessons", "derived", ""] {
            assert!(
                !insert_memory(&conn, "repo", kind, "a body"),
                "{kind:?} must not be an accepted memory kind",
            );
        }
        assert!(!insert_memory(&conn, "", "lesson", "a body"), "empty scope");
        assert!(!insert_memory(&conn, "repo", "lesson", ""), "empty body");

        // A self-reported confidence is a probability, and is not the score an
        // `inferred` edge carries.
        let with_confidence = |c: f64| {
            conn.execute(
                "INSERT INTO agent_memory (scope, kind, body, confidence)
                 VALUES ('repo', 'lesson', 'b', ?1)",
                [c],
            )
            .is_ok()
        };
        assert!(with_confidence(0.0) && with_confidence(1.0));
        assert!(!with_confidence(-0.1) && !with_confidence(1.1));
    }

    /// **Supersession is recorded, never inferred** — so the successor and the
    /// moment it happened stand or fall together, and nothing supersedes itself.
    /// A row with a `superseded_at` and no `superseded_by` would be a record
    /// dropped out of live listing with no auditable reason, which is exactly the
    /// state ADR-0013 exists to rule out.
    #[test]
    fn agent_memory_supersession_columns_stand_or_fall_together() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        assert!(insert_memory(&conn, "repo", "lesson", "the old finding"));
        assert!(insert_memory(&conn, "repo", "lesson", "the new finding"));

        let update = |by: Option<i64>, at: Option<&str>| {
            conn.execute(
                "UPDATE agent_memory SET superseded_by = ?1, superseded_at = ?2 WHERE id = 1",
                rusqlite::params![by, at],
            )
            .is_ok()
        };
        assert!(!update(Some(2), None), "a successor with no moment");
        assert!(
            !update(None, Some("2026-01-01")),
            "a moment with no successor"
        );
        assert!(!update(Some(1), Some("2026-01-01")), "self-supersession");
        assert!(
            update(Some(2), Some("2026-01-01")),
            "the one legitimate shape"
        );
        assert!(
            update(None, None),
            "and clearing it again is legitimate too"
        );
    }

    /// Anchor evidence with no anchor key names nothing and can never be checked
    /// for drift, so the schema refuses it outright.
    #[test]
    fn agent_memory_refuses_anchor_evidence_without_a_key() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let insert = |key: Option<&str>, blob: Option<&str>, path: Option<&str>| {
            conn.execute(
                "INSERT INTO agent_memory (scope, kind, body, anchor_key, anchor_blob, anchor_path)
                 VALUES ('repo', 'lesson', 'b', ?1, ?2, ?3)",
                rusqlite::params![key, blob, path],
            )
            .is_ok()
        };
        assert!(
            insert(None, None, None),
            "an unanchored memory is legitimate"
        );
        assert!(insert(Some("sym:rust:a.rs#f"), Some("blob1"), Some("a.rs")));
        assert!(!insert(None, Some("blob1"), None), "a blob naming no node");
        assert!(!insert(None, None, Some("a.rs")), "a path naming no node");
    }

    /// **`AUTOINCREMENT` is not decoration.** `id` is the monotonic generation
    /// ADR-0013 ranks on instead of a clock, and a plain `INTEGER PRIMARY KEY`
    /// would reuse the largest deleted rowid — so forgetting the newest record
    /// would hand its number straight to the next write. That breaks monotonicity
    /// *and* silently re-points any surviving `superseded_by` at an unrelated
    /// record. This is the test that would fail if the keyword were ever dropped.
    #[test]
    fn agent_memory_ids_are_never_reused_after_a_delete() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        assert!(insert_memory(&conn, "repo", "lesson", "first"));
        assert!(insert_memory(&conn, "repo", "lesson", "second"));
        conn.execute("DELETE FROM agent_memory WHERE id = 2", [])
            .expect("delete the newest");
        assert!(insert_memory(&conn, "repo", "lesson", "third"));

        let id: i64 = conn
            .query_row(
                "SELECT id FROM agent_memory WHERE body = 'third'",
                [],
                |r| r.get(0),
            )
            .expect("query");
        assert_eq!(id, 3, "a forgotten id must never be handed out again");
    }

    /// ADR-0013 adds an artifact store, **not** a provenance class. Memory has no
    /// source blob and was not written into a reviewed file, so it is neither
    /// `derived` nor `authored` — and the way to keep that true is for the table
    /// to have no provenance column to borrow one from, while the three tokens
    /// `nodes`/`edges` accept stay exactly as migrations 1 and 6 defined them.
    #[test]
    fn the_memory_migration_leaves_the_provenance_vocabulary_alone() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");

        for provenance in ["derived", "authored", "inferred"] {
            conn.execute(
                "INSERT INTO nodes (key, kind, name, provenance) VALUES (?1, 'fn', 'n', ?2)",
                [provenance, provenance],
            )
            .unwrap_or_else(|e| panic!("{provenance} must remain a valid node provenance: {e}"));
        }
        for rejected in ["memory", "episodic", "remembered", ""] {
            assert!(
                conn.execute(
                    "INSERT INTO nodes (key, kind, name, provenance) VALUES (?1, 'fn', 'n', ?2)",
                    [&format!("bad-{rejected}"), rejected],
                )
                .is_err(),
                "{rejected:?} must not be an accepted node provenance"
            );
            assert!(
                conn.execute(
                    "INSERT INTO edges (src, dst, kind, provenance) VALUES (1, 1, 'calls', ?1)",
                    [rejected],
                )
                .is_err(),
                "{rejected:?} must not be an accepted edge provenance"
            );
        }

        let columns: Vec<String> = {
            let mut stmt = conn
                .prepare("SELECT name FROM pragma_table_info('agent_memory')")
                .expect("prepare");
            stmt.query_map([], |r| r.get::<_, String>(0))
                .expect("query")
                .collect::<Result<_, _>>()
                .expect("collect")
        };
        assert!(
            !columns.iter().any(|c| c == "provenance"),
            "a memory record must not carry a provenance class: {columns:?}"
        );
        assert!(
            !columns.iter().any(|c| c.starts_with("span")),
            "a span is byte offsets, not an anchor: {columns:?}"
        );
    }

    #[test]
    fn apply_creates_core_tables() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        for table in [
            "nodes",
            "edges",
            "imports",
            "analysis_runs",
            "findings",
            "media_content",
            "agent_memory",
            "agent_cache",
            "agent_cache_clock",
            "schema_migrations",
        ] {
            let count: i64 = conn
                .query_row(
                    "SELECT count(*) FROM sqlite_master WHERE type = 'table' AND name = ?1",
                    [table],
                    |r| r.get(0),
                )
                .expect("query");
            assert_eq!(count, 1, "table {table} should exist");
        }
    }

    /// **Every migration has its own version, and the list is in order.**
    ///
    /// This exists because of the one failure mode append-only numbering has that
    /// the tooling cannot catch: two branches each append a migration, each picks
    /// the same next number, and the two constants **merge cleanly in git** — they
    /// touch different lines of a growing array and different lines of the file.
    /// Nothing goes red. The breakage arrives later, at runtime, on whichever store
    /// applies them second, because `apply` records `version` as a primary key and
    /// the second insert violates it. Migration 13 was migration 12 for exactly one
    /// day, for exactly this reason.
    ///
    /// Ascending order is checked too. `apply` reads the recorded version **once**
    /// and then walks the array, so an out-of-order entry is applied out of order —
    /// harmless while migrations are independent, and silently wrong the first time
    /// one depends on an earlier one. A merge that interleaves two branches'
    /// appends can produce exactly that, so it is worth a test rather than a habit.
    ///
    /// Gaps are **not** checked, and are legitimate: a number can be claimed by a
    /// branch that never merges.
    #[test]
    fn migration_versions_are_unique_and_ascending() {
        let versions: Vec<u32> = MIGRATIONS.iter().map(|m| m.version).collect();
        let mut sorted = versions.clone();
        sorted.sort_unstable();
        sorted.dedup();
        assert_eq!(
            versions.len(),
            sorted.len(),
            "two migrations share a version — which is exactly what a same-number \
             collision between two branches looks like after a clean merge: {versions:?}",
        );
        assert_eq!(
            versions, sorted,
            "the migration list is out of order, so `apply` would run them out of \
             order: {versions:?}",
        );
        assert!(
            versions.first().is_some_and(|&v| v >= 1),
            "version 0 is the `nothing applied yet` sentinel and cannot be a migration",
        );
    }

    /// The cache tier refuses the same half-states the episodic tier does: a
    /// negative size or counter is a corrupt write, not a small one, and anchor
    /// evidence with no anchor key names nothing that could ever be checked for
    /// drift — which is the `anchor_valid` half of the eviction order.
    #[test]
    fn agent_cache_refuses_negative_counters_and_orphan_anchor_evidence() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let insert = |key: &str, bytes: i64, generation: i64, last_used: i64, hits: i64| {
            conn.execute(
                "INSERT INTO agent_cache (key, fingerprint, json, bytes, generation, last_used, hits)
                 VALUES (?1, 'fp', '{}', ?2, ?3, ?4, ?5)",
                rusqlite::params![key, bytes, generation, last_used, hits],
            )
            .is_ok()
        };
        assert!(insert("ok", 0, 0, 0, 0), "a zero-size entry is legitimate");
        assert!(!insert("", 1, 0, 0, 0), "an empty key names nothing");
        assert!(!insert("neg-bytes", -1, 0, 0, 0));
        assert!(!insert("neg-gen", 1, -1, 0, 0));
        assert!(!insert("neg-used", 1, 0, -1, 0));
        assert!(!insert("neg-hits", 1, 0, 0, -1));

        let anchored = |key: &str, anchor: Option<&str>, blob: Option<&str>| {
            conn.execute(
                "INSERT INTO agent_cache
                     (key, fingerprint, json, bytes, generation, last_used, anchor_key, anchor_blob)
                 VALUES (?1, 'fp', '{}', 1, 0, 0, ?2, ?3)",
                rusqlite::params![key, anchor, blob],
            )
            .is_ok()
        };
        assert!(anchored("unanchored", None, None));
        assert!(anchored("anchored", Some("sym:rust:a.rs#f"), Some("blob1")));
        assert!(
            !anchored("orphan-blob", None, Some("blob1")),
            "a blob naming no node",
        );
    }

    /// The logical clock is a **single row**, on `sync_state`'s precedent, and the
    /// migration seeds it — so the first cache write finds a counter to draw from
    /// rather than having to create one. Nothing here is a wall-clock: ADR-0013 §3
    /// rules that out, because the store is shared across worktrees.
    #[test]
    fn the_cache_clock_is_a_single_seeded_row() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let (ticks, generation): (i64, i64) = conn
            .query_row(
                "SELECT ticks, generation FROM agent_cache_clock WHERE id = 0",
                [],
                |r| Ok((r.get(0)?, r.get(1)?)),
            )
            .expect("the migration seeds the clock");
        assert_eq!((ticks, generation), (0, 0));
        assert!(
            conn.execute("INSERT INTO agent_cache_clock (id) VALUES (1)", [])
                .is_err(),
            "there is exactly one clock",
        );
    }

    /// The two tiers are **separate tables with opposite rules**, which is the
    /// whole design: bounding episodic memory would be data loss, and leaving the
    /// cache unbounded is the growth ADR-0013 exists to stop. This pins the split
    /// at the schema level — the cache carries the eviction signal, and the
    /// episodic table carries none of it, so no sweep written against those column
    /// names can reach `agent_memory` even by mistake.
    #[test]
    fn only_the_cache_tier_carries_the_eviction_signal() {
        let mut conn = Connection::open_in_memory().expect("open");
        apply(&mut conn).expect("apply");
        let columns = |table: &str| -> Vec<String> {
            let mut stmt = conn
                .prepare(&format!("SELECT name FROM pragma_table_info('{table}')"))
                .expect("prepare");
            stmt.query_map([], |r| r.get::<_, String>(0))
                .expect("query")
                .collect::<Result<Vec<_>, _>>()
                .expect("collect")
        };
        let cache = columns("agent_cache");
        let memory = columns("agent_memory");
        for signal in ["bytes", "generation", "last_used", "hits"] {
            assert!(
                cache.iter().any(|c| c == signal),
                "the cache tier carries {signal}",
            );
            assert!(
                !memory.iter().any(|c| c == signal),
                "{signal} must not exist on the episodic tier: nothing sweeps it",
            );
        }
    }
}