import process from "node:process";

import { setTimeout as delay } from "node:timers/promises";

import { pathToFileURL } from "node:url";

import { createPnpmRunnerSpawnSpec } from "../pnpm-runner.mjs";

const PLUGIN_SPEC =

process.env.OPENCLAW_KITCHEN_SINK_NPM_SPEC || "npm:@openclaw/kitchen-sink@latest";

return { command: "node", baseArgs: [resolved], label: resolved };

}

}

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

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

}

function makeEnv() {

}

async function runOpenClaw(runner, args, env, options = {}) {

return runCommand(runner.command, [...runner.baseArgs, ...args], {

const command = resolveOpenClawCommand(runner, args, env, {

stdio: ["ignore", "pipe", "pipe"],

});

return runCommand(command.command, command.args, {

...command.options,

env,

timeoutMs: options.timeoutMs ?? COMMAND_TIMEOUT_MS,

});

}

function resolveOpenClawCommand(runner, args, env, options = {}) {

if (runner.pnpm) {

return createPnpmRunnerSpawnSpec({

env,

pnpmArgs: [...runner.baseArgs, ...args],

stdio: options.stdio,

});

}

return {

command: runner.command,

args: [...runner.baseArgs, ...args],

options: { env, stdio: options.stdio },

};

}

function parseJsonOutput(stdout) {

const trimmed = stdout.trim();

if (!trimmed) {

function startGateway(runner, port, env, logPath) {

const log = fs.openSync(logPath, "w");

const child = childProcess.spawn(

runner.command,

const command = resolveOpenClawCommand(

runner,

[

...runner.baseArgs,

"gateway",

"--port",

String(port),

"--bind",

"loopback",

"--allow-unconfigured",

],

env,

{

env,

stdio: ["ignore", log, log],

detached: false,

},

);

const child = childProcess.spawn(command.command, command.args, {

...command.options,

env,

detached: false,

});

fs.closeSync(log);

return child;

}