Mzeey-Empire · chuks-qua · Sep 27, 2026 · Sep 24, 2026 · Sep 24, 2026 · Sep 24, 2026
@@ -26,6 +26,7 @@
 | Last turn shows native agent changes, settles durably, and identifies Git fallback | [Last turn native diff](turn-diff-review.md) | Codex composer and Review Electron proof, plus focused Git/RPC and migration checks |
 | A thread starts, runs, stops, clears active state, and retains a cancelled reconnect snapshot | [Thread lifecycle](thread-lifecycle.md) | `runtime live --scenario stop` |
 | Provider events become durable assistant conversation data | [Provider events and durability](provider-events-and-durability.md) | `runtime live --scenario completion` |
+| Consecutive replies settle while switching away and back during streaming | [Provider events and durability](provider-events-and-durability.md#consecutive-turns-and-navigation) | Real-provider Electron follow-ups, mid-turn navigation, idle observation, and reload |
 | Seven active tasks keep event order while model and terminal controls settle | [Multi-surface journeys](multi-surface-journeys.md#seven-active-tasks-and-controls) | Fixture-owned seven-task public RPC run, then Electron controls and reload |
 | Codex reroutes, warnings, diagnostics, and authentication recovery remain bounded, durable, and thread-scoped | [Provider events and durability](provider-events-and-durability.md) | Composer notice journey and `runtime health` |
 | Approval review offers only valid access modes, waits for a real permission request, and keeps Full Access review-free | [Provider events and durability](provider-events-and-durability.md) | Approval review journey and focused policy and mapper tests |

@@ -19,6 +19,14 @@ If cleanup is incomplete, use the receipt's exact path with
 `--cleanup-receipt <receipt-path> --confirm-run` before another run. Do not
 delete tasks by title or age.
 
+For the worker-owned turn change in issue #1760, collect at least ten matched
+receipts. Compare server-loop delay, public event throughput, memory, and
+`metrics.workerQueue` peaks with the recorded baseline. Require model-picker
+and Stop acknowledgement within 2 seconds, terminal readiness within 5 seconds,
+and ordered durable events in every run. Run `--stop-one` as a separate case;
+require the six peers to finish and the stopped task to remain cancelled after
+reload. Trace and fix a missed budget before calling the run complete.
+
 In the owned Electron app, create separate direct tasks in `.dev/fixture-repo`.
 Open and close the model picker, open a Terminal, switch tasks, and reload.
 Capture the settled controls and terminal output in a screenshot, record the
@@ -28,6 +36,10 @@ final conversation check and [Electron live testing](../../../electorn-live-test
 for the desktop control and capture. Report any unavailable control or missing
 capture as a gap. A public RPC receipt alone does not prove the desktop path.
 
+Also run the [consecutive-turn navigation journey](provider-events-and-durability.md#consecutive-turns-and-navigation)
+with real Codex. The seven-task fixture starts one turn per task and cannot prove
+successful follow-ups or renderer state while switching during streaming.
+
 ## Provider completeness
 
 Use this journey when a change affects turn diffs, Review, provider events, automatic review, or workspace invalidation. Resolve the upstream Codex source with the OpenSrc command in the repository instructions before a Codex run. Record the resolved upstream commit in the receipt. The cache is read-only.

@@ -17,7 +17,8 @@
 1. Open the project for this worktree.
 2. Start a short thread with a selected provider and model.
 3. Wait for the final reply.
-4. Reload or reopen the conversation and confirm that the reply remains.
+4. Send a follow-up in the same conversation. Require its reply, cleared activity indicator, and restored Send control.
+5. Run the consecutive-turn journey below, then reload and confirm that replies remain.
 
 ## Driving it with verify-mcode
 
@@ -32,6 +33,28 @@ This fixture checks the production Codex event boundary, not a real model run or
 
 ## Runtime checks
 
+### Consecutive turns and navigation
+
+In the owned Electron app, select a real provider and model and create a direct
+task under `.dev/fixture-repo`. Record its ID before proceeding.
+
+1. Send a short prompt, wait for completion, then send a second prompt in the
+   same task. Require both replies and a restored Send control after each turn.
+2. Send a longer follow-up. After assistant text starts streaming, switch to
+   another fixture task and back before completion. Capture active runtime state
+   before leaving, while away, and after returning. The response must continue
+   and finish once, without cancellation or text appearing in the other task.
+3. Send another follow-up after navigation. Require a completed public runtime,
+   no Stop control or thinking indicator, and no reactivation for 40 seconds.
+4. Reload, reopen the same task, verify the durable replies through
+   `conversation.page`, and send one more follow-up to completion.
+5. Save a video of the mid-turn switch, settled screenshots, terminal outcomes,
+   provider/model, and exact owned IDs. Delete only the tasks created for proof.
+
+A first-turn server receipt does not cover this journey. Compare desktop state
+with the public runtime from that desktop's server; its isolated database can
+differ from the worktree server. Report which providers were actually exercised.
+
 Run `runtime health`, then run:
 
 ```sh

@@ -67,7 +67,7 @@ const FOCUSED_TEST_FILES = [
   "src/features/agents/turns/__tests__/turn-event-sink.test.ts",
   "src/features/agents/turns/__tests__/turn-finalizer.test.ts",
   "src/features/agents/turns/__tests__/turn-runtime.test.ts",
-  "src/features/agents/canonical/__tests__/canonical-agent-event-sink.test.ts",
+  "src/features/agents/canonical/__tests__/canonical-agent-boundary.test.ts",
   "src/features/agents/collaboration/adapters/__tests__/codex-collaboration-event-adapter.test.ts",
   "src/features/providers/composition/__tests__/provider-event-ingress.test.ts",
   "src/features/projects/git/__tests__/git-repository-fetch.test.ts",

@@ -1,4 +1,5 @@
 import { afterEach, describe, expect, it } from "vitest";
+import * as NodeChildProcess from "node:child_process";
 import * as NodeFSPromises from "node:fs/promises";
 import * as NodeOS from "node:os";
 import * as NodePath from "node:path";
@@ -24,6 +25,8 @@ describe("buildServerRuntimeBundles", () => {
     const serverOutFile = NodePath.join(outputRoot, "server.cjs");
     const ptyHostOutFile = NodePath.join(outputRoot, "pty-host.cjs");
     const providerEventWorkerOutFile = NodePath.join(outputRoot, "provider-event.worker.cjs");
+    const canonicalWriterWorkerOutFile = NodePath.join(outputRoot, "canonical-agent-writer.worker.cjs");
+    const executionWorkerOutFile = NodePath.join(outputRoot, "execution.worker.cjs");
 
     try {
       compileServerWithSwc(serverRoot);
@@ -36,7 +39,11 @@ describe("buildServerRuntimeBundles", () => {
 
       expect(() => new NodeVM.Script(bundledEntry, { filename: "server.cjs" })).not.toThrow();
       await NodeFSPromises.access(providerEventWorkerOutFile);
+      await NodeFSPromises.access(canonicalWriterWorkerOutFile);
+      await NodeFSPromises.access(executionWorkerOutFile);
+      expect(await NodeFSPromises.readFile(executionWorkerOutFile, "utf8")).toContain("writer-request");
       expect(await NodeFSPromises.readFile(serverOutFile, "utf8")).toContain("provider-event.worker.cjs");
+      expect(startAndCloseBundledWorker(executionWorkerOutFile)).toBe("ready,closed");
     } finally {
       await NodeFSPromises.rm(outputRoot, { recursive: true, force: true });
       await NodeFSPromises.rm(distTsc, { recursive: true, force: true });
@@ -63,17 +70,39 @@ describe("buildServerRuntimeBundles", () => {
       "composition",
       "provider-event.worker.js",
     );
+    const canonicalWriterWorkerEntry = NodePath.join(
+      serverRoot,
+      "dist-tsc",
+      "features",
+      "agents",
+      "canonical",
+      "canonical-agent-writer.worker.js",
+    );
+    const executionWorkerEntry = NodePath.join(
+      serverRoot,
+      "dist-tsc",
+      "features",
+      "agents",
+      "execution",
+      "execution.worker.js",
+    );
     const serverOutFile = NodePath.join(fixtureRoot, "dist", "server.cjs");
     const ptyHostOutFile = NodePath.join(fixtureRoot, "dist", "pty-host.cjs");
     const providerEventWorkerOutFile = NodePath.join(fixtureRoot, "dist", "provider-event.worker.cjs");
+    const canonicalWriterWorkerOutFile = NodePath.join(fixtureRoot, "dist", "canonical-agent-writer.worker.cjs");
+    const executionWorkerOutFile = NodePath.join(fixtureRoot, "dist", "execution.worker.cjs");
 
     await Promise.all([
       NodeFSPromises.mkdir(NodePath.dirname(ptyHostEntry), { recursive: true }),
       NodeFSPromises.mkdir(NodePath.dirname(providerEventWorkerEntry), { recursive: true }),
+      NodeFSPromises.mkdir(NodePath.dirname(canonicalWriterWorkerEntry), { recursive: true }),
+      NodeFSPromises.mkdir(NodePath.dirname(executionWorkerEntry), { recursive: true }),
     ]);
     await NodeFSPromises.writeFile(serverEntry, 'console.log("server-entry");\n');
     await NodeFSPromises.writeFile(ptyHostEntry, 'console.log("pty-host-entry");\n');
     await NodeFSPromises.writeFile(providerEventWorkerEntry, 'console.log("provider-event-worker");\n');
+    await NodeFSPromises.writeFile(canonicalWriterWorkerEntry, 'console.log("canonical-writer-worker");\n');
+    await NodeFSPromises.writeFile(executionWorkerEntry, 'console.log("execution-worker");\n');
 
     await buildServerRuntimeBundles({
       serverRoot,
@@ -85,8 +114,36 @@ describe("buildServerRuntimeBundles", () => {
     await NodeFSPromises.access(serverOutFile);
     await NodeFSPromises.access(ptyHostOutFile);
     await NodeFSPromises.access(providerEventWorkerOutFile);
+    await NodeFSPromises.access(canonicalWriterWorkerOutFile);
+    await NodeFSPromises.access(executionWorkerOutFile);
     expect(await NodeFSPromises.readFile(serverOutFile, "utf8")).toContain("server-entry");
     expect(await NodeFSPromises.readFile(ptyHostOutFile, "utf8")).toContain("pty-host-entry");
     expect(await NodeFSPromises.readFile(providerEventWorkerOutFile, "utf8")).toContain("provider-event-worker");
+    expect(await NodeFSPromises.readFile(canonicalWriterWorkerOutFile, "utf8")).toContain("canonical-writer-worker");
+    expect(await NodeFSPromises.readFile(executionWorkerOutFile, "utf8")).toContain("execution-worker");
   }, 30_000);
 });
+
+function startAndCloseBundledWorker(workerPath) {
+  const script = `
+    import { pathToFileURL } from "node:url";
+    const worker = new Worker(pathToFileURL(process.env.MCODE_TEST_EXECUTION_WORKER), { type: "module", ref: true });
+    const received = [];
+    const timer = setTimeout(() => { worker.terminate(); process.exit(1); }, 3000);
+    worker.onmessage = (event) => {
+      received.push(event.data.kind);
+      if (event.data.kind === "ready") worker.postMessage({ kind: "close" });
+      if (event.data.kind === "closed") {
+        clearTimeout(timer);
+        worker.terminate();
+        process.stdout.write(received.join(","));
+      }
+    };
+    worker.onerror = () => { clearTimeout(timer); process.exit(1); };
+  `;
+  return NodeChildProcess.execFileSync("bun", ["-e", script], {
+    encoding: "utf8",
+    timeout: 5_000,
+    env: { ...process.env, MCODE_TEST_EXECUTION_WORKER: workerPath },
+  });
+}
@@ -90,7 +90,7 @@ await buildServerRuntimeBundles({
   production: true,
 });
 
-console.log("Server bundles complete: dist/server/server.cjs, dist/server/pty-host.cjs");
+console.log("Server bundles complete: dist/server/server.cjs, dist/server/pty-host.cjs, dist/server/execution.worker.cjs");
 
 const drizzleSrc = NodePath.resolve(serverRoot, "drizzle");
 const drizzleDst = NodePath.resolve(desktopRoot, "dist/server/drizzle");

@@ -160,7 +160,7 @@ const serverEsbuildCfg = {
   ...shared,
   entryPoints: [NodePath.resolve(serverRoot, "dist-tsc/index.js")],
   outfile: serverOutFile,
-  external: ["bun:sqlite", "node-pty", "electron", "koffi"],
+  external: ["bun", "bun:sqlite", "node-pty", "electron", "koffi"],
   banner: {
     js: 'var __importMetaUrl = require("url").pathToFileURL(__filename).href;',
   },

@@ -0,0 +1,10 @@
+CREATE TABLE `canonical_writer_operation_receipts` (
+	`execution_id` text NOT NULL,
+	`operation_id` text NOT NULL,
+	`kind` text NOT NULL,
+	`input_hash` text NOT NULL,
+	`receipt_json` text NOT NULL,
+	`created_at` text DEFAULT (strftime('%Y-%m-%dT%H:%M:%fZ', 'now')) NOT NULL,
+	PRIMARY KEY(`execution_id`, `operation_id`),
+	FOREIGN KEY (`execution_id`) REFERENCES `canonical_agent_turns`(`execution_id`) ON UPDATE no action ON DELETE cascade
+);
@@ -0,0 +1,5 @@
+CREATE TABLE `canonical_writer_live_publication_heads` (
+	`thread_id` text PRIMARY KEY NOT NULL,
+	`last_sequence` integer NOT NULL,
+	FOREIGN KEY (`thread_id`) REFERENCES `threads`(`id`) ON UPDATE no action ON DELETE cascade
+);