return { pnpm: true, baseArgs: ["openclaw"], label: "pnpm openclaw" };

}

function makeEnv() {

export function makeEnv() {

const root = fs.mkdtempSync(path.join(os.tmpdir(), "openclaw-kitchen-sink-rpc-"));

const home = path.join(root, "home");

const stateDir = path.join(home, ".openclaw");

};

}

export async function cleanupKitchenSinkEnv(root, options = {}) {

if (root) {

const attempts = Math.max(1, options.attempts ?? 5);

const delayMs = Math.max(0, options.delayMs ?? 250);

let lastError;

for (let attempt = 1; attempt <= attempts; attempt += 1) {

try {

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

return true;

} catch (error) {

lastError = error;

if (attempt < attempts) {

await delay(delayMs);

}

}

}

if (options.warn !== false) {

const message = lastError instanceof Error ? lastError.message : String(lastError);

console.error(`Kitchen Sink RPC temp root cleanup failed; preserved ${root}: ${message}`);

}

return false;

}

return true;

}

function writeJson(file, value) {

fs.mkdirSync(path.dirname(file), { recursive: true });

fs.writeFileSync(file, `${JSON.stringify(value, null, 2)}\n`);

const port = readPositiveInt(process.env.OPENCLAW_KITCHEN_SINK_RPC_PORT, DEFAULT_PORT);

const { root, env } = makeEnv();

const logPath = path.join(root, "gateway.log");

const keepTmp = process.env.OPENCLAW_KITCHEN_SINK_KEEP_TMP === "1";

let failed = false;

let child;

console.log(`Kitchen Sink RPC walk using ${PLUGIN_SPEC} via ${runner.label}`);

await runOpenClaw(runner, ["plugins", "install", PLUGIN_SPEC], env, {

timeoutMs: INSTALL_TIMEOUT_MS,

});

runner = resolveOpenClawRunner();

console.log(`Kitchen Sink RPC runtime runner: ${runner.label}`);

configureKitchenSink(env, port);

await runOpenClaw(runner, ["plugins", "enable", PLUGIN_ID], env, { timeoutMs: 60000 });

const inspect = parseJsonOutput(

(await runOpenClaw(runner, ["plugins", "inspect", PLUGIN_ID, "--runtime", "--json"], env))

.stdout,

);

if (inspect?.plugin?.status !== "loaded") {

throw new Error(`Kitchen Sink plugin did not inspect as loaded: ${JSON.stringify(inspect)}`);

}

const inspectPlugin = inspect.plugin ?? {};

const inspectProviders = [

...(Array.isArray(inspectPlugin.providerIds) ? inspectPlugin.providerIds : []),

...(Array.isArray(inspectPlugin.providers) ? inspectPlugin.providers : []),

];

assertIncludesAny(inspectProviders, EXPECTED_PROVIDERS, "plugins inspect providers");

const child = await startGateway(runner, port, env, logPath);

const processSamples = [];

const sampleGateway = async () => {

const windowsSampleOptions = runner.pnpm

? { windowsCommandLineNeedles: ["gateway", "--port", String(port)] }

: {};

let sample = await sampleProcess(child.pid, windowsSampleOptions);

if (!sample && process.platform === "win32") {

sample = await sampleWindowsProcessByPort(port);

}

if (sample) {

processSamples.push(sample);

}

return sample;

};

let sampleInFlight = null;

const collectTimedSample = () => {

sampleInFlight ??= sampleGateway().finally(() => {

sampleInFlight = null;

});

return sampleInFlight;

};

let sampleTimer;

try {

console.log(`Kitchen Sink RPC walk using ${PLUGIN_SPEC} via ${runner.label}`);

await runOpenClaw(runner, ["plugins", "install", PLUGIN_SPEC], env, {

timeoutMs: INSTALL_TIMEOUT_MS,

});

runner = resolveOpenClawRunner();

console.log(`Kitchen Sink RPC runtime runner: ${runner.label}`);

configureKitchenSink(env, port);

await runOpenClaw(runner, ["plugins", "enable", PLUGIN_ID], env, { timeoutMs: 60000 });

const inspect = parseJsonOutput(

(await runOpenClaw(runner, ["plugins", "inspect", PLUGIN_ID, "--runtime", "--json"], env))

.stdout,

);

if (inspect?.plugin?.status !== "loaded") {

throw new Error(`Kitchen Sink plugin did not inspect as loaded: ${JSON.stringify(inspect)}`);

}

const inspectPlugin = inspect.plugin ?? {};

const inspectProviders = [

...(Array.isArray(inspectPlugin.providerIds) ? inspectPlugin.providerIds : []),

...(Array.isArray(inspectPlugin.providers) ? inspectPlugin.providers : []),

];

assertIncludesAny(inspectProviders, EXPECTED_PROVIDERS, "plugins inspect providers");

child = await startGateway(runner, port, env, logPath);

const sampleGateway = async () => {

const windowsSampleOptions = runner.pnpm

? { windowsCommandLineNeedles: ["gateway", "--port", String(port)] }

: {};

let sample = await sampleProcess(child.pid, windowsSampleOptions);

if (!sample && process.platform === "win32") {

sample = await sampleWindowsProcessByPort(port);

}

if (sample) {

processSamples.push(sample);

}

return sample;

};

const collectTimedSample = () => {

sampleInFlight ??= sampleGateway().finally(() => {

sampleInFlight = null;

});

return sampleInFlight;

};

await waitForGatewayReady(child, port, logPath);

const initialSample = await sampleGateway();

sampleTimer = setInterval(() => {

);

console.log("Kitchen Sink RPC walk passed");

} catch (error) {

failed = true;

console.error(tailFile(logPath));

throw error;

} finally {

if (sampleTimer) {

clearInterval(sampleTimer);

}

await stopGateway(child);

if (!failed && !keepTmp) {

await cleanupKitchenSinkEnv(root);

} else if (failed || keepTmp) {

console.error(`Kitchen Sink RPC temp root preserved: ${root}`);

}

}

}