test: stabilize release gate coverage

Author: BunsDev

apps/server/integration/orchestrationEngine.integration.test.ts

@@ -330,185 +330,188 @@ it.live.skipIf(!process.env.CODEX_BINARY_PATH)(
     ),
 );
 
-it.live("runs multi-turn file edits and persists checkpoint diffs", () =>
-  withHarness((harness) =>
-    Effect.gen(function* () {
-      yield* seedProjectAndThread(harness);
+it.live(
+  "runs multi-turn file edits and persists checkpoint diffs",
+  () =>
+    withHarness((harness) =>
+      Effect.gen(function* () {
+        yield* seedProjectAndThread(harness);
 
-      yield* harness.adapterHarness!.queueTurnResponseForNextSession({
-        events: [
-          {
-            type: "turn.started",
-            ...runtimeBase("evt-multi-1", "2026-02-24T10:01:00.000Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-          },
-          {
-            type: "tool.started",
-            ...runtimeBase("evt-multi-2", "2026-02-24T10:01:00.100Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            toolKind: "command",
-            title: "Edit file",
-            detail: "README.md",
-          },
-          {
-            type: "tool.completed",
-            ...runtimeBase("evt-multi-3", "2026-02-24T10:01:00.200Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            toolKind: "command",
-            title: "Edit file",
-            detail: "README.md",
-          },
-          {
-            type: "message.delta",
-            ...runtimeBase("evt-multi-4", "2026-02-24T10:01:00.300Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            delta: "Updated README to v2.\n",
-          },
-          {
-            type: "turn.completed",
-            ...runtimeBase("evt-multi-5", "2026-02-24T10:01:00.400Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            status: "completed",
-          },
-        ],
-        mutateWorkspace: ({ cwd }) =>
-          Effect.sync(() => {
-            fs.writeFileSync(path.join(cwd, "README.md"), "v2\n", "utf8");
-          }),
-      });
+        yield* harness.adapterHarness!.queueTurnResponseForNextSession({
+          events: [
+            {
+              type: "turn.started",
+              ...runtimeBase("evt-multi-1", "2026-02-24T10:01:00.000Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+            },
+            {
+              type: "tool.started",
+              ...runtimeBase("evt-multi-2", "2026-02-24T10:01:00.100Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              toolKind: "command",
+              title: "Edit file",
+              detail: "README.md",
+            },
+            {
+              type: "tool.completed",
+              ...runtimeBase("evt-multi-3", "2026-02-24T10:01:00.200Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              toolKind: "command",
+              title: "Edit file",
+              detail: "README.md",
+            },
+            {
+              type: "message.delta",
+              ...runtimeBase("evt-multi-4", "2026-02-24T10:01:00.300Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              delta: "Updated README to v2.\n",
+            },
+            {
+              type: "turn.completed",
+              ...runtimeBase("evt-multi-5", "2026-02-24T10:01:00.400Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              status: "completed",
+            },
+          ],
+          mutateWorkspace: ({ cwd }) =>
+            Effect.sync(() => {
+              fs.writeFileSync(path.join(cwd, "README.md"), "v2\n", "utf8");
+            }),
+        });
 
-      yield* startTurn({
-        harness,
-        commandId: "cmd-turn-start-multi-1",
-        messageId: "msg-user-multi-1",
-        text: "Make first edit",
-      });
-      yield* harness.waitForReceipt(
-        (receipt): receipt is CheckpointDiffFinalizedReceipt =>
-          receipt.type === "checkpoint.diff.finalized" &&
-          receipt.threadId === THREAD_ID &&
-          receipt.checkpointTurnCount === 1,
-      );
+        yield* startTurn({
+          harness,
+          commandId: "cmd-turn-start-multi-1",
+          messageId: "msg-user-multi-1",
+          text: "Make first edit",
+        });
+        yield* harness.waitForReceipt(
+          (receipt): receipt is CheckpointDiffFinalizedReceipt =>
+            receipt.type === "checkpoint.diff.finalized" &&
+            receipt.threadId === THREAD_ID &&
+            receipt.checkpointTurnCount === 1,
+        );
 
-      yield* harness.waitForThread(
-        THREAD_ID,
-        (entry) => entry.checkpoints.length === 1 && entry.session?.threadId === "thread-1",
-      );
+        yield* harness.waitForThread(
+          THREAD_ID,
+          (entry) => entry.checkpoints.length === 1 && entry.session?.threadId === "thread-1",
+        );
 
-      yield* harness.adapterHarness!.queueTurnResponse(THREAD_ID, {
-        events: [
-          {
-            type: "turn.started",
-            ...runtimeBase("evt-multi-6", "2026-02-24T10:02:00.000Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-          },
-          {
-            type: "message.delta",
-            ...runtimeBase("evt-multi-7", "2026-02-24T10:02:00.100Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            delta: "Updated README to v3.\n",
-          },
-          {
-            type: "turn.completed",
-            ...runtimeBase("evt-multi-8", "2026-02-24T10:02:00.200Z"),
-            threadId: THREAD_ID,
-            turnId: FIXTURE_TURN_ID,
-            status: "completed",
-          },
-        ],
-        mutateWorkspace: ({ cwd }) =>
-          Effect.sync(() => {
-            fs.writeFileSync(path.join(cwd, "README.md"), "v3\n", "utf8");
-          }),
-      });
+        yield* harness.adapterHarness!.queueTurnResponse(THREAD_ID, {
+          events: [
+            {
+              type: "turn.started",
+              ...runtimeBase("evt-multi-6", "2026-02-24T10:02:00.000Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+            },
+            {
+              type: "message.delta",
+              ...runtimeBase("evt-multi-7", "2026-02-24T10:02:00.100Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              delta: "Updated README to v3.\n",
+            },
+            {
+              type: "turn.completed",
+              ...runtimeBase("evt-multi-8", "2026-02-24T10:02:00.200Z"),
+              threadId: THREAD_ID,
+              turnId: FIXTURE_TURN_ID,
+              status: "completed",
+            },
+          ],
+          mutateWorkspace: ({ cwd }) =>
+            Effect.sync(() => {
+              fs.writeFileSync(path.join(cwd, "README.md"), "v3\n", "utf8");
+            }),
+        });
 
-      yield* startTurn({
-        harness,
-        commandId: "cmd-turn-start-multi-2",
-        messageId: "msg-user-multi-2",
-        text: "Make second edit",
-      });
-      const secondReceipt = yield* harness.waitForReceipt(
-        (receipt): receipt is CheckpointDiffFinalizedReceipt =>
-          receipt.type === "checkpoint.diff.finalized" &&
-          receipt.threadId === THREAD_ID &&
-          receipt.checkpointTurnCount === 2,
-      );
-      if (secondReceipt.type !== "checkpoint.diff.finalized") {
-        throw new Error("Expected checkpoint.diff.finalized receipt.");
-      }
-      assert.equal(secondReceipt.status, "ready");
-      yield* harness.waitForReceipt(
-        (receipt): receipt is TurnProcessingQuiescedReceipt =>
-          receipt.type === "turn.processing.quiesced" &&
-          receipt.threadId === THREAD_ID &&
-          receipt.checkpointTurnCount === 2,
-      );
+        yield* startTurn({
+          harness,
+          commandId: "cmd-turn-start-multi-2",
+          messageId: "msg-user-multi-2",
+          text: "Make second edit",
+        });
+        const secondReceipt = yield* harness.waitForReceipt(
+          (receipt): receipt is CheckpointDiffFinalizedReceipt =>
+            receipt.type === "checkpoint.diff.finalized" &&
+            receipt.threadId === THREAD_ID &&
+            receipt.checkpointTurnCount === 2,
+        );
+        if (secondReceipt.type !== "checkpoint.diff.finalized") {
+          throw new Error("Expected checkpoint.diff.finalized receipt.");
+        }
+        assert.equal(secondReceipt.status, "ready");
+        yield* harness.waitForReceipt(
+          (receipt): receipt is TurnProcessingQuiescedReceipt =>
+            receipt.type === "turn.processing.quiesced" &&
+            receipt.threadId === THREAD_ID &&
+            receipt.checkpointTurnCount === 2,
+        );
 
-      const secondTurnThread = yield* harness.waitForThread(
-        THREAD_ID,
-        (entry) =>
-          entry.latestTurn?.turnId === "turn-2" &&
-          entry.checkpoints.length === 2 &&
-          entry.checkpoints.some((checkpoint) => checkpoint.checkpointTurnCount === 2),
-      );
-      const secondCheckpoint = secondTurnThread.checkpoints.find(
-        (checkpoint) => checkpoint.checkpointTurnCount === 2,
-      );
-      assert.equal(
-        secondCheckpoint?.files.some((file) => file.path === "README.md"),
-        true,
-      );
+        const secondTurnThread = yield* harness.waitForThread(
+          THREAD_ID,
+          (entry) =>
+            entry.latestTurn?.turnId === "turn-2" &&
+            entry.checkpoints.length === 2 &&
+            entry.checkpoints.some((checkpoint) => checkpoint.checkpointTurnCount === 2),
+        );
+        const secondCheckpoint = secondTurnThread.checkpoints.find(
+          (checkpoint) => checkpoint.checkpointTurnCount === 2,
+        );
+        assert.equal(
+          secondCheckpoint?.files.some((file) => file.path === "README.md"),
+          true,
+        );
 
-      const checkpointRows = yield* harness.checkpointRepository.listByThreadId({
-        threadId: THREAD_ID,
-      });
-      assert.deepEqual(
-        checkpointRows.map((row) => row.checkpointTurnCount),
-        [1, 2],
-      );
+        const checkpointRows = yield* harness.checkpointRepository.listByThreadId({
+          threadId: THREAD_ID,
+        });
+        assert.deepEqual(
+          checkpointRows.map((row) => row.checkpointTurnCount),
+          [1, 2],
+        );
 
-      const incrementalDiff = yield* harness.checkpointStore.diffCheckpoints({
-        cwd: harness.workspaceDir,
-        fromCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 1),
-        toCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 2),
-        fallbackFromToHead: false,
-      });
-      assert.equal(incrementalDiff.includes("README.md"), true);
+        const incrementalDiff = yield* harness.checkpointStore.diffCheckpoints({
+          cwd: harness.workspaceDir,
+          fromCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 1),
+          toCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 2),
+          fallbackFromToHead: false,
+        });
+        assert.equal(incrementalDiff.includes("README.md"), true);
 
-      const fullDiff = yield* harness.checkpointStore.diffCheckpoints({
-        cwd: harness.workspaceDir,
-        fromCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 0),
-        toCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 2),
-        fallbackFromToHead: false,
-      });
-      assert.equal(fullDiff.includes("README.md"), true);
+        const fullDiff = yield* harness.checkpointStore.diffCheckpoints({
+          cwd: harness.workspaceDir,
+          fromCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 0),
+          toCheckpointRef: checkpointRefForThreadTurn(THREAD_ID, 2),
+          fallbackFromToHead: false,
+        });
+        assert.equal(fullDiff.includes("README.md"), true);
 
-      assert.equal(
-        gitShowFileAtRef(
-          harness.workspaceDir,
-          checkpointRefForThreadTurn(THREAD_ID, 1),
-          "README.md",
-        ),
-        "v2\n",
-      );
-      assert.equal(
-        gitShowFileAtRef(
-          harness.workspaceDir,
-          checkpointRefForThreadTurn(THREAD_ID, 2),
-          "README.md",
-        ),
-        "v3\n",
-      );
-    }),
-  ),
+        assert.equal(
+          gitShowFileAtRef(
+            harness.workspaceDir,
+            checkpointRefForThreadTurn(THREAD_ID, 1),
+            "README.md",
+          ),
+          "v2\n",
+        );
+        assert.equal(
+          gitShowFileAtRef(
+            harness.workspaceDir,
+            checkpointRefForThreadTurn(THREAD_ID, 2),
+            "README.md",
+          ),
+          "v3\n",
+        );
+      }),
+    ),
+  30_000,
 );
 
 it.live("tracks approval requests and resolves pending approvals on user response", () =>

apps/server/src/git/Layers/GitCore.test.ts

@@ -199,16 +199,19 @@ it.layer(TestLayer)("git integration", (it) => {
       }),
     );
 
-    it.effect("does not include detached HEAD pseudo-refs as branches", () =>
-      Effect.gen(function* () {
-        const tmp = yield* makeTmpDir();
-        yield* initRepoWithCommit(tmp);
-        yield* git(tmp, ["checkout", "--detach", "HEAD"]);
+    it.effect(
+      "does not include detached HEAD pseudo-refs as branches",
+      () =>
+        Effect.gen(function* () {
+          const tmp = yield* makeTmpDir();
+          yield* initRepoWithCommit(tmp);
+          yield* git(tmp, ["checkout", "--detach", "HEAD"]);
 
-        const result = yield* (yield* GitCore).listBranches({ cwd: tmp });
-        expect(result.branches.some((branch) => branch.name.startsWith("("))).toBe(false);
-        expect(result.branches.some((branch) => branch.current)).toBe(false);
-      }),
+          const result = yield* (yield* GitCore).listBranches({ cwd: tmp });
+          expect(result.branches.some((branch) => branch.name.startsWith("("))).toBe(false);
+          expect(result.branches.some((branch) => branch.current)).toBe(false);
+        }),
+      30_000,
     );
 
     it.effect("keeps current branch first and sorts the remaining branches by recency", () =>