#!/usr/bin/env node

// Runs additional architecture and boundary checks with sharding, concurrency,

// timeout handling, and grouped CI output.

import { spawn } from "node:child_process";

import { performance } from "node:perf_hooks";

const DEFAULT_CHECK_TIMEOUT_MS = 10 * 60 * 1000;

const DEFAULT_OUTPUT_MAX_BYTES = 512 * 1024;

const TIMEOUT_KILL_GRACE_MS = 5_000;

/** Ordered list of supplemental boundary checks used by CI sharding. */

export const BOUNDARY_CHECKS = [

["prompt:snapshots:check", "pnpm", ["prompt:snapshots:check"]],

["plugin-extension-boundary", "pnpm", ["run", "lint:plugins:no-extension-imports"]],

["lint:ui:no-raw-window-open", "pnpm", ["lint:ui:no-raw-window-open"]],

].map(([label, command, args]) => ({ label, command, args }));

/**

* Resolves the configured boundary-check concurrency.

*/

export function resolveConcurrency(value, fallback = 4, label = "concurrency") {

return resolvePositiveInteger(value, fallback, label);

}

/**

* Parses positive integer CLI/env options with a fallback.

*/

export function resolvePositiveInteger(value, fallback, label = "value") {

if (value === undefined || value === null || value === "") {

return fallback;

return parsed;

}

/**

* Parses one N/TOTAL shard selector into zero-based index form.

*/

export function parseShardSpec(value) {

if (!value) {

return null;

return { count, index: index - 1, label: `${index}/${count}` };

}

/**

* Parses a comma-separated list of N/TOTAL shard selectors.

*/

export function parseShardSelection(value) {

if (!value) {

return null;

});

}

/**

* Selects checks whose ordinal belongs to the requested shard set.

*/

export function selectChecksForShard(checks, shardSpec) {

const shards =

typeof shardSpec === "string"

);

}

/**

* Formats a check command for CI group output.

*/

export function formatCommand({ command, args }) {

return [command, ...args].join(" ");

}

/**

* Keeps only the tail of noisy check output so failure logs stay bounded.

*/

export function createBoundedOutputBuffer(maxBytes = DEFAULT_OUTPUT_MAX_BYTES) {

const limit = Math.max(1, maxBytes);

const chunks = [];

};

}

/**

* Runs one boundary check with timeout and process-group termination.

*/

export function runSingleCheck(

check,

{

}

}

/**

* Runs boundary checks with bounded concurrency and returns the failure count.

*/

export async function runChecks(

checks = BOUNDARY_CHECKS,

{

process.env.OPENCLAW_ADDITIONAL_BOUNDARY_CONCURRENCY === undefined

? "OPENCLAW_EXTENSION_BOUNDARY_CONCURRENCY"

: "OPENCLAW_ADDITIONAL_BOUNDARY_CONCURRENCY";

const concurrency = resolveConcurrency(

concurrencyRaw,

4,

concurrencyLabel,

);

const concurrency = resolveConcurrency(concurrencyRaw, 4, concurrencyLabel);

const checkTimeoutMs = resolvePositiveInteger(

process.env.OPENCLAW_ADDITIONAL_BOUNDARY_TIMEOUT_MS,

DEFAULT_CHECK_TIMEOUT_MS,