vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 06:40:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(docker): keep web search smoke on one gateway connection

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-27 04:51:54 +01:00
parent 6590e0e872
commit 36c08e0288
2 changed files with 40 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
scripts/e2e/openai-web-search-minimal-docker.sh
View File

@@ -359,9 +359,8 @@ node "$entry" gateway health \
--json >/dev/null
cat >/tmp/openclaw-openai-web-search-minimal-client.mjs <<'NODE'
import { execFileSync } from "node:child_process";
import { pathToFileURL } from "node:url";
const entry = process.env.OPENCLAW_ENTRY;
const port = process.env.PORT;
const token = process.env.OPENCLAW_GATEWAY_TOKEN;
const mode = process.argv[2];
@@ -372,65 +371,47 @@ const message =
: "Return exactly OPENCLAW_SCHEMA_E2E_OK.";
const id = mode === "reject" ? "schema-reject" : "schema-success";
if (!entry || !port || !token) throw new Error("missing OPENCLAW_ENTRY/PORT/OPENCLAW_GATEWAY_TOKEN");
if (!port || !token) throw new Error("missing PORT/OPENCLAW_GATEWAY_TOKEN");
const callGatewayUrl = new URL("dist/gateway/call.js", pathToFileURL(`${process.cwd()}/`));
const { callGateway } = await import(callGatewayUrl.href);
const gatewayArgs = [
entry,
"gateway",
"call",
"--url",
`ws://127.0.0.1:${port}`,
"--token",
token,
"--timeout",
"120000",
"--json",
];
function gatewayCall(method, params) {
async function runAgent() {
try {
return {
ok: true,
value: JSON.parse(execFileSync("node", [...gatewayArgs, method, "--params", JSON.stringify(params)], {
encoding: "utf8",
stdio: ["ignore", "pipe", "pipe"],
})),
};
return await callGateway({
method: "agent",
params: {
sessionKey,
message,
thinking: "minimal",
deliver: false,
timeout: 180,
idempotencyKey: id,
},
expectFinal: true,
url: `ws://127.0.0.1:${port}`,
token,
timeoutMs: 240000,
});
} catch (error) {
const stderr = typeof error?.stderr === "string" ? error.stderr : "";
const stdout = typeof error?.stdout === "string" ? error.stdout : "";
const combined = [String(error), stderr.trim(), stdout.trim()].filter(Boolean).join("\n");
return { ok: false, error: new Error(combined) };
if (mode === "reject") {
console.error(String(error));
process.exit(0);
}
throw error;
}
}
const sendRes = gatewayCall("agent", {
sessionKey,
message,
thinking: "minimal",
deliver: false,
timeout: 180,
idempotencyKey: id,
});
if (!sendRes.ok) throw sendRes.error;
const runId =
sendRes.value && typeof sendRes.value === "object" && typeof sendRes.value.runId === "string"
? sendRes.value.runId
: id;
const wait = gatewayCall("agent.wait", { runId, timeoutMs: 180000 });
if (!wait.ok) throw wait.error;
const result = await runAgent();
if (mode === "reject") {
console.error(JSON.stringify(wait.value));
console.error(JSON.stringify(result));
process.exit(0);
}
if (wait.value?.status !== "ok") {
throw new Error(`agent run did not complete successfully: ${JSON.stringify(wait.value)}`);
if (result?.status !== "ok") {
throw new Error(`agent run did not complete successfully: ${JSON.stringify(result)}`);
}
NODE
OPENCLAW_ENTRY="$entry" PORT="$PORT" OPENCLAW_GATEWAY_TOKEN="$TOKEN" node /tmp/openclaw-openai-web-search-minimal-client.mjs success >/tmp/openclaw-openai-web-search-minimal-client-success.log 2>&1
PORT="$PORT" OPENCLAW_GATEWAY_TOKEN="$TOKEN" node /tmp/openclaw-openai-web-search-minimal-client.mjs success >/tmp/openclaw-openai-web-search-minimal-client-success.log 2>&1
node - "$MOCK_REQUEST_LOG" <<'NODE'
const fs = require("node:fs");
@@ -454,7 +435,7 @@ if (success.body.reasoning?.effort === "minimal") {
}
NODE
OPENCLAW_ENTRY="$entry" PORT="$PORT" OPENCLAW_GATEWAY_TOKEN="$TOKEN" node /tmp/openclaw-openai-web-search-minimal-client.mjs reject >/tmp/openclaw-openai-web-search-minimal-client-reject.log 2>&1
PORT="$PORT" OPENCLAW_GATEWAY_TOKEN="$TOKEN" node /tmp/openclaw-openai-web-search-minimal-client.mjs reject >/tmp/openclaw-openai-web-search-minimal-client-reject.log 2>&1
for _ in $(seq 1 80); do
if grep -Fq "$RAW_SCHEMA_ERROR" "$GATEWAY_LOG"; then

9
test/scripts/docker-build-helper.test.ts
View File

@@ -5,6 +5,7 @@ const HELPER_PATH = "scripts/lib/docker-build.sh";
const DOCKER_ALL_SCHEDULER_PATH = "scripts/test-docker-all.mjs";
const DOCKER_E2E_SCENARIOS_PATH = "scripts/lib/docker-e2e-scenarios.mjs";
const INSTALL_E2E_RUNNER_PATH = "scripts/docker/install-sh-e2e/run.sh";
const OPENAI_WEB_SEARCH_MINIMAL_E2E_PATH = "scripts/e2e/openai-web-search-minimal-docker.sh";
const CENTRALIZED_BUILD_SCRIPTS = [
"scripts/docker/setup.sh",
"scripts/e2e/browser-cdp-snapshot-docker.sh",
@@ -86,4 +87,12 @@ describe("docker build helper", () => {
expect(runner).toContain('TURN3_SESSION_ID="${SESSION_ID_PREFIX}-exec-hostname"');
expect(runner).toContain('TURN4_SESSION_ID="${SESSION_ID_PREFIX}-image-write"');
});
it("keeps OpenAI web search smoke on one gateway agent connection", () => {
const runner = readFileSync(OPENAI_WEB_SEARCH_MINIMAL_E2E_PATH, "utf8");
expect(runner).toContain('new URL("dist/gateway/call.js"');
expect(runner).toContain("expectFinal: true");
expect(runner).not.toContain('"agent.wait"');
});
});