],

],

]);

const BROAD_ONLY_TEST_HELPERS = new Set(["test/helpers/poll.ts"]);

const TOOLING_SOURCE_TEST_TARGETS = new Map([

[".crabbox.yaml", ["test/scripts/package-acceptance-workflow.test.ts"]],

[".github/workflows/ci.yml", ["test/scripts/ci-workflow-guards.test.ts"]],

if (siblingTest && !shouldCombineSiblingTestWithImportGraph(changedPath)) {

return [siblingTest];

}

if (BROAD_ONLY_TEST_HELPERS.has(changedPath)) {

return null;

}

if (shouldRouteChangedTargetWithoutImportGraph(changedPath)) {

return changedPath.startsWith("ui/src/") ? [changedPath] : null;

}

export { extractFirstTextBlock };

export type ChatEventPayload = {

runId?: string;

sessionKey?: string;

state?: string;

message?: unknown;

};

export type GatewayInstance = OpenClawTestInstance;

const GATEWAY_CONNECT_STATUS_TIMEOUT_MS = 10_000;

const suffix = lastError instanceof Error ? `: ${lastError.message}` : "";

throw new Error(`timeout waiting for node status for ${nodeId}${suffix}`);

}

export async function waitForChatFinalEvent(params: {

events: ChatEventPayload[];

runId: string;

sessionKey: string;

timeoutMs?: number;

}): Promise<ChatEventPayload> {

const deadline = Date.now() + (params.timeoutMs ?? 45_000);

while (Date.now() < deadline) {

const match = params.events.find(

(evt) =>

evt.runId === params.runId && evt.sessionKey === params.sessionKey && evt.state === "final",

);

if (match) {

return match;

}

await sleep(20);

}

const observed = params.events

.filter((evt) => evt.runId === params.runId || evt.sessionKey === params.sessionKey)

.map((evt) => `${evt.runId ?? "no-run"}:${evt.sessionKey ?? "no-session"}:${evt.state}`)

.slice(-10)

.join(", ");

throw new Error(

`timeout waiting for final chat event (runId=${params.runId}, sessionKey=${params.sessionKey}, observed=${observed || "none"})`,

);

}

// UI style fixtures load expected UI style files for tests.

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

import { readFile } from "node:fs/promises";

import { resolve } from "node:path";

export function resolveStylePath(path: string): string {

export function readStyleSheet(path: string): string {

return readFileSync(resolveStylePath(path), "utf8");

}

export function readStyleSheetAsync(path: string): Promise<string> {

return readFile(resolveStylePath(path), "utf8");

}

});

it("keeps shared test helpers cheap by default when no precise target exists", () => {

expect(

resolveChangedTargetArgs(["--changed", "origin/main"], process.cwd(), () => [

"test/helpers/poll.ts",

]),

).toStrictEqual([]);

let args: string[] | null = null;

withTinyGitRepo(

{

"test/helpers/unmapped-helper.ts": "export const unmapped = true;\n",

},

(cwd) => {

args = resolveChangedTargetArgs(["--changed", "origin/main"], cwd, () => [

"test/helpers/unmapped-helper.ts",

]);

},

);

expect(args).toStrictEqual([]);

});

it("routes imported shared test helpers through affected tests", () => {

});

it("keeps the broad changed run available for shared test helpers", () => {

expect(

resolveChangedTargetArgs(

["--changed", "origin/main"],

process.cwd(),

() => ["test/helpers/poll.ts"],

{ env: { OPENCLAW_TEST_CHANGED_BROAD: "1" } },

),

).toBeNull();

let args: string[] | null = [];

withTinyGitRepo(

{

"test/helpers/unmapped-helper.ts": "export const unmapped = true;\n",

},

(cwd) => {

args = resolveChangedTargetArgs(

["--changed", "origin/main"],

cwd,

() => ["test/helpers/unmapped-helper.ts"],

{ env: { OPENCLAW_TEST_CHANGED_BROAD: "1" } },

);

},

);

expect(args).toBeNull();

});

it("routes channel contract helper edits through the tests that import them", () => {

},

{

code: "module-mocking-helper",

pattern: /(?:runtime-module-mocks|plugins-cli-test-helpers|manager\.test-helpers)/u,

pattern: /(?:plugins-cli-test-helpers|manager\.test-helpers)/u,

},

{

code: "vitest-mock-api",