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

fix(test): tolerate channel readiness degradation

Browse Source
This commit is contained in:
Vincent Koc
2026-05-01 04:49:25 -07:00
parent 2ea47988dd
commit c3bac63c1b
1 changed files with 38 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
scripts/e2e/lib/bundled-plugin-install-uninstall/runtime-smoke.mjs
View File

@@ -228,11 +228,28 @@ async function waitForReady(params) {
} catch (error) {
lastError = error instanceof Error ? error.message : String(error);
}
if (logShowsGatewayReady(params.logPath) && (await httpOk(params.port, "/healthz"))) {
return;
}
await delay(250);
}
throw new Error(`gateway did not become ready: ${lastError}\n${tailFile(params.logPath)}`);
}
function logShowsGatewayReady(logPath) {
const log = fs.existsSync(logPath) ? fs.readFileSync(logPath, "utf8") : "";
return log.includes("[gateway] ready");
}
async function httpOk(port, pathName) {
try {
const res = await fetch(`http://127.0.0.1:${port}${pathName}`);
return res.ok;
} catch {
return false;
}
}
async function assertHttpOk(port, pathName) {
const res = await fetch(`http://127.0.0.1:${port}${pathName}`);
if (!res.ok) {
@@ -240,6 +257,19 @@ async function assertHttpOk(port, pathName) {
}
}
async function assertReadyzProbe(options) {
const res = await fetch(`http://127.0.0.1:${options.port}/readyz`);
if (res.ok) {
return;
}
if (!options.allowDegradedReadyz) {
throw new Error(`/readyz returned HTTP ${res.status}`);
}
console.log(
`Runtime readyz smoke degraded for ${options.pluginId}: /readyz returned HTTP ${res.status}`,
);
}
async function rpcCall(method, params, options) {
const args = [
options.entrypoint,
@@ -351,7 +381,13 @@ async function smokePlugin(pluginId, pluginDir, requiresConfig, pluginIndex) {
});
try {
await waitForReady({ child, port, logPath });
await assertBaseGatewayProbes({ entrypoint, port, env: process.env });
await assertBaseGatewayProbes({
entrypoint,
port,
env: process.env,
pluginId,
allowDegradedReadyz: plan.channels.length > 0,
});
await runManifestProbes(plan, { entrypoint, port, env: process.env, pluginId });
await runWatchdog({ child, logPath, port, entrypoint, env: process.env, pluginId });
console.log(`Runtime smoke passed for ${pluginId}`);
@@ -365,7 +401,7 @@ async function smokePlugin(pluginId, pluginDir, requiresConfig, pluginIndex) {
async function assertBaseGatewayProbes(options) {
await assertHttpOk(options.port, "/healthz");
await assertHttpOk(options.port, "/readyz");
await assertReadyzProbe(options);
await rpcCall("health", {}, options);
}