Merge remote-tracking branch 'origin/main' into claude/smb-contract-traits

# Conflicts:
#	.claude/board/AGENT_LOG.md
#	.claude/board/EPIPHANIES.md
#	Cargo.toml

Author: claude

.claude/board/AGENT_LOG.md

@@ -250,3 +250,18 @@ newest-first.** A `BlackboardEntry` by any other transport.
 **Commits:** `5e00049` (AGENT_LOG created) → `c0eda21` (blackboard protocol) → `13c1f19` (three-layer docs) → current
 **Tests:** 209 contract + 14 RBAC = 223 pass
 **Outcome:** Documented three coordination layers (Teleport / File Blackboard / Branch Pub-Sub). Added `cat >>` heredoc as canonical append pattern. Permissions opened for `cat >> AGENT_LOG.md`, `git push/fetch/pull`, `cargo test/check`. RBAC crate shipped (permission × role × policy × access). Ontology layer shipped (LinkSpec, PrefetchDepth, ActionSpec, ModelBinding, ModelHealth, SimulationSpec).
+
+
+## 2026-04-24T16:30 — Supabase subscriber v2 (sonnet, claude/supabase-subscriber-wire-up)
+
+**D-ids:** DM-4a/b/c, DM-6a/b
+**Commit:** `ec3b5c7`
+**Tests:** 17 pass with realtime feature (13 without); 5 new tests total
+**Outcome:** Wired LanceMembrane::subscribe() from Phase-A disconnected mpsc stub to live tokio::sync::watch::Receiver<CognitiveEventRow> under [realtime] feature. PR #255 merged.
+
+## 2026-04-24T16:30 — Archetype scaffold v2 (sonnet, claude/archetype-crate-scaffold)
+
+**D-ids:** DU-2.1..2.6
+**Commit:** `816a7c0`
+**Tests:** 12 pass
+**Outcome:** Shipped `lance-graph-archetype` crate scaffold: Component + Processor traits, World meta-state with tick/fork/at_tick stubs, CommandBroker FIFO queue, ArchetypeError. PR #254 merged.

.claude/board/EPIPHANIES.md

@@ -76,6 +76,12 @@ The bardioc Required/Optional/Free property concept maps 1:1 to the I1 Codec Reg
 Cross-ref: `contract::property` (PropertyKind, PropertySpec, Schema, SchemaBuilder), `contract::cam::CodecRoute`, smb-office-rs `lance-graph-contract-proposal.md`.
 
 
+## 2026-04-24 — FINDING: subscribe() wired; LanceVersionWatcher delivers always-latest CognitiveEventRow to subscribers (DM-4/6)
+
+`LanceMembrane::subscribe()` now returns a `tokio::sync::watch::Receiver<CognitiveEventRow>` under the `[realtime]` feature gate — supabase-shape always-latest semantics. `project()` calls `watcher.bump(row)` after building the scalar row; subscribers observe the latest committed event without polling. `DrainTask` scaffold ships unconditionally (no feature gate) as a `Future` shell for the follow-up `steering_intent` drain loop. Tokio was already an optional dep in `lance-graph-callcenter/Cargo.toml` under `[realtime]` — no new deps required.
+
+**Status:** FINDING
+
 ## 2026-04-24 — Vsa16kF32 switchboard carrier shipped (CrystalFingerprint::Vsa16kF32 + 16K algebra)
 
 **Status:** FINDING

.claude/board/INTEGRATION_PLANS.md

@@ -36,6 +36,19 @@
 
 ---
 
+## v1 — Supabase Subscriber Wire-up (authored 2026-04-24)
+
+**Author:** sonnet agent, session 2026-04-24 (branch claude/supabase-subscriber-wire-up)
+**Scope:** Flip `LanceMembrane::subscribe()` from Phase-A stub to a live `tokio::sync::watch::Receiver<CognitiveEventRow>` wired to `LanceVersionWatcher`; ship `DrainTask` scaffold.
+**Path:** `.claude/plans/supabase-subscriber-v1.md`
+**Deliverables:** DM-4a swap Subscription type, DM-4b `version_watcher.rs`, DM-4c uncomment `pub mod version_watcher`, DM-6a `drain.rs` scaffold, DM-6b uncomment `pub mod drain`.
+
+**Status (2026-04-24):** In PR. All deliverables in branch `claude/supabase-subscriber-wire-up`.
+
+**Confidence (2026-04-24):** FINDING — 17 tests pass (13 without realtime, 17 with; 4 new tests in `version_watcher.rs`, 1 new `subscribe_receives_on_project` in `lance_membrane.rs`). Zero regressions.
+
+---
+
 ## v1 — Unified Integration: PersonaHub × ONNX × Archetype × MM-CoT × RoleDB (authored 2026-04-23)
 
 **Author:** main-thread session 2026-04-23

.claude/board/STATUS_BOARD.md

@@ -272,9 +272,9 @@ pattern IS the Supabase-shape transcode approach).
 |---|---|---|---|
 | DM-2 | `LanceMembrane: ExternalMembrane` impl with `project()` + compile-time BBB leak test | **In progress** | Phase A shipped `9a8d6a0` — `LanceMembrane` struct + `project()` + `ingest()` + `subscribe()` stub. Phase B: full Lance append + version counter pending DM-4. |
 | DM-3 | `CommitFilter` → DataFusion `Expr` translator (`[query]` feature) | **Queued** | — |
-| DM-4 | `LanceVersionWatcher` — tails Lance version counter, emits Phoenix `postgres_changes` (`[realtime]`) | **Queued** | — |
+| DM-4 | `LanceVersionWatcher` — tails Lance version counter, emits Phoenix `postgres_changes` (`[realtime]`) | **In PR** | branch `claude/supabase-subscriber-wire-up` — DM-4a/b/c: `version_watcher.rs` (117 LOC, 4 tests), `lib.rs` `pub mod version_watcher`, `LanceMembrane::watcher` field + `project()` calls `bump()`, `subscribe()` returns `watch::Receiver<CognitiveEventRow>`. |
 | DM-5 | `PhoenixServer` — minimal WS server, Phoenix channel subset (`[realtime]`) | **Queued** | Resolve UNKNOWN-2 (which consumers need Phoenix wire?) first |
-| DM-6 | `DrainTask` — `steering_intent` Lance read → `UnifiedStep` → `OrchestrationBridge::route()` | **Queued** | — |
+| DM-6 | `DrainTask` — `steering_intent` Lance read → `UnifiedStep` → `OrchestrationBridge::route()` | **In PR** | branch `claude/supabase-subscriber-wire-up` — DM-6a/b scaffold: `drain.rs` (89 LOC, 2 tests), `lib.rs` `pub mod drain`, `Poll::Pending` until follow-up PR wires real drain loop. |
 | DM-7 | `JwtMiddleware` + `ActorContext` → `LogicalPlan` RLS rewriter (`[auth]`) | **Queued** | Resolve UNKNOWN-3 (pgwire?) + UNKNOWN-4 (actor_id type) first |
 | DM-8 | `PostgRestHandler` — query-string → DataFusion SQL → Lance scan → Arrow response (`[serve]`) | **Queued** | Confirm PostgREST compat needed (§ 8 stop point 4) before building |
 | DM-9 | End-to-end test: shader fires → `LanceMembrane::project()` → Lance append → Phoenix subscriber receives event | **Queued** | Depends on DM-2 through DM-6 |

.claude/plans/archetype-scaffold-v1.md

@@ -0,0 +1,90 @@
+# Archetype Transcode Crate Scaffold — v1
+
+> **Status:** In progress (2026-04-24)
+> **Owner:** @archetype-specialist, @truth-architect
+> **Scope:** NEW crate `crates/lance-graph-archetype/`; deps only on `lance-graph-contract`, `arrow`, `lance` (peer-dep, optional).
+> **Depends on:** ADR-0001 Decision 1 (transcode-not-bridge). No runtime dependency on upstream Python.
+
+## Goal
+
+Flip `lance-graph-archetype` from "does-not-exist" to "scaffolded-and-locked." Ship the 6 foundational trait/struct files per ADR-0001 Decision 1. No runtime behaviour yet — this is the LOCKED-MAPPING-INCOMPLETE → LOCKED-AND-SCAFFOLDED pivot.
+
+## Deliverables
+
+- **DU-2.1** — `crates/lance-graph-archetype/Cargo.toml` + `src/lib.rs` + workspace `members` entry in root `Cargo.toml`.
+- **DU-2.2** — `src/component.rs: pub trait Component { fn arrow_field() -> arrow::datatypes::Field; fn type_id() -> &'static str; }` plus a test-only `MockComponent` impl asserting trait-object construction.
+- **DU-2.3** — `src/processor.rs: pub trait Processor { fn matches(schema: &arrow::datatypes::Schema) -> bool; fn process(batch: arrow::record_batch::RecordBatch) -> Result<arrow::record_batch::RecordBatch, ArchetypeError>; }`.
+- **DU-2.4** — `src/world.rs: pub struct World { tick: u64, dataset_uri: String }` with `new() / tick() / current_tick() / fork(&self, branch: &str) / at_tick(&self, tick: u64)` methods. `fork()` and `at_tick()` return `Err(ArchetypeError::Unimplemented { method: "..." })` stubs — docstrings tie to ADR-0001:61-72 / 95.
+- **DU-2.5** — `src/command_broker.rs: pub struct CommandBroker { queue: Vec<Command>, ... }` + `pub enum Command { Spawn, Despawn, Update }` — channel-based drain interface with `submit() / drain()` method stubs.
+- **DU-2.6** — `src/error.rs: pub enum ArchetypeError { Unimplemented { method: &'static str }, SchemaMismatch { ... }, LanceIo(...) }` with `thiserror::Error` impl.
+
+## Non-goals (explicit)
+
+- Runtime World tick behaviour — stubs only.
+- `AsyncProcessor` (Python async equivalent) — future follow-up.
+- Entity=`PersonaCard` wiring — DU-2.7, later PR.
+- Lance dataset integration beyond the `dataset_uri: String` placeholder — the `fork()` → `lance::checkout(branch)` wiring is DU-2.8.
+
+## Acceptance criteria
+
+- `cargo check -p lance-graph-archetype` compiles cleanly.
+- `cargo test -p lance-graph-archetype` — minimum 4 tests pass (one per core trait + one per stub-returns-Unimplemented).
+- `cargo test --workspace` — no regressions in other crates.
+- Root `Cargo.toml` workspace.members updated.
+- `STATUS_BOARD.md` DU-2 row status: Queued → In progress.
+- Verdict flip in `.claude/plans/unified-integration-v1.md §6`: Archetype row `LOCKED-MAPPING-INCOMPLETE` → `LOCKED-AND-SCAFFOLDED`.
+- `.claude/board/INTEGRATION_PLANS.md` — prepend entry pointing to this plan file.
+- `.claude/board/LATEST_STATE.md § Contract Inventory` — add a new block for `lance-graph-archetype` naming the shipped types.
+- `.claude/board/EPIPHANIES.md` — prepend short FINDING entry noting scaffold landed.
+
+## Architecture notes
+
+Per ADR-0001 Decision 1 (`.claude/adr/0001-archetype-transcode-stack.md:14-102`): this crate defines its OWN Rust interface. It does NOT mirror the Python `VangelisTech/archetype` API. The Python repo is a DESIGN SPEC, not a runtime dependency. "Upstream Python API unstable" is NOT a blocker.
+
+Per ADR-0001 Decision 3 (`adr/0001-archetype-transcode-stack.md:320-334`): BBB invariant bans `Vsa16kF32` / `RoleKey` / `NarsTruth` / `BlackboardEntry` from crossing the membrane. Archetype types defined in this crate are INSIDE-BBB; they do NOT appear on `CognitiveEventRow`. The scalar projection for "archetype tick happened" is already covered by `CognitiveEventRow.cycle_fp_hi/lo` + `MetaWord`.
+
+Mapping (locked, do not re-litigate):
+
+| ECS concept | lance-graph-contract type | This crate |
+|---|---|---|
+| Entity | `contract::persona::PersonaCard` | imported, not redefined |
+| World | `contract::a2a_blackboard::Blackboard` (runtime) + `World { dataset_uri, tick }` (archetype meta) | the latter is new here |
+| Tick | `contract::collapse_gate::GateDecision` fire | imported, not redefined |
+| Component | trait in this crate | **DU-2.2** |
+| Processor | trait in this crate | **DU-2.3** |
+| CommandBroker | struct in this crate | **DU-2.5** |
+
+## File layout
+
+```
+crates/lance-graph-archetype/
+  Cargo.toml
+  src/
+    lib.rs              # pub use component::*; etc.
+    component.rs        # trait Component
+    processor.rs        # trait Processor
+    world.rs            # struct World
+    command_broker.rs   # struct CommandBroker, enum Command
+    error.rs            # enum ArchetypeError (thiserror)
+```
+
+## Test layout
+
+Each module gets a `#[cfg(test)] mod tests` with at minimum one test. Minimum 4 tests total:
+
+1. `component::tests::mock_component_has_arrow_field`
+2. `processor::tests::trait_object_is_constructable`
+3. `world::tests::fork_returns_unimplemented`
+4. `world::tests::tick_increments`
+
+## Dependencies
+
+```toml
+[dependencies]
+lance-graph-contract = { path = "../lance-graph-contract" }
+arrow = { workspace = true }
+thiserror = { workspace = true }
+
+[dev-dependencies]
+# nothing initially
+```

.claude/plans/supabase-subscriber-v1.md

@@ -0,0 +1,76 @@
+# Supabase-shape Subscriber Flow Wire-up — v1
+
+> **Status:** In progress (2026-04-24)
+> **Owner:** @callcenter-specialist, @bus-compiler
+> **Scope:** `lance-graph-callcenter` crate only (plus `external_membrane.rs` if trait surface bends)
+> **Depends on:** none (substrate-independent)
+
+## Goal
+
+Flip `LanceMembrane::subscribe()` from GHOST to PARTIAL. Ship DM-4 `LanceVersionWatcher` + DM-6 `DrainTask`. Close the Outside-BBB loop so Lance dataset version bumps fire notifications to subscribers with filtered `CognitiveEventRow` payloads.
+
+## Deliverables
+
+- **DM-4a** — Swap `Subscription` associated type from `mpsc::Receiver<u64>` to `tokio::sync::watch::Receiver<CognitiveEventRow>` in `lance_membrane.rs`.
+- **DM-4b** — Create `crates/lance-graph-callcenter/src/version_watcher.rs`. Holds the `watch::Sender<CognitiveEventRow>`; `bump(row)` on each `project()` commit.
+- **DM-4c** — Uncomment `pub mod version_watcher` in `lib.rs:71-72`; export `LanceVersionWatcher`.
+- **DM-5a** — `subscribe(filter)` returns the `watch::Receiver` wrapped with a `CommitFilter` predicate combinator.
+- **DM-6a** — Create `crates/lance-graph-callcenter/src/drain.rs`. Scaffold only — `DrainTask` struct + `drain()` method that currently returns `Poll::Pending`. Wiring to `OrchestrationBridge::route()` is the follow-up PR.
+- **DM-6b** — Uncomment `pub mod drain` in `lib.rs:78-79`; export `DrainTask`.
+- **DM-7** — Flip test `subscribe_returns_disconnected_receiver` to `subscribe_receives_on_project` — assert `rx.borrow().version > 0` after a `project()` call.
+
+## Non-goals (explicit)
+
+- `dialect` Phase-B source wiring — separate TECH_DEBT row (@callcenter-specialist).
+- `scent` Phase-C CAM-PQ cascade — blocked on substrate migration (PR B, pending).
+- `PhoenixServer` DM-5 — Queued separately.
+- `DrainTask` runtime drain of `steering_intent` — this PR ships only the scaffold.
+
+## Acceptance criteria
+
+- `cargo test -p lance-graph-callcenter --lib` — 11 existing tests pass + new `subscribe_receives_on_project` test passes. Zero regressions.
+- `bbb_scalar_only_compile_check` still compiles.
+- `cargo check --workspace` compiles.
+- Verdict flip in `.claude/plans/unified-integration-v1.md §6`: Supabase row `GHOST` → `PARTIAL` (one-line Edit on the table row).
+- `.claude/board/INTEGRATION_PLANS.md` — prepend entry pointing to this plan file.
+- `.claude/board/STATUS_BOARD.md` — DM-4 / DM-6 rows status updated.
+- `.claude/board/EPIPHANIES.md` — prepend short FINDING entry noting subscribe wire-up.
+
+## Architecture notes
+
+Per CLAUDE.md BBB invariant, `Subscription` must carry Arrow-scalar content only — `CognitiveEventRow` is the canonical outbound DTO and is already scalar-only (compile-time enforced by `bbb_scalar_only_compile_check`). `tokio::sync::watch` is the right primitive for the supabase-realtime-shaped fan-out: single-producer (the membrane), many-consumer (subscribers), always-latest semantics (skip stale revisions).
+
+Implementation sketch:
+
+```rust
+// version_watcher.rs
+pub struct LanceVersionWatcher {
+    tx: tokio::sync::watch::Sender<CognitiveEventRow>,
+}
+impl LanceVersionWatcher {
+    pub fn new(initial: CognitiveEventRow) -> Self { ... }
+    pub fn bump(&self, row: CognitiveEventRow) { let _ = self.tx.send(row); }
+    pub fn subscribe(&self) -> tokio::sync::watch::Receiver<CognitiveEventRow> { self.tx.subscribe() }
+}
+```
+
+The `CommitFilter` wrapper is NOT a new trait — it's a method `LanceMembrane::subscribe_filtered(filter: CommitFilter) -> impl Stream<Item = CognitiveEventRow>` that calls `self.watcher.subscribe()` and uses `tokio_stream::wrappers::WatchStream::new(rx).filter(move |row| filter.matches(row))`.
+
+## File-level edits (full list)
+
+1. `crates/lance-graph-callcenter/Cargo.toml` — add `tokio = { workspace = true, features = ["sync"] }` if not present; add `tokio-stream = { workspace = true }` (minimal features).
+2. `crates/lance-graph-callcenter/src/version_watcher.rs` — NEW.
+3. `crates/lance-graph-callcenter/src/drain.rs` — NEW (scaffold).
+4. `crates/lance-graph-callcenter/src/lib.rs:71-72` — uncomment `pub mod version_watcher`.
+5. `crates/lance-graph-callcenter/src/lib.rs:78-79` — uncomment `pub mod drain`.
+6. `crates/lance-graph-callcenter/src/lance_membrane.rs:56` — field `watcher: LanceVersionWatcher`.
+7. `crates/lance-graph-callcenter/src/lance_membrane.rs:117` — `type Subscription = watch::Receiver<CognitiveEventRow>`.
+8. `crates/lance-graph-callcenter/src/lance_membrane.rs:186-189` — `subscribe()` body = `self.watcher.subscribe()`.
+9. `crates/lance-graph-callcenter/src/lance_membrane.rs` — `project()` path (wherever it completes a commit) — call `self.watcher.bump(row)` after the Lance write.
+10. `crates/lance-graph-callcenter/src/lance_membrane.rs` tests — flip `subscribe_returns_disconnected_receiver` to `subscribe_receives_on_project`.
+11. `crates/lance-graph-contract/src/external_membrane.rs` — IF the `Subscription` associated type is declared here with bounds, widen to `Clone + Send` as needed. Do NOT add Vsa/RoleKey/NarsTruth — BBB deny-list stays intact.
+12. Board files (INTEGRATION_PLANS, STATUS_BOARD, EPIPHANIES, unified-integration-v1 §6) — per Acceptance.
+
+## Test
+
+- New test `subscribe_receives_on_project` — construct `LanceMembrane`, call `subscribe()` → `rx`, call `project(some_event)` → assert `rx.borrow().<relevant field>` matches `some_event`.

Cargo.lock

@@ -7,6 +7,7 @@ members = [
     "crates/lance-graph-contract",
     "crates/neural-debug",
     "crates/lance-graph-callcenter",
+    "crates/lance-graph-archetype",
     "crates/lance-graph-rbac",
 ]
 exclude = [

Cargo.toml

@@ -0,0 +1,19 @@
+[package]
+name = "lance-graph-archetype"
+version = "0.1.0"
+edition = "2021"
+description = "Archetype transcode scaffold (ECS-style types transcoded to Arrow/Lance). Per ADR-0001 Decision 1: defines its OWN Rust interface (not a mirror of upstream Python). Inside-BBB only — types in this crate never cross the CognitiveEventRow membrane."
+license = "Apache-2.0"
+keywords = ["lance", "graph", "archetype", "ecs", "transcode"]
+
+[dependencies]
+lance-graph-contract = { path = "../lance-graph-contract" }
+# NOTE: plan specified { workspace = true } for arrow/thiserror, but this
+# workspace has no shared [workspace.dependencies] table today; using
+# explicit versions consistent with the rest of the codebase (arrow 57,
+# thiserror 2). See PR description for the single-line deviation.
+arrow = "57"
+thiserror = "2"
+
+[dev-dependencies]
+# nothing initially