}

}

function parseProbePid(raw: string): number | undefined {

const text = raw.trim();

if (!/^[1-9]\d*$/u.test(text)) {

return undefined;

}

const pid = Number(text);

return Number.isSafeInteger(pid) ? pid : undefined;

}

async function readProbePid(pidPath: string): Promise<number | undefined> {

try {

const raw = (await fs.readFile(pidPath, "utf-8")).trim();

const pid = Number.parseInt(raw, 10);

return Number.isInteger(pid) && pid > 0 ? pid : undefined;

return parseProbePid(await fs.readFile(pidPath, "utf-8"));

} catch {

return undefined;

}

const pids: number[] = [];

const seen = new Set<number>();

for (const line of raw.split(/\r?\n/)) {

const pid = Number.parseInt(line.trim(), 10);

if (!Number.isInteger(pid) || pid <= 0 || seen.has(pid)) {

const pid = parseProbePid(line);

if (pid === undefined || seen.has(pid)) {

continue;

}

seen.add(pid);

}

});

it("does not parse malformed probe pid prefixes", async () => {

const root = fs.mkdtempSync(path.join(os.tmpdir(), "openclaw-cron-mcp-client-"));

try {

const pidPath = path.join(root, "probe.pid");

fs.writeFileSync(pidPath, "123abc\n", "utf8");

const startedAt = Date.now();

await expect(waitForProbePid(pidPath, { pollMs: 1, timeoutMs: 20 })).resolves.toBeUndefined();

expect(Date.now() - startedAt).toBeLessThan(1000);

} finally {

fs.rmSync(root, { force: true, recursive: true });

}

});

it("accepts cron finished events only when the run status is ok", () => {

expect(() => assertCronFinishedOk({ status: "ok" })).not.toThrow();

expect(() => assertCronFinishedOk({ status: "error" })).toThrow(