fix(scripts): cap issue labeler response bodies · openclaw/openclaw@9331ac2

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
`@@ -4,6 +4,7 @@ import { homedir } from "node:os";`
`4`	`4`	`import { dirname, join } from "node:path";`
`5`	`5`	`import { pathToFileURL } from "node:url";`
`6`	`6`	`import { isRecord } from "../src/utils.js";`
	`7`	`+import { readBoundedResponseText as readBoundedBodyText } from "./lib/bounded-response.ts";`
`7`	`8`	`import { parseStrictIntegerOption } from "./lib/dev-tooling-safety.ts";`
`8`	`9`
`9`	`10`	`function writeStdoutLine(message = ""): void {`
`@@ -22,6 +23,7 @@ const WORK_BATCH_SIZE = 500;`
`22`	`23`	`const STATE_VERSION = 1;`
`23`	`24`	`const DEFAULT_OPENAI_TIMEOUT_MS = 60_000;`
`24`	`25`	`const OPENAI_ERROR_BODY_MAX_CHARS = 4096;`
	`26`	`+const OPENAI_RESPONSE_BODY_MAX_BYTES = 256 * 1024;`
`25`	`27`	`const STATE_FILE_NAME = "issue-labeler-state.json";`
`26`	`28`	`const CONFIG_BASE_DIR = process.env.XDG_CONFIG_HOME ?? join(homedir(), ".config");`
`27`	`29`	`const STATE_FILE_PATH = join(CONFIG_BASE_DIR, "openclaw", STATE_FILE_NAME);`
`@@ -322,6 +324,19 @@ async function readBoundedResponseText(`
`322`	`324`	return truncated ? `${text}\n[truncated]` : text;
`323`	`325`	`}`
`324`	`326`
	`327`	`+async function readBoundedOpenAIJson(`
	`328`	`+response: Response,`
	`329`	`+maxBytes = OPENAI_RESPONSE_BODY_MAX_BYTES,`
	`330`	`+): Promise<OpenAIResponse> {`
	`331`	`+const text = await readBoundedBodyText(response, "OpenAI classification", maxBytes, {`
	`332`	`+createTooLargeError: (message) =>`
	`333`	`+Object.assign(new Error(message), {`
	`334`	`+code: "ETOOBIG",`
	`335`	`+}),`
	`336`	`+});`
	`337`	`+return JSON.parse(text) as OpenAIResponse;`
	`338`	`+}`
	`339`	`+`
`325`	`340`	`function logHeader(title: string) {`
`326`	`341`	writeStdoutLine(`\n${title}`);
`327`	`342`	`writeStdoutLine("=".repeat(title.length));`
`@@ -729,7 +744,7 @@ async function classifyItem(`
`729`	`744`	throw new Error(`OpenAI request failed (${response.status}): ${text}`);
`730`	`745`	`}`
`731`	`746`
`732`		`-return (await response.json()) as OpenAIResponse;`
	`747`	`+return await readBoundedOpenAIJson(response);`
`733`	`748`	`},`
`734`	`749`	`);`
`735`	`750`	`const rawText = extractResponseText(payload);`
`@@ -993,6 +1008,7 @@ async function main() {`
`993`	`1008`	`export const testing = {`
`994`	`1009`	`classifyItem,`
`995`	`1010`	`normalizeClassification,`
	`1011`	`+ readBoundedOpenAIJson,`
`996`	`1012`	`readBoundedResponseText,`
`997`	`1013`	`resolveOpenAITimeoutMs,`
`998`	`1014`	`};`

Original file line number	Diff line number	Diff line change
`@@ -10,17 +10,16 @@ const labelItem = {`
`10`	`10`
`11`	`11`	`describe("label-open-issues helpers", () => {`
`12`	`12`	`it("classifies items from OpenAI structured response text", async () => {`
`13`		`-const response = {`
`14`		`-ok: true,`
`15`		`-status: 200,`
`16`		`-json: async () => ({`
	`13`	`+const response = new Response(`
	`14`	`+JSON.stringify({`
`17`	`15`	`output_text: JSON.stringify({`
`18`	`16`	`category: "bug",`
`19`	`17`	`isSupport: true,`
`20`	`18`	`isSkillOnly: false,`
`21`	`19`	`}),`
`22`	`20`	`}),`
`23`		`-} as Response;`
	`21`	`+{ status: 200 },`
	`22`	`+);`
`24`	`23`
`25`	`24`	`await expect(`
`26`	`25`	`testing.classifyItem(labelItem, "issue", {`
`@@ -55,11 +54,7 @@ describe("label-open-issues helpers", () => {`
`55`	`54`	`});`
`56`	`55`
`57`	`56`	`it("times out stalled OpenAI classification body reads", async () => {`
`58`		`-const response = {`
`59`		`-ok: true,`
`60`		`-status: 200,`
`61`		`-json: () => new Promise(() => {}),`
`62`		`-} as Response;`
	`57`	`+const response = new Response(new ReadableStream({}), { status: 200 });`
`63`	`58`	`const request = testing.classifyItem(labelItem, "issue", {`
`64`	`59`	`apiKey: "test-key",`
`65`	`60`	`model: "test-model",`
`@@ -96,6 +91,53 @@ describe("label-open-issues helpers", () => {`
`96`	`91`	`expect(message.length).toBeLessThan(4300);`
`97`	`92`	`});`
`98`	`93`
	`94`	`+it("reads bounded OpenAI classification JSON responses", async () => {`
	`95`	`+await expect(`
	`96`	`+testing.readBoundedOpenAIJson(new Response('{"output_text":"{}"}'), 1024),`
	`97`	`+).resolves.toEqual({ output_text: "{}" });`
	`98`	`+});`
	`99`	`+`
	`100`	`+it("rejects oversized OpenAI classification JSON responses by content length", async () => {`
	`101`	`+let canceled = false;`
	`102`	`+const response = new Response(`
	`103`	`+new ReadableStream({`
	`104`	`+cancel() {`
	`105`	`+canceled = true;`
	`106`	`+},`
	`107`	`+}),`
	`108`	`+{`
	`109`	`+headers: {`
	`110`	`+"content-length": "1025",`
	`111`	`+},`
	`112`	`+},`
	`113`	`+);`
	`114`	`+`
	`115`	`+await expect(testing.readBoundedOpenAIJson(response, 1024)).rejects.toMatchObject({`
	`116`	`+code: "ETOOBIG",`
	`117`	`+message: "OpenAI classification response body exceeded 1024 bytes",`
	`118`	`+});`
	`119`	`+expect(canceled).toBe(true);`
	`120`	`+});`
	`121`	`+`
	`122`	`+it("rejects oversized streamed OpenAI classification JSON responses", async () => {`
	`123`	`+const encoder = new TextEncoder();`
	`124`	`+const response = new Response(`
	`125`	`+new ReadableStream({`
	`126`	`+start(controller) {`
	`127`	`+controller.enqueue(encoder.encode('{"output_text":"'));`
	`128`	`+controller.enqueue(encoder.encode("x".repeat(1024)));`
	`129`	`+controller.enqueue(encoder.encode('"}'));`
	`130`	`+controller.close();`
	`131`	`+},`
	`132`	`+}),`
	`133`	`+);`
	`134`	`+`
	`135`	`+await expect(testing.readBoundedOpenAIJson(response, 1024)).rejects.toMatchObject({`
	`136`	`+code: "ETOOBIG",`
	`137`	`+message: "OpenAI classification response body exceeded 1024 bytes",`
	`138`	`+});`
	`139`	`+});`
	`140`	`+`
`99`	`141`	`it("rejects invalid OpenAI classification timeout values", () => {`
`100`	`142`	`expect(testing.resolveOpenAITimeoutMs("250")).toBe(250);`
`101`	`143`	`expect(() => testing.resolveOpenAITimeoutMs("slow")).toThrow(`

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

推荐订阅源

Recent Commits to openclaw:main