Merge branch 'main' into docs/ai-chat-powershell

VectorPeak · web-flow · commit 0efadb843510 · 2026-07-16T13:29:28.000+08:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -80,6 +80,7 @@ Docs: https://docs.openclaw.ai
 - **Control UI New Session reconnects:** rediscover agents, nodes, repository branches, and folder-browser state, refresh derived workspaces, gate unvalidated devices, and block ambiguous retries after Gateway client replacement while preserving the typed task and explicit choices. Fixes #106372.
 - **macOS remote node readiness:** take the main-session key from the node hello snapshot instead of opening an operator connection during node admission, preventing remote tunnel recovery from leaving Computer Use and node exec stuck in lifecycle transition.
 - **Claude CLI context budgets:** honor Anthropic model and per-agent `contextTokens` limits by passing the effective limit to Claude Code's native auto-compactor and persisting the same prepared budget in OpenClaw session state. Fixes #80933. (#93198) Thanks @mushuiyu886.
+- **Transcript read failures:** propagate permission and I/O failures from streaming JSONL session reads instead of treating unreadable transcripts as empty. (#106412) Thanks @zenglingbiao.
 - **Native app connection and relay reliability:** keep Android disconnects stopped across Activity recreation, fail remote camera commands without opening permission prompts, refresh mobile node registration after capability changes, surface iOS onboarding connection failures, cancel stale Talk owners on session switches, reject invalid Watch acknowledgments, preserve Watch events received during startup, and prevent older agent overview requests from replacing newer gateway state.
 - **Gateway source watch:** hand the configured port off from the installed service before starting the tmux watcher, preserve failed panes for attach/capture, and keep explicit alternate-port watches side by side with the managed Gateway.
 - **Claude CLI max-turn diagnostics:** preserve terminal max-turn results with OpenClaw and Claude session context, warn when tool actions may already have run, and stop unsafe auth-profile or model replay for potentially side-effecting turns. (#94130) Thanks @zhangguiping-xydt.
diff --git a/src/config/sessions/transcript-stream.test.ts b/src/config/sessions/transcript-stream.test.ts
@@ -2,7 +2,7 @@
 import fs from "node:fs";
 import os from "node:os";
 import path from "node:path";
-import { afterEach, beforeEach, describe, expect, it } from "vitest";
+import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
 import {
   streamSessionTranscriptLines,
   streamSessionTranscriptLinesReverse,
@@ -23,6 +23,7 @@ beforeEach(() => {
 });
 
 afterEach(() => {
+  vi.restoreAllMocks();
   fs.rmSync(tempDir, { recursive: true, force: true });
 });
 
@@ -58,6 +59,15 @@ describe("streamSessionTranscriptLines", () => {
     expect(lines).toEqual([]);
   });
 
+  it("propagates stat failures other than ENOENT", async () => {
+    const error = Object.assign(new Error("EACCES: permission denied"), { code: "EACCES" });
+    vi.spyOn(fs.promises, "stat").mockRejectedValueOnce(error);
+
+    await expect(
+      collect(streamSessionTranscriptLines("/some/protected/transcript.jsonl")),
+    ).rejects.toBe(error);
+  });
+
   it("forwards malformed JSON lines as raw text so callers can choose to skip them", async () => {
     fs.writeFileSync(
       transcriptPath,
@@ -106,14 +116,23 @@ describe("streamSessionTranscriptLinesReverse", () => {
     expect(lines).toEqual(["third", "second", "first"]);
   });
 
-  it("returns an empty iterator when the file cannot be opened", async () => {
+  it("returns an empty iterator when the file does not exist", async () => {
     const lines = await collect(
       streamSessionTranscriptLinesReverse(path.join(tempDir, "missing.jsonl")),
     );
 
     expect(lines).toEqual([]);
   });
 
+  it("propagates open failures other than ENOENT", async () => {
+    const error = Object.assign(new Error("EACCES: permission denied"), { code: "EACCES" });
+    vi.spyOn(fs.promises, "open").mockRejectedValueOnce(error);
+
+    await expect(
+      collect(streamSessionTranscriptLinesReverse("/some/protected/transcript.jsonl")),
+    ).rejects.toBe(error);
+  });
+
   it("preserves complete lines across chunk boundaries", async () => {
     const longLine = "x".repeat(2048);
     fs.writeFileSync(transcriptPath, `${longLine}\nbeta\ngamma\n`, "utf-8");
diff --git a/src/config/sessions/transcript-stream.ts b/src/config/sessions/transcript-stream.ts
@@ -1,6 +1,7 @@
 // Transcript streaming reads large JSONL files forward or backward without whole-file buffering.
 import fs from "node:fs";
 import readline from "node:readline";
+import { hasErrnoCode } from "../../infra/errors.js";
 import { readFileRangeAsync } from "./file-range.js";
 
 // Shared streaming helpers for JSONL session transcripts.
@@ -40,8 +41,11 @@ export async function* streamSessionTranscriptLines(
   let stat: fs.Stats;
   try {
     stat = await fs.promises.stat(filePath);
-  } catch {
-    return;
+  } catch (error) {
+    if (hasErrnoCode(error, "ENOENT")) {
+      return;
+    }
+    throw error;
   }
   if (!stat.isFile() || stat.size <= 0) {
     return;
@@ -72,7 +76,7 @@ export async function* streamSessionTranscriptLines(
  * Stream the non-empty, trimmed JSONL lines of a transcript file in reverse
  * (newest-first) order.
  *
- * Returns an empty async iterator if the file cannot be opened, is empty, or is
+ * Returns an empty async iterator if the file does not exist, is empty, or is
  * not a regular file. The implementation splits on newline bytes before UTF-8
  * decoding so multibyte characters survive arbitrary chunk boundaries.
  */
@@ -88,8 +92,11 @@ export async function* streamSessionTranscriptLinesReverse(
   let fileHandle: Awaited<ReturnType<typeof fs.promises.open>>;
   try {
     fileHandle = await fs.promises.open(filePath, "r");
-  } catch {
-    return;
+  } catch (error) {
+    if (hasErrnoCode(error, "ENOENT")) {
+      return;
+    }
+    throw error;
   }
   try {
     const stat = await fileHandle.stat();
