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

test: bound docker fs bridge probes

Browse Source
This commit is contained in:
Peter Steinberger
2026-04-13 18:25:50 -07:00
parent 3deea5a426
commit 73d3cf9920
1 changed files with 33 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/agents/sandbox/fs-bridge.e2e-docker.test.ts
View File

@@ -11,13 +11,32 @@ type DockerExecResult = {
code: number;
};
async function execDockerRawForTest(args: string[]): Promise<DockerExecResult> {
async function execDockerRawForTest(
args: string[],
opts?: { timeoutMs?: number },
): Promise<DockerExecResult> {
return await new Promise<DockerExecResult>((resolve) => {
const child = spawn("docker", args, {
stdio: ["ignore", "pipe", "pipe"],
});
const timeoutMs = opts?.timeoutMs ?? 30_000;
let stdout = "";
let stderr = "";
let settled = false;
const finish = (result: DockerExecResult) => {
if (settled) {
return;
}
settled = true;
clearTimeout(timeout);
resolve(result);
};
const timeout = setTimeout(() => {
child.kill("SIGKILL");
const command = `docker ${args.join(" ")}`;
finish({ stdout, stderr: stderr || `${command} timed out`, code: 124 });
}, timeoutMs);
timeout.unref();
child.stdout?.on("data", (chunk) => {
stdout += chunk.toString();
});
@@ -25,10 +44,10 @@ async function execDockerRawForTest(args: string[]): Promise<DockerExecResult> {
stderr += chunk.toString();
});
child.on("error", () => {
resolve({ stdout: "", stderr: "", code: 1 });
finish({ stdout: "", stderr: "", code: 1 });
});
child.on("close", (code) => {
resolve({ stdout, stderr, code: code ?? 0 });
finish({ stdout, stderr, code: code ?? 0 });
});
});
}
@@ -43,18 +62,20 @@ async function execDockerForTest(args: string[]): Promise<void> {
async function sandboxImageReady(): Promise<boolean> {
try {
const dockerVersion = await execDockerRawForTest(["version"]);
const dockerVersion = await execDockerRawForTest(["version"], { timeoutMs: 5_000 });
if (dockerVersion.code !== 0) {
return false;
}
const pythonCheck = await execDockerRawForTest([
"run",
"--rm",
"--entrypoint",
"python3",
DEFAULT_SANDBOX_IMAGE,
"--version",
]);
const imageCheck = await execDockerRawForTest(["image", "inspect", DEFAULT_SANDBOX_IMAGE], {
timeoutMs: 5_000,
});
if (imageCheck.code !== 0) {
return false;
}
const pythonCheck = await execDockerRawForTest(
["run", "--rm", "--entrypoint", "python3", DEFAULT_SANDBOX_IMAGE, "--version"],
{ timeoutMs: 15_000 },
);
return pythonCheck.code === 0;
} catch {
return false;