refactor: share e2e text file helpers · openclaw/openclaw@65b0071

Recent Commits to openclaw:main

vincentkoc · 2026-05-30 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,6 @@`
`1`	`1`	`import fs from "node:fs";`
`2`	`2`	`import path from "node:path";`
	`3`	`+import { readTextFileTail, tailText } from "../text-file-utils.mjs";`
`3`	`4`
`4`	`5`	`const command = process.argv[2];`
`5`	`6`	`const readJson = (file) => JSON.parse(fs.readFileSync(file, "utf8"));`
`@@ -49,36 +50,6 @@ function agentErrorPath() {`
`49`	`50`	`return process.env.OPENCLAW_LIVE_PLUGIN_TOOL_AGENT_ERROR_PATH \|\| "/tmp/openclaw-agent.err";`
`50`	`51`	`}`
`51`	`52`
`52`		`-function tailText(text, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`53`		`-if (Buffer.byteLength(text, "utf8") <= maxBytes) {`
`54`		`-return text;`
`55`		`-}`
`56`		`-return Buffer.from(text, "utf8").subarray(-maxBytes).toString("utf8");`
`57`		`-}`
`58`		`-`
`59`		`-function readTextFileTail(file, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`60`		`-let stat;`
`61`		`-try {`
`62`		`-stat = fs.statSync(file);`
`63`		`-} catch {`
`64`		`-return "";`
`65`		`-}`
`66`		`-if (!stat.isFile() \|\| stat.size <= 0) {`
`67`		`-return "";`
`68`		`-}`
`69`		`-`
`70`		`-const length = Math.min(maxBytes, stat.size);`
`71`		`-const start = stat.size - length;`
`72`		`-const fd = fs.openSync(file, "r");`
`73`		`-try {`
`74`		`-const buffer = Buffer.alloc(length);`
`75`		`-const bytesRead = fs.readSync(fd, buffer, 0, length, start);`
`76`		`-return buffer.subarray(0, bytesRead).toString("utf8");`
`77`		`-} finally {`
`78`		`-fs.closeSync(fd);`
`79`		`-}`
`80`		`-}`
`81`		`-`
`82`	`53`	`function scanFileForNeedles(file, pendingNeedles) {`
`83`	`54`	`let stat;`
`84`	`55`	`try {`
`@@ -381,9 +352,9 @@ function assertAgentTurn() {`
`381`	`352`	`const response = JSON.parse(stdout);`
`382`	`353`	`const text = (response.payloads \|\| []).map((payload) => payload?.text \|\| "").join("\n");`
`383`	`354`	`if (!text.includes(expected)) {`
`384`		`-const stderrTail = readTextFileTail(errorPath);`
	`355`	`+const stderrTail = readTextFileTail(errorPath, ERROR_DETAIL_TAIL_BYTES);`
`385`	`356`	`throw new Error(`
`386`		-`live agent reply did not contain tool slug ${expected}:\nstdout tail=${tailText(stdout)}\nstderr tail=${stderrTail}`,
	`357`	+`live agent reply did not contain tool slug ${expected}:\nstdout tail=${tailText(stdout, ERROR_DETAIL_TAIL_BYTES)}\nstderr tail=${stderrTail}`,
`387`	`358`	`);`
`388`	`359`	`}`
`389`	`360`	`const sessionsDir = path.join(stateDir(), "agents", "main", "sessions");`

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`import fs from "node:fs";`
	`2`	`+import { readTextFileTail, tailText } from "../text-file-utils.mjs";`
`2`	`3`
`3`	`4`	`const command = process.argv[2];`
`4`	`5`
`@@ -7,36 +8,6 @@ const REQUEST_LOG_SCAN_CHUNK_BYTES = 64 * 1024;`
`7`	`8`	`const RESPONSE_PREVIEW_BYTES = 8 * 1024;`
`8`	`9`	`const RESPONSE_PREVIEW_COUNT = 5;`
`9`	`10`
`10`		`-function tailText(text, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`11`		`-if (Buffer.byteLength(text, "utf8") <= maxBytes) {`
`12`		`-return text;`
`13`		`-}`
`14`		`-return Buffer.from(text, "utf8").subarray(-maxBytes).toString("utf8");`
`15`		`-}`
`16`		`-`
`17`		`-function readTextFileTail(file, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`18`		`-let stat;`
`19`		`-try {`
`20`		`-stat = fs.statSync(file);`
`21`		`-} catch {`
`22`		`-return "";`
`23`		`-}`
`24`		`-if (!stat.isFile() \|\| stat.size <= 0) {`
`25`		`-return "";`
`26`		`-}`
`27`		`-`
`28`		`-const length = Math.min(maxBytes, stat.size);`
`29`		`-const start = stat.size - length;`
`30`		`-const fd = fs.openSync(file, "r");`
`31`		`-try {`
`32`		`-const buffer = Buffer.alloc(length);`
`33`		`-const bytesRead = fs.readSync(fd, buffer, 0, length, start);`
`34`		`-return buffer.subarray(0, bytesRead).toString("utf8");`
`35`		`-} finally {`
`36`		`-fs.closeSync(fd);`
`37`		`-}`
`38`		`-}`
`39`		`-`
`40`	`11`	`function scanTextFileLines(file, onLine) {`
`41`	`12`	`const fd = fs.openSync(file, "r");`
`42`	`13`	`try {`
`@@ -134,7 +105,7 @@ function assertSuccessRequest() {`
`134`	`105`	`const { responseCount, success, recentResponses } = scanSuccessRequest(logPath);`
`135`	`106`	`if (responseCount < 1) {`
`136`	`107`	`throw new Error(`
`137`		-`mock OpenAI /v1/responses was not used. Request log tail: ${readTextFileTail(logPath)}`,
	`108`	+`mock OpenAI /v1/responses was not used. Request log tail: ${readTextFileTail(logPath, ERROR_DETAIL_TAIL_BYTES)}`,
`138`	`109`	`);`
`139`	`110`	`}`
`140`	`111`	`if (!success) {`

Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@ import {`
`5`	`5`	`assertOpenAiRequestLogUsed,`
`6`	`6`	`} from "../agent-turn-output.mjs";`
`7`	`7`	`import { applyMockOpenAiModelConfig } from "../fixtures/mock-openai-config.mjs";`
	`8`	`+import { readTextFileTail } from "../text-file-utils.mjs";`
`8`	`9`
`9`	`10`	`const command = process.argv[2];`
`10`	`11`
`@@ -22,36 +23,6 @@ function readJson(file) {`
`22`	`23`	`return JSON.parse(fs.readFileSync(file, "utf8"));`
`23`	`24`	`}`
`24`	`25`
`25`		`-function tailText(text, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`26`		`-if (Buffer.byteLength(text, "utf8") <= maxBytes) {`
`27`		`-return text;`
`28`		`-}`
`29`		`-return Buffer.from(text, "utf8").subarray(-maxBytes).toString("utf8");`
`30`		`-}`
`31`		`-`
`32`		`-function readTextFileTail(file, maxBytes = ERROR_DETAIL_TAIL_BYTES) {`
`33`		`-let stat;`
`34`		`-try {`
`35`		`-stat = fs.statSync(file);`
`36`		`-} catch {`
`37`		`-return "";`
`38`		`-}`
`39`		`-if (!stat.isFile() \|\| stat.size <= 0) {`
`40`		`-return "";`
`41`		`-}`
`42`		`-`
`43`		`-const length = Math.min(maxBytes, stat.size);`
`44`		`-const start = stat.size - length;`
`45`		`-const fd = fs.openSync(file, "r");`
`46`		`-try {`
`47`		`-const buffer = Buffer.alloc(length);`
`48`		`-const bytesRead = fs.readSync(fd, buffer, 0, length, start);`
`49`		`-return buffer.subarray(0, bytesRead).toString("utf8");`
`50`		`-} finally {`
`51`		`-fs.closeSync(fd);`
`52`		`-}`
`53`		`-}`
`54`		`-`
`55`	`26`	`function fileContainsText(file, needle) {`
`56`	`27`	`let stat;`
`57`	`28`	`try {`
`@@ -142,7 +113,7 @@ function assertFileContains() {`
`142`	`113`	`const needle = process.argv[4];`
`143`	`114`	`assert(`
`144`	`115`	`fileContainsText(file, needle),`
`145`		-`${file} did not contain ${needle}. Output tail: ${readTextFileTail(file)}`,
	`116`	+`${file} did not contain ${needle}. Output tail: ${readTextFileTail(file, ERROR_DETAIL_TAIL_BYTES)}`,
`146`	`117`	`);`
`147`	`118`	`}`
`148`	`119`

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,31 @@`
	`1`	`+import fs from "node:fs";`
	`2`	`+`
	`3`	`+export function tailText(text, maxBytes) {`
	`4`	`+if (Buffer.byteLength(text, "utf8") <= maxBytes) {`
	`5`	`+return text;`
	`6`	`+}`
	`7`	`+return Buffer.from(text, "utf8").subarray(-maxBytes).toString("utf8");`
	`8`	`+}`
	`9`	`+`
	`10`	`+export function readTextFileTail(file, maxBytes) {`
	`11`	`+let stat;`
	`12`	`+try {`
	`13`	`+stat = fs.statSync(file);`
	`14`	`+} catch {`
	`15`	`+return "";`
	`16`	`+}`
	`17`	`+if (!stat.isFile() \|\| stat.size <= 0) {`
	`18`	`+return "";`
	`19`	`+}`
	`20`	`+`
	`21`	`+const length = Math.min(maxBytes, stat.size);`
	`22`	`+const start = stat.size - length;`
	`23`	`+const fd = fs.openSync(file, "r");`
	`24`	`+try {`
	`25`	`+const buffer = Buffer.alloc(length);`
	`26`	`+const bytesRead = fs.readSync(fd, buffer, 0, length, start);`
	`27`	`+return buffer.subarray(0, bytesRead).toString("utf8");`
	`28`	`+} finally {`
	`29`	`+fs.closeSync(fd);`
	`30`	`+}`
	`31`	`+}`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main