feat(native-chat): store each chat's status with its history; startup seeds and settles from it

config/scripts/vitest-sqlite-runtime-files.mjs

@@ -84,8 +84,10 @@ export const SQLITE_RUNTIME_INCLUDE = [
   'src/main/native-chat/agent-session-wire/structured-agent-session-live-turn-window.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-main-agent-working-agreement.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-newer-content-host.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-open-settlement.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-option-settlement.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-owed-work-release.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-persisted-tab-listing.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-pre-spawn-first-answer.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-processless-reservation.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-prompt-cancel.test.ts',
@@ -107,18 +109,22 @@ export const SQLITE_RUNTIME_INCLUDE = [
   'src/main/native-chat/agent-session-wire/structured-agent-session-restart-offer-newer-orca.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-restart-restore.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-restart-status-publication.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-restore-after-listing.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-restore-without-import.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-rewind-at-rest.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-rewind-live-send.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-rewind.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-send-during-startup-lease-check.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-send-idempotency.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-send-open-stale-turn.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-send-preparation.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-send-restarts-failed-start.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-settled-attach-retry.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-stale-turn-verdict.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-start-failure-writer.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-startup-damaged-chat.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-startup-reconcile-failure.test.ts',
+  'src/main/native-chat/agent-session-wire/structured-agent-session-startup-state.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-status-feed-child-work.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-status-feed-child.test.ts',
   'src/main/native-chat/agent-session-wire/structured-agent-session-status-feed-children.test.ts',
@@ -183,6 +189,8 @@ export const SQLITE_RUNTIME_INCLUDE = [
   'src/main/runtime/structured-agent-session-rollback-compatibility.test.ts',
   'src/main/runtime/structured-agent-session-spawn-token-descendants.test.ts',
   'src/main/runtime/structured-agent-session-startup-reconcile.test.ts',
+  'src/main/runtime/structured-agent-session-startup-restoration.test.ts',
+  'src/main/runtime/structured-agent-session-tab-listing-startup.test.ts',
   'src/main/runtime/structured-claude-pending-rewind.test.ts',
   'src/main/ssh-expired-lease-pane-readoption.test.ts',
   'src/main/ssh-reattach-pane-cardinality.test.ts',

docs/reference/agent-status-store.md

@@ -128,11 +128,23 @@ forgot the row would strand a permanently working-looking agent.
 
 Two rules the ingest must keep:
 
-- **Never persist a structured row.** The journal is the durable truth for a
-  structured session and the host republishes on restore. A structured row in
-  `last-status.json` would hydrate as `restoredUnconfirmed` and then fight the
-  live republish. The serializer skips rows carrying `structuredHost`, and
-  hydrate drops any such row found on disk. Applying one therefore also skips
+- **Never persist a structured row in the store.** The chat journal database
+  is the durable truth for a structured session. Each chat's status is stored
+  there beside its journal (`journal_session_state`), written in the same
+  transaction as the journal rows it describes, so it is always current. A
+  chat last written before that table existed, by an older build, or whose row
+  was derived by other rules, has no current row: it gets one when it is
+  opened, which also settles it and publishes its status. A listed one is
+  opened by the background restore after the tab listing answers, as is a
+  listed chat whose history is still in an older build's per-chat file. A
+  corrupt chat gets no row until its open rebuilds it.
+  At host startup, before the tab listing answers, the host republishes the
+  row of each settled chat that is still listed and not already open, without
+  opening it; after that it settles every chat a gone process left with work.
+  A structured row in `last-status.json` would
+  hydrate as `restoredUnconfirmed` and fight that republish, so the serializer
+  still skips rows carrying `structuredHost`, and hydrate still drops any found
+  on disk. Applying one therefore also skips
   the persist schedule: the walk and stringify could only reproduce the file
   that is already on disk, once per debounce window for every streaming chat.
 - **Never let it fight a hook row.** A structured session has no PTY, so no

src/main/agent-hooks/first-work-branch-rename.test.ts

@@ -3,6 +3,7 @@ import type { GlobalSettings } from '../../shared/global-settings-types'
 import type { Repo } from '../../shared/repo-types'
 import type { AgentJournalRenderItem } from '../../shared/agent-session-journal-types'
 import type { AgentSessionJournal } from '../native-chat/agent-session-journal/journal-store'
+import { projectStructuredAgentSessionStatusState } from '../../shared/structured-agent-session-projection'
 import { StructuredAgentSessionStatusFeed } from '../native-chat/agent-session-wire/structured-agent-session-status-feed'
 import { maybeAutoRenameWorkspaceOnFirstStructuredTurn } from './first-work-structured-session-rename'
 import { WORKTREE_ID_SEPARATOR } from '../../shared/worktree/id'
@@ -104,12 +105,15 @@ describe('maybeAutoRenameBranchOnFirstWork', () => {
       // A real journal's sequence only ever advances, so the feed's projection
       // cache must miss on every publish here: this test is about the rename.
       let sequence = 0
-      // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: the status feed reads only cursor(), lastActivityAt(), stopMarks and snapshot() of a journal.
+      // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: a stand-in journal offering only what the status feed reads (submissions, cursor, Stop marks, its projection, activity).
       const journal = {
-        snapshot: () => ({ items, submissions: [] }),
+        submissions: () => [],
         stopMarks: { latest: () => null, revision: () => 0 },
         lastActivityAt: () => 1,
-        cursor: () => ({ epoch: 1, sequence: (sequence += 1) })
+        cursor: () => ({ epoch: 1, sequence: (sequence += 1) }),
+        sessionStatus: {
+          at: (fence?: number) => projectStructuredAgentSessionStatusState(items, [], fence)
+        }
       } as unknown as AgentSessionJournal
       const pending: Promise<void>[] = []
       const observe = vi.fn((summary, options) => {
@@ -193,24 +197,35 @@ describe('maybeAutoRenameBranchOnFirstWork', () => {
     const { deps, setDisplayName, setRenameError } = makeDeps({
       getRepo: () => ({ id: REPO_ID, kind: 'folder', path: '/workspace/platform' }) as Repo
     })
-    // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: the status feed reads only cursor(), lastActivityAt(), stopMarks and snapshot() of a journal.
+    const items: AgentJournalRenderItem[] = [
+      {
+        itemId: 'user-1',
+        sequence: 1,
+        revision: 1,
+        observedAt: 1,
+        body: { kind: 'message', role: 'user', blocks: [{ type: 'text', text: 'Fix auth' }] }
+      },
+      {
+        itemId: 'turn-1',
+        sequence: 2,
+        revision: 1,
+        observedAt: 1,
+        body: {
+          kind: 'status',
+          text: 'Working',
+          turnLifecycle: { turnId: 'turn-1', state: 'running' }
+        }
+      }
+    ]
+    // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: a stand-in journal offering only what the status feed reads (submissions, cursor, Stop marks, its projection, activity).
     const journal = {
       lastActivityAt: () => 1,
       stopMarks: { latest: () => null, revision: () => 0 },
       cursor: () => ({ epoch: 1, sequence: 1 }),
-      snapshot: () => ({
-        items: [
-          { body: { kind: 'message', role: 'user', blocks: [{ type: 'text', text: 'Fix auth' }] } },
-          {
-            body: {
-              kind: 'status',
-              text: 'Working',
-              turnLifecycle: { turnId: 'turn-1', state: 'running' }
-            }
-          }
-        ],
-        submissions: []
-      })
+      sessionStatus: {
+        at: (fence?: number) => projectStructuredAgentSessionStatusState(items, [], fence)
+      },
+      submissions: () => []
     } as unknown as AgentSessionJournal
     const location = {
       executionHostId: 'local' as const,

src/main/claude/claude-background-wake-retention.test.ts

@@ -7,6 +7,7 @@
 import { afterEach, describe, expect, it, vi } from 'vitest'
 import type { AgentJournalSubmission } from '../../shared/agent-session-journal-types'
 import { structuredRunningChildWork } from '../../shared/agent-child-work-listing'
+import { projectStructuredAgentSessionStatusState } from '../../shared/structured-agent-session-projection'
 import type { AgentHookServer } from '../agent-hooks/server'
 import type { StructuredAgentSessionJournalProjections } from '../native-chat/agent-session-wire/structured-agent-session-status-journal-projection'
 import { StructuredAgentSessionStatusFeed } from '../native-chat/agent-session-wire/structured-agent-session-status-feed'
@@ -29,31 +30,37 @@ async function wiredSession() {
   const run = await producer(host)
   const submissions: AgentJournalSubmission[] = []
   let sequence = 0
+  const snapshot = () => ({
+    items: [...run.journalItems.values()]
+      .sort((a, b) => a.sequence - b.sequence)
+      .map((item) => ({ ...item, revision: 1, observedAt: item.sequence })),
+    submissions: submissions.map((submission) => ({ ...submission }))
+  })
   const journal = {
     cursor: () => ({ epoch: 'epoch-1', sequence: ++sequence }),
     lastActivityAt: () => 1,
-    submissions: (): ReturnType<Journal['submissions']> =>
-      submissions.map((submission) => ({ ...submission })),
+    submissions: (): ReturnType<Journal['submissions']> => snapshot().submissions,
     item: (itemId: string): ReturnType<Journal['item']> => {
       const item = run.journalItems.get(itemId)
       return item ? { ...item, revision: 1, observedAt: run.now() } : null
     },
     // No Stop was ever pressed here.
     stopMarks: { latest: () => null, revision: () => 0 },
-    snapshot: () => ({
-      items: [...run.journalItems.values()]
-        .sort((a, b) => a.sequence - b.sequence)
-        .map((item) => ({ ...item, revision: 1, observedAt: run.now() })),
-      submissions: submissions.map((submission) => ({ ...submission }))
-    })
+    // The journal's own projection, which the feed shares with the status stored beside it.
+    sessionStatus: {
+      at: (fence?: number) => {
+        const { items, submissions: sent } = snapshot()
+        return projectStructuredAgentSessionStatusState(items, sent, fence)
+      }
+    }
   }
   const feed = new StructuredAgentSessionStatusFeed({
     logger: createStructuredAgentSessionLogger(),
     sessions: new Map([
       [
         parent.sessionId,
         {
-          // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: the fixture supplies the feed's cursor, clock, Stop marks, snapshot, submissions and item reads.
+          // oxlint-disable-next-line typescript/consistent-type-assertions -- SAFETY: the fixture supplies the feed's cursor, clock, Stop marks, submissions, item reads and projection.
           journal: journal as unknown as Journal,
           params: {
             location: {

src/main/claude/claude-subagent-resume-after-restart.test.ts

@@ -14,6 +14,10 @@ import {
 import type { AgentSessionJournal } from '../native-chat/agent-session-journal/journal-store'
 import { createTrackedJournalOpener } from '../native-chat/agent-session-journal/journal-host-database-test-support'
 import { createDeferredStructuredAgentSessionEventSink } from '../native-chat/agent-session-wire/structured-agent-session-event-sink'
+import {
+  appendOpenSettlement,
+  planOpenSettlement
+} from '../native-chat/agent-session-wire/structured-agent-session-open-settlement'
 import { createClaudeJournalTranslator } from './claude-structured-journal-translation'
 import { claudeSubagentGroupBody, claudeSubagentGroupIdentity } from './claude-subagent-group-row'
 import { testEventSinkLogging } from '../native-chat/agent-session-wire/structured-agent-session-logger-test-support'
@@ -455,6 +459,15 @@ describe('a Claude subagent resumed after its provider restarted', () => {
     // contact was lost, not when.
     await crashed.close()
     const journal = await openJournal()
+    // What the conversation's open appends before an acquisition reads the journal.
+    await appendOpenSettlement(
+      journal,
+      planOpenSettlement(journal, null, { acquisition: true }),
+      0,
+      (error) => {
+        throw error
+      }
+    )
     const [lost] = rowsListing(journal, 'agent-a')[0]?.agents ?? []
     expect(lost).toMatchObject({ id: 'agent-a', state: 'unverifiable' })
     expect(lost?.settledAt).toBeUndefined()