createQaChannelGatewayConfig,

QA_CHANNEL_REQUIRED_PLUGIN_IDS,

} from "./qa-channel-transport.js";

import {

appendQaChildOutput,

appendQaChildOutputTail,

createQaChildOutputCapture,

createQaChildOutputTail,

formatQaChildOutputTail,

QA_CHILD_STDOUT_MAX_BYTES,

readQaChildOutput,

} from "./child-output.js";

import { buildQaGatewayConfig } from "./qa-gateway-config.js";

type ModelRow = {

});

await fs.writeFile(configPath, `${JSON.stringify(cfg, null, 2)}\n`, "utf8");

const stdout: Buffer[] = [];

const stderr: Buffer[] = [];

const stdout = createQaChildOutputCapture();

const stderr = createQaChildOutputTail();

const nodeExecPath = await resolveQaNodeExecPath();

await new Promise<void>((resolve, reject) => {

let aborted = params.signal?.aborted === true;

} else {

params.signal?.addEventListener("abort", abortCatalogLoad, { once: true });

}

child.stdout.on("data", (chunk) => stdout.push(Buffer.from(chunk)));

child.stderr.on("data", (chunk) => stderr.push(Buffer.from(chunk)));

child.stdout.on("data", (chunk) => appendQaChildOutput(stdout, chunk));

child.stderr.on("data", (chunk) => appendQaChildOutputTail(stderr, chunk));

child.once("error", (error) => {

cleanup();

reject(aborted ? createCatalogAbortError() : error);

return;

}

if (code === 0) {

if (stdout.exceeded) {

reject(

new Error(

`qa model catalog stdout exceeded ${QA_CHILD_STDOUT_MAX_BYTES} bytes; refusing to parse truncated output`,

),

);

return;

}

resolve();

return;

}

const stderrText = formatQaChildOutputTail(stderr, "qa model catalog stderr");

reject(

new Error(

`qa model catalog failed (${code ?? "unknown"}): ${Buffer.concat(stderr).toString("utf8").trim()}`,

`qa model catalog failed (${code ?? "unknown"}): ${stderrText}`,

),

);

});

});

return parseQaRunnerModelOptionsOutput(Buffer.concat(stdout).toString("utf8"));

return parseQaRunnerModelOptionsOutput(readQaChildOutput(stdout));

} finally {

await fs.rm(tempRoot, { recursive: true, force: true });

}