feat(decopilot): unified per-run projection workflow (consume step + hosted child harness)#4179

Merged

tlgimenes merged 50 commits into

mainfrom

Jun 30, 2026

Commits on Jun 29, 2026

refactor(decopilot): consume-step projection architecture on v3 contract

tlgimenes
and
claude
committed
fix(decopilot): re-arm run status on turn-start so a 2nd turn isn't dropped

tlgimenes
and
claude
committed
fix(decopilot): persist checkpoint parts for single-step (CLI) harness turns

tlgimenes
and
claude
committed
chore(decopilot): checkpoint projection WIP before message-id unification

tlgimenes
and
claude
committed
docs(decopilot): message-id unification spec + implementation plan

tlgimenes
and
claude
committed
feat(harness): share one message-id generator and stamp start.messageId in all harnesses

tlgimenes
and
claude
committed
feat(decopilot): consume harness message id verbatim + continuation merge in fold

tlgimenes
and
claude
committed
fix(decopilot): terminal projector persists harness message id, merge from originalMessages
tlgimenes
committed
refactor(decopilot): drop deterministic assistant-id generator from checkpoint + live ingest
tlgimenes
committed
test(decopilot): two-turns id test verifies verbatim harness start.messageId flow-through
tlgimenes
committed
refactor(decopilot): add shared nats-chunk-source skeleton (types + source)
tlgimenes
committed
refactor(decopilot): add shared reassembleFragments transform
tlgimenes
committed
refactor(decopilot): add shared unwrapPayload transform
tlgimenes
committed
test(decopilot): verify approval continuation merges onto proposal (no duplicate message)

tlgimenes
and
claude
committed
refactor(decopilot): add projector fenceFilter transform
tlgimenes
committed
refactor(decopilot): add projector assertContiguousAndDedup transform

tlgimenes
and
claude
committed
test(decopilot): assert continuation content merged onto proposal (harden Layer 2 gate)

tlgimenes
and
claude
committed
refactor(decopilot): add projectorChunkStream terminal stage
tlgimenes
committed
docs(decopilot): note single-message invariant behind the continuation-id remap
tlgimenes
committed
fix(decopilot): test projectorChunkStream cancel cascade via infinite source; revert natsChunkSource exhaustion hack

tlgimenes
and
claude
committed
refactor(decopilot): compose projector chunk stream from shared transforms
tlgimenes
committed
fix(decopilot): satisfy tsc strict-null in nats-chunk-source tests

tlgimenes
and
claude
committed
docs(decopilot): align comments with the unified message-id architecture
tlgimenes
committed
docs(decopilot): document widened onDone trigger; drop stray path comment

tlgimenes
and
claude
committed
refactor(decopilot): compose live tail stream from shared nats-chunk-source decode

tlgimenes
and
claude
committed
refactor(decopilot): harden live-tail cleanup (guard releaseLock, restore cleaned flag)

tlgimenes
and
claude
committed
fix(decopilot): stop the subscription on projector error exits too

tlgimenes
and
claude
committed
refactor(decopilot): import shared FRAG_* header constants

tlgimenes
and
claude
committed
fix(decopilot): mint a fresh run fence per turn so approval continuations dispatch

tlgimenes
and
claude
committed
refactor(decopilot): delete dead checkpoint projector + projector-run-log

tlgimenes
and
claude
committed
refactor(decopilot): drop dead projected_seq thread column

tlgimenes
and
claude
committed
refactor(decopilot): drop the checkpoint event kind from the shared decode

tlgimenes
and
claude
committed
refactor(decopilot): remove checkpoint publication + wire helpers

tlgimenes
and
claude
committed
fix(decopilot): restore mid-stream outbox-truncation report dropped with checkpoint debounce

tlgimenes
and
claude
committed
refactor(decopilot): remove orphaned projectRun left dead by checkpoint removal

tlgimenes
and
claude
committed
refactor(decopilot): remove dead checkpoint e2e stub routes + vacuous tests

tlgimenes
and
claude
committed
refactor(decopilot): add run-stream codec (serialize side) in @decocms/harness

tlgimenes
and
claude
committed
refactor(decopilot): move run-stream decode into the codec; parse path consumes it

tlgimenes
and
claude
committed
refactor(decopilot): hosted produce path serializes via the codec

tlgimenes
and
claude
committed
fix(decopilot): preserve metrics on oversized drop + silent unfenced-done sentinel

tlgimenes
and
claude
committed
feat(decopilot): desktop relay fragments large chunks via the codec

tlgimenes
and
claude
committed
refactor(decopilot): codec is the single source of truth for run-stream wire

tlgimenes
and
claude
committed
docs(decopilot): fix stale codec comments (re-export note + unwrapPayload ref)

tlgimenes
and
claude
committed
docs(decopilot): codec header reflects both serialize + decode sides

tlgimenes
and
claude
committed
refactor(decopilot): drop resume debug log + dead checkpoint-pass residue

tlgimenes
and
claude
committed