fix(orchestration): native chats get each orchestration message whole instead of a check pointer

config/reliability-gates.jsonc

@@ -2022,7 +2022,8 @@
       "oracle": "Inject adapter/RPC acknowledgement loss, caller replacement, logical-client close after response, auth recovery with a written request, missing host submissions, legacy pending rows, stale fences, expiry, mobile remount, and phone storage refusal. Assert at most one dispatch for repeated transmission of one operation. For a later phone Send, assert a fresh id and second delivery while the original host entry remains unknown; equal images use current uploaded paths and delivery fields follow current host capabilities.",
       "commands": [
         "ORCA_BACKGROUND_LAUNCH=1 pnpm test src/shared/agent-session-operation-ledger.test.ts src/shared/structured-agent-session-send-evidence.test.ts src/main/runtime/agent-session/ownership/agent-session-operation-admission.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.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-host.test.ts src/main/runtime/orchestration/structured-pointer-operation-id.test.ts src/renderer/src/components/native-chat/structured-agent-session-message-sender.test.ts src/renderer/src/components/native-chat/use-structured-agent-session.test.tsx src/renderer/src/lib/launch-structured-agent-session.test.ts",
-        "ORCA_BACKGROUND_LAUNCH=1 pnpm --dir mobile test ../mobile/src/session/mobile-structured-send-new-action.test.ts ../mobile/src/session/use-mobile-structured-agent-session-send.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-queued.test.tsx ../mobile/src/session/mobile-structured-send-delivery.test.ts ../mobile/src/session/use-mobile-structured-agent-session-background-tasks.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-newer-approval-send.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-read-failure.test.tsx ../mobile/src/session/use-mobile-structured-agent-session.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-prompt-cancel.test.tsx ../mobile/src/session/native-chat/composer/mobile-native-chat-image-attachment.test.ts ../mobile/src/session/native-chat/composer/use-mobile-native-chat-image-attachments.test.ts ../mobile/src/session/use-mobile-structured-native-chat-send-bridge.test.ts ../mobile/src/mobile-web-shell/page-storage-keys.test.ts ../mobile/src/mobile-web-shell/bridge/page-async-storage.test.ts ../mobile/src/mobile-web-shell/use-page-host-snapshot.test.tsx ../mobile/src/mobile-web-shell/bridge-host-init.test.ts ../mobile/src/transport/mobile-relay-rpc-session.test.ts ../mobile/src/transport/rpc-client-delivery-ambiguity.test.ts ../mobile/src/transport/stable-logical-rpc-client.test.ts --maxWorkers=2"
+        "ORCA_BACKGROUND_LAUNCH=1 pnpm --dir mobile test ../mobile/src/session/mobile-structured-send-new-action.test.ts ../mobile/src/session/use-mobile-structured-agent-session-send.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-queued.test.tsx ../mobile/src/session/mobile-structured-send-delivery.test.ts ../mobile/src/session/use-mobile-structured-agent-session-background-tasks.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-newer-approval-send.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-read-failure.test.tsx ../mobile/src/session/use-mobile-structured-agent-session.test.tsx ../mobile/src/session/use-mobile-structured-agent-session-prompt-cancel.test.tsx ../mobile/src/session/native-chat/composer/mobile-native-chat-image-attachment.test.ts ../mobile/src/session/native-chat/composer/use-mobile-native-chat-image-attachments.test.ts ../mobile/src/session/use-mobile-structured-native-chat-send-bridge.test.ts ../mobile/src/mobile-web-shell/page-storage-keys.test.ts ../mobile/src/mobile-web-shell/bridge/page-async-storage.test.ts ../mobile/src/mobile-web-shell/use-page-host-snapshot.test.tsx ../mobile/src/mobile-web-shell/bridge-host-init.test.ts ../mobile/src/transport/mobile-relay-rpc-session.test.ts ../mobile/src/transport/rpc-client-delivery-ambiguity.test.ts ../mobile/src/transport/stable-logical-rpc-client.test.ts --maxWorkers=2",
+        "ORCA_BACKGROUND_LAUNCH=1 pnpm test src/main/native-chat/agent-session-wire/structured-agent-session-mail-queue.test.ts src/main/native-chat/agent-session-wire/structured-agent-session-mail-creation-recovery.test.ts"
       ],
       "testFiles": [
         "src/shared/agent-session-operation-ledger.test.ts",
@@ -2033,6 +2034,8 @@
         "src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts",
         "src/main/runtime/orchestration/structured-mailbox-pointer-host.test.ts",
         "src/main/runtime/orchestration/structured-pointer-operation-id.test.ts",
+        "src/main/native-chat/agent-session-wire/structured-agent-session-mail-queue.test.ts",
+        "src/main/native-chat/agent-session-wire/structured-agent-session-mail-creation-recovery.test.ts",
         "src/renderer/src/components/native-chat/structured-agent-session-message-sender.test.ts",
         "src/renderer/src/components/native-chat/use-structured-agent-session.test.tsx",
         "src/renderer/src/lib/launch-structured-agent-session.test.ts",
@@ -2086,12 +2089,16 @@
           "assertions": ["reuses an option operation after a pending admission refusal"]
         },
         {
-          "file": "src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts",
-          "assertions": ["retries a rejected nudge on the next journal edge"]
+          "file": "src/main/native-chat/agent-session-wire/structured-agent-session-mail-queue.test.ts",
+          "assertions": [
+            "recovers only the original ordinary creation after ambiguous acceptance, a lost delivered stamp, edits, Move, Delete, epoch retirement, read and resetTasks"
+          ]
         },
         {
-          "file": "src/main/runtime/orchestration/structured-pointer-operation-id.test.ts",
-          "assertions": ["never re-mints an ambiguous batch after the host replay window expires"]
+          "file": "src/main/native-chat/agent-session-wire/structured-agent-session-mail-creation-recovery.test.ts",
+          "assertions": [
+            "reconciles a saved random batch through original receipt/member history N=%i after Delete and restart, without recreating either report"
+          ]
         },
         {
           "file": "mobile/src/transport/rpc-client-delivery-ambiguity.test.ts",
@@ -2129,7 +2136,8 @@
           "date": "2026-10-13",
           "runner": "local",
           "platform": "macos",
-          "command": "ORCA_BACKGROUND_LAUNCH=1 pnpm test src/shared/agent-session-operation-ledger.test.ts src/shared/structured-agent-session-send-evidence.test.ts src/main/runtime/agent-session/ownership/agent-session-operation-admission.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.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-host.test.ts src/main/runtime/orchestration/structured-pointer-operation-id.test.ts src/renderer/src/components/native-chat/structured-agent-session-message-sender.test.ts src/renderer/src/components/native-chat/use-structured-agent-session.test.tsx src/renderer/src/lib/launch-structured-agent-session.test.ts",
+          "command": "ORCA_BACKGROUND_LAUNCH=1 pnpm test src/shared/agent-session-operation-ledger.test.ts src/shared/structured-agent-session-send-evidence.test.ts src/main/runtime/agent-session-operation-admission.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.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-host.test.ts src/main/runtime/orchestration/structured-pointer-operation-id.test.ts src/renderer/src/components/native-chat/structured-agent-session-message-sender.test.ts src/renderer/src/components/native-chat/use-structured-agent-session.test.tsx src/renderer/src/lib/launch-structured-agent-session.test.ts",
+          "currentCommand": "ORCA_BACKGROUND_LAUNCH=1 pnpm test src/shared/agent-session-operation-ledger.test.ts src/shared/structured-agent-session-send-evidence.test.ts src/main/runtime/agent-session/ownership/agent-session-operation-admission.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.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-delivery.test.ts src/main/runtime/orchestration/structured-mailbox-pointer-host.test.ts src/main/runtime/orchestration/structured-pointer-operation-id.test.ts src/renderer/src/components/native-chat/structured-agent-session-message-sender.test.ts src/renderer/src/components/native-chat/use-structured-agent-session.test.tsx src/renderer/src/lib/launch-structured-agent-session.test.ts",
           "result": "passed",
           "durationSeconds": 6.47,
           "summary": "Eleven focused host, shared, renderer and orchestration files passed 196 tests, including unknown send outcomes, reused message IDs and host replay without duplicate dispatch. The send-idempotency suite pins only that an unknown outcome is never resent; the removed refusal-retry matrix has no replacement here."

mobile/src/session/use-mobile-structured-agent-session-queued.test.tsx

@@ -1,6 +1,6 @@
 // Test capability-gated queue writes with authoritative cards; Stop preserves host-held drafts and legacy Edit copies before deleting.
 
-import { createElement } from 'react'
+import { createElement, memo } from 'react'
 import { agentJournalSubmissionKey } from '../../../src/shared/agent-session-journal-item-key'
 import { act, create, type ReactTestRenderer } from 'react-test-renderer'
 import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
@@ -66,13 +66,19 @@ describe('mobile structured queued messages', () => {
     close: () => {}
   }
 
+  const queueRender = vi.fn()
+  const QueueObserver = memo(({ cards, pause }: { cards: unknown; pause: unknown }) => {
+    queueRender(cards, pause)
+    return null
+  })
+
   function Harness({
     hostSupport,
     sessionId = SESSION_ID
   }: {
     hostSupport: StructuredAgentSessionHostSupport
     sessionId?: string
-  }): null {
+  }) {
     hook = useMobileStructuredAgentSession({
       client,
       sessionId,
@@ -84,7 +90,7 @@ describe('mobile structured queued messages', () => {
       appendComposerText: appendText,
       onSendError
     })
-    return null
+    return createElement(QueueObserver, { cards: hook.queued.cards, pause: hook.queued.pause })
   }
 
   async function mountSession(
@@ -144,6 +150,27 @@ describe('mobile structured queued messages', () => {
     unmountSession()
   })
 
+  it.each([100, 1000])(
+    'does not render the mounted N=%i queue consumer for token-only frames',
+    async (count) => {
+      const cards = Array.from({ length: count }, (_, position) =>
+        queuedDraft({ messageId: `report-${position}`, position })
+      )
+      await mountSession(CAPABLE, snapshotEvent({ queuedMessages: cards }))
+      await act(async () => {})
+      queueRender.mockClear()
+      await act(async () =>
+        listener?.({ ...batchEvent(), activity: { turnId: 'working', text: 'token' } })
+      )
+      await act(async () => {})
+      expect(hook?.queued.cards).toHaveLength(count)
+      expect(queueRender).not.toHaveBeenCalled()
+      await act(async () => listener?.(batchEvent(cards.slice(1))))
+      await vi.waitFor(() => expect(hook?.queued.cards).toHaveLength(count - 1))
+      expect(queueRender).toHaveBeenCalledTimes(1)
+    }
+  )
+
   it('reverts an optimistic relative move when the host reports a changed queue', async () => {
     const mail = queuedDraft({
       messageId: 'mail',
@@ -700,6 +727,50 @@ describe('mobile structured queued messages', () => {
       expect(onSendError).toHaveBeenCalledWith(expect.any(String))
     })
 
+    it('uses existing Resume for report-only and returned-prefix worker queues and follows the released host state', async () => {
+      sendRequest.mockImplementation(async (method) =>
+        method === 'agentSession.queuedMessagesResume'
+          ? mutationOk({ resumed: true })
+          : method === 'agentSession.options'
+            ? ok({ models: [], current: {} })
+            : ok({})
+      )
+      const worker = queuedDraft({
+        messageId: 'worker',
+        position: 2,
+        body: {
+          kind: 'message',
+          role: 'user',
+          blocks: [],
+          from: {
+            kind: 'agent',
+            senders: [],
+            orchestration: {
+              message: 'mail-notice',
+              mailbox: 'run:r',
+              dispatchId: null,
+              messages: []
+            }
+          }
+        }
+      })
+      await mountSession(CAPABLE, snapshotEvent({ queuedMessages: [worker] }))
+      for (const cards of [
+        [worker],
+        [queuedDraft({ messageId: 'returned', state: 'returned', returnedReason: null }), worker]
+      ]) {
+        act(() => listener?.(batchEvent(cards, [], { reason: 'stopped' })))
+        expect(hook!.queued.pause).toEqual({ reason: 'stopped' })
+        expect(hook!.queued.cards.find((card) => card.messageId === 'worker')?.hold).toBe('turn')
+        await act(async () => expect(await hook!.queued.resume()).toBe(true))
+        expect(Object.keys(requestOf('agentSession.queuedMessagesResume').params)).toEqual([
+          'envelope'
+        ])
+        act(() => listener?.(batchEvent(cards, [], null)))
+        expect(hook!.queued.pause).toBeNull()
+      }
+    })
+
     it('an incapable Stop is exactly today’s cancel', async () => {
       sendRequest.mockImplementation(async (method) => {
         if (method === 'agentSession.cancel') {

src/cli/handlers/orchestration-legacy-read-only.test.ts

@@ -6,6 +6,9 @@ vi.mock('../format', () => ({ printResult: vi.fn() }))
 vi.mock('../selectors', () => ({ getTerminalHandle: vi.fn() }))
 
 import { printResult } from '../format'
+import { parseArgs, validateCommandAndFlags } from '../args'
+import { COMMAND_SPECS } from '../specs'
+import { RuntimeClient } from '../runtime-client'
 import { ORCHESTRATION_HANDLERS } from './orchestration'
 
 beforeEach(() => {
@@ -14,6 +17,33 @@ beforeEach(() => {
 })
 
 describe('legacy orchestration CLI inspection', () => {
+  it('filters exact-id results from an older host before printing', async () => {
+    callMock.mockResolvedValue({ result: { messages: [{ id: 'unrelated' }], count: 1 } })
+    const parsed = parseArgs(
+      'orchestration inbox --id old_report --terminal term_coord --full'.split(' ')
+    )
+    validateCommandAndFlags(COMMAND_SPECS, parsed)
+    const client = new RuntimeClient('/tmp/orca-pr-28567-cli-test', 60_000, null, null)
+    client.call = callMock
+    await ORCHESTRATION_HANDLERS['orchestration inbox']({
+      flags: parsed.flags,
+      client,
+      cwd: '/repo',
+      json: true
+    })
+    const printed = vi.mocked(printResult).mock.calls[0]
+    expect(callMock).toHaveBeenCalledWith(
+      'orchestration.inbox',
+      expect.objectContaining({ id: 'old_report' })
+    )
+    expect(printed?.[0].result).toEqual({ messages: [], count: 0 })
+    const guidance = printed?.[2]({ messages: [], count: 0 })
+    expect(guidance).toContain(
+      'same inbox command without --id, keeping its terminal and execution profile'
+    )
+    expect(guidance).toContain('--full --limit 100')
+    expect(guidance).toContain('increase --limit')
+  })
   it('labels legacy rows in plain check output', async () => {
     const result = {
       messages: [

src/cli/handlers/orchestration/message-inbox-handlers.ts

@@ -32,15 +32,25 @@ export const ORCHESTRATION_INBOX_HANDLERS: Record<string, CommandHandler> = {
 
   'orchestration inbox': async ({ flags, client, json }) => {
     const full = flags.has('full')
+    const id = getOptionalStringFlag(flags, 'id')
     const result = await client.call<{
       messages: MessageSummary[]
       count: number
     }>('orchestration.inbox', {
+      id,
       limit: getOptionalPositiveIntegerFlag(flags, 'limit'),
       terminal: getPresentStringFlag(flags, 'terminal')
     })
+    // Older hosts ignore id; never print their unrelated history as an exact lookup.
+    if (id) {
+      result.result.messages = result.result.messages.filter((message) => message.id === id)
+      result.result.count = result.result.messages.length
+    }
     printResult(result, json, (value) => {
       if (value.count === 0) {
+        if (id) {
+          return `Message ${id} was not returned; an older host may only search recent history. Rerun the same inbox command without --id, keeping its terminal and execution profile, with --full --limit 100 and look for ${id}; increase --limit to look farther back.`
+        }
         return 'No messages.'
       }
       return value.messages

src/cli/specs/orchestration.ts

@@ -1,6 +1,5 @@
 import { GLOBAL_FLAGS, type CommandSpec } from '../args'
 import { ORCHESTRATION_WORKER_COMMAND_SPECS } from './orchestration-worker-specs'
-
 export const ORCHESTRATION_COMMAND_SPECS: CommandSpec[] = [
   {
     path: ['orchestration', 'run-create'],
@@ -131,8 +130,8 @@ export const ORCHESTRATION_COMMAND_SPECS: CommandSpec[] = [
   {
     path: ['orchestration', 'inbox'],
     summary: 'Show messages across (or for) recipients',
-    usage: 'orca orchestration inbox [--limit <n>] [--terminal <handle>] [--full] [--json]',
-    allowedFlags: [...GLOBAL_FLAGS, 'limit', 'terminal', 'full'],
+    usage: 'orca orchestration inbox [--id <id>] [--limit <n>] [--terminal <handle>] [--full]',
+    allowedFlags: [...GLOBAL_FLAGS, 'id', 'limit', 'terminal', 'full'],
     identityFlagRoles: { terminal: 'target' }
   },
   {