// Measures plugin lifecycle matrix E2E command timings.

import { spawn } from "node:child_process";

import { spawn, spawnSync } from "node:child_process";

import fs from "node:fs";

import path from "node:path";

return value;

}

function readPositiveIntEnvOrGetconf(name, variable) {

if (process.env[name] !== undefined) {

return readPositiveIntEnv(name, "");

}

const result = spawnSync("getconf", [variable], { encoding: "utf8" });

if (result.error || result.status !== 0) {

const details =

result.error?.message || result.stderr.trim() || `exit ${String(result.status)}`;

throw new Error(

`failed to derive ${name} from getconf ${variable}: ${details}; set ${name} explicitly`,

);

}

return readPositiveIntEnv(name, result.stdout);

}

function readPositiveNumberEnv(name, fallback) {

const text = String(process.env[name] ?? fallback).trim();

if (!/^\d+(?:\.\d+)?$/u.test(text)) {

return value;

}

const pageSize = readPositiveIntEnv("OPENCLAW_PROC_PAGE_SIZE", 4096);

const clockTicks = readPositiveIntEnv("OPENCLAW_PROC_CLK_TCK", 100);

const pollMs = readPositiveIntEnv("OPENCLAW_PLUGIN_LIFECYCLE_METRIC_POLL_MS", 100);

const timeoutMs = readPositiveIntEnv("OPENCLAW_PLUGIN_LIFECYCLE_PHASE_TIMEOUT_MS", 300000);

const timeoutKillGraceMs = readPositiveIntEnv(

process.exit(2);

}

// /proc RSS is in host pages and CPU times are in host clock ticks. Query the

// live units so 64 KiB ARM kernels do not under-report resource use.

const pageSize = readPositiveIntEnvOrGetconf("OPENCLAW_PROC_PAGE_SIZE", "PAGESIZE");

const clockTicks = readPositiveIntEnvOrGetconf("OPENCLAW_PROC_CLK_TCK", "CLK_TCK");

function readProcSnapshot() {

const stats = new Map();

for (const entry of fs.readdirSync("/proc", { withFileTypes: true })) {

// Plugin Lifecycle Measure tests cover plugin lifecycle measure script behavior.

import { spawn, spawnSync, type ChildProcess } from "node:child_process";

import { existsSync, mkdtempSync, readFileSync, rmSync } from "node:fs";

import {

chmodSync,

existsSync,

mkdirSync,

mkdtempSync,

readFileSync,

rmSync,

writeFileSync,

} from "node:fs";

import { tmpdir } from "node:os";

import path from "node:path";

import { afterEach, describe, expect, it } from "vitest";

return dir;

}

function writeFakeGetconf(dir: string, body: string): string {

const binDir = path.join(dir, "bin");

mkdirSync(binDir);

const getconfPath = path.join(binDir, "getconf");

writeFileSync(getconfPath, `#!/bin/sh\n${body}\n`, "utf8");

chmodSync(getconfPath, 0o755);

return binDir;

}

function pidExists(pid: number): boolean {

try {

process.kill(pid, 0);

});

describe("plugin lifecycle resource sampler", () => {

it.runIf(process.platform === "linux")(

"derives proc units from getconf when overrides are absent",

() => {

const dir = makeTempDir();

const summary = path.join(dir, "summary.tsv");

const logPath = path.join(dir, "getconf.log");

const binDir = writeFakeGetconf(

dir,

'printf "%s\\n" "$1" >>"$GETCONF_LOG"\ncase "$1" in PAGESIZE) echo 16384 ;; CLK_TCK) echo 250 ;; esac',

);

const env = {

...process.env,

GETCONF_LOG: logPath,

PATH: `${binDir}:${process.env.PATH ?? ""}`,

};

delete env.OPENCLAW_PROC_PAGE_SIZE;

delete env.OPENCLAW_PROC_CLK_TCK;

const result = spawnSync(

process.execPath,

[scriptPath, summary, "getconf-units", "--", process.execPath, "-e", ""],

{

cwd: process.cwd(),

encoding: "utf8",

env,

timeout: 5000,

},

);

expect(readFileSync(logPath, "utf8")).toBe("PAGESIZE\nCLK_TCK\n");

expect(result.stderr).not.toContain("failed to derive OPENCLAW_PROC");

},

);

it("rejects loose numeric env values instead of parsing prefixes", () => {

const dir = makeTempDir();

const summary = path.join(dir, "summary.tsv");