refactor: share e2e mock http helpers · openclaw/openclaw@be6cac3

Recent Commits to openclaw:main

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

File tree

- - openai-web-search-minimal

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,29 @@`
	`1`	`+export function readBody(req) {`
	`2`	`+return new Promise((resolve, reject) => {`
	`3`	`+let body = "";`
	`4`	`+req.setEncoding("utf8");`
	`5`	`+req.on("data", (chunk) => {`
	`6`	`+body += chunk;`
	`7`	`+});`
	`8`	`+req.on("end", () => resolve(body));`
	`9`	`+req.on("error", reject);`
	`10`	`+});`
	`11`	`+}`
	`12`	`+`
	`13`	`+export function writeJson(res, status, body) {`
	`14`	`+res.writeHead(status, { "content-type": "application/json" });`
	`15`	`+res.end(JSON.stringify(body));`
	`16`	`+}`
	`17`	`+`
	`18`	`+export function writeSse(res, events) {`
	`19`	`+res.writeHead(200, {`
	`20`	`+"content-type": "text/event-stream",`
	`21`	`+"cache-control": "no-store",`
	`22`	`+connection: "keep-alive",`
	`23`	`+});`
	`24`	`+for (const event of events) {`
	`25`	+res.write(`data: ${JSON.stringify(event)}\n\n`);
	`26`	`+}`
	`27`	`+res.write("data: [DONE]\n\n");`
	`28`	`+res.end();`
	`29`	`+}`

Original file line number	Diff line number	Diff line change
`@@ -1,29 +1,13 @@`
`1`	`1`	`import fs from "node:fs";`
`2`	`2`	`import http from "node:http";`
`3`	`3`	`import { readPositiveIntEnv } from "../env-limits.mjs";`
	`4`	`+import { readBody, writeJson, writeSse } from "../mock-openai-http.mjs";`
`4`	`5`
`5`	`6`	`const port = readPositiveIntEnv("MOCK_PORT");`
`6`	`7`	`const requestLog = process.env.MOCK_REQUEST_LOG;`
`7`	`8`	`const successMarker = process.env.SUCCESS_MARKER;`
`8`	`9`	`const rawSchemaError = process.env.RAW_SCHEMA_ERROR;`
`9`	`10`
`10`		`-function readBody(req) {`
`11`		`-return new Promise((resolve, reject) => {`
`12`		`-let body = "";`
`13`		`-req.setEncoding("utf8");`
`14`		`-req.on("data", (chunk) => {`
`15`		`-body += chunk;`
`16`		`-});`
`17`		`-req.on("end", () => resolve(body));`
`18`		`-req.on("error", reject);`
`19`		`-});`
`20`		`-}`
`21`		`-`
`22`		`-function writeJson(res, status, body) {`
`23`		`-res.writeHead(status, { "content-type": "application/json" });`
`24`		`-res.end(JSON.stringify(body));`
`25`		`-}`
`26`		`-`
`27`	`11`	`function writeOpenAiReject(res) {`
`28`	`12`	`writeJson(res, 400, {`
`29`	`13`	`error: {`
`@@ -97,19 +81,6 @@ function responseEvents(text) {`
`97`	`81`	`];`
`98`	`82`	`}`
`99`	`83`
`100`		`-function writeSse(res, events) {`
`101`		`-res.writeHead(200, {`
`102`		`-"content-type": "text/event-stream",`
`103`		`-"cache-control": "no-store",`
`104`		`-connection: "keep-alive",`
`105`		`-});`
`106`		`-for (const event of events) {`
`107`		-res.write(`data: ${JSON.stringify(event)}\n\n`);
`108`		`-}`
`109`		`-res.write("data: [DONE]\n\n");`
`110`		`-res.end();`
`111`		`-}`
`112`		`-`
`113`	`84`	`const server = http.createServer(async (req, res) => {`
`114`	`85`	`const url = new URL(req.url ?? "/", "http://127.0.0.1");`
`115`	`86`	`if (req.method === "GET" && url.pathname === "/health") {`

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,7 @@`
`1`	`1`	`import fs from "node:fs";`
`2`	`2`	`import http from "node:http";`
`3`	`3`	`import { readPositiveIntEnv } from "./lib/env-limits.mjs";`
	`4`	`+import { readBody, writeJson, writeSse } from "./lib/mock-openai-http.mjs";`
`4`	`5`
`5`	`6`	`const port =`
`6`	`7`	`process.env.MOCK_PORT != null`
`@@ -9,23 +10,6 @@ const port =`
`9`	`10`	`const successMarker = process.env.SUCCESS_MARKER ?? "OPENCLAW_E2E_OK";`
`10`	`11`	`const requestLog = process.env.MOCK_REQUEST_LOG;`
`11`	`12`
`12`		`-function readBody(req) {`
`13`		`-return new Promise((resolve, reject) => {`
`14`		`-let body = "";`
`15`		`-req.setEncoding("utf8");`
`16`		`-req.on("data", (chunk) => {`
`17`		`-body += chunk;`
`18`		`-});`
`19`		`-req.on("end", () => resolve(body));`
`20`		`-req.on("error", reject);`
`21`		`-});`
`22`		`-}`
`23`		`-`
`24`		`-function writeJson(res, status, body) {`
`25`		`-res.writeHead(status, { "content-type": "application/json" });`
`26`		`-res.end(JSON.stringify(body));`
`27`		`-}`
`28`		`-`
`29`	`13`	`function responseEvents(text) {`
`30`	`14`	`const itemId = "msg_e2e_1";`
`31`	`15`	`return [`
`@@ -88,19 +72,6 @@ function responseEvents(text) {`
`88`	`72`	`];`
`89`	`73`	`}`
`90`	`74`
`91`		`-function writeSse(res, events) {`
`92`		`-res.writeHead(200, {`
`93`		`-"content-type": "text/event-stream",`
`94`		`-"cache-control": "no-store",`
`95`		`-connection: "keep-alive",`
`96`		`-});`
`97`		`-for (const event of events) {`
`98`		-res.write(`data: ${JSON.stringify(event)}\n\n`);
`99`		`-}`
`100`		`-res.write("data: [DONE]\n\n");`
`101`		`-res.end();`
`102`		`-}`
`103`		`-`
`104`	`75`	`function writeChatCompletion(res, stream, text = successMarker) {`
`105`	`76`	`if (stream) {`
`106`	`77`	`writeSse(res, [`

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

推荐订阅源

Recent Commits to openclaw:main

File tree