/**

* Runs CPU-heavy compaction planning in a worker thread when histories are

* large enough to risk starving the main event loop.

*/

import path from "node:path";

import { fileURLToPath, pathToFileURL } from "node:url";

import { Worker } from "node:worker_threads";

}

}

/** Builds summary chunks, offloading large histories to the planning worker. */

export async function buildSummaryChunksWithWorker(params: {

messages: AgentMessage[];

maxChunkTokens: number;

return value.chunks;

}

/** Builds an oversized-message fallback plan, using the worker when worthwhile. */

export async function buildOversizedFallbackPlanWithWorker(params: {

messages: AgentMessage[];

contextWindow: number;

};

}

/** Builds a staged summarization split plan with worker fallback. */

export async function buildStageSplitPlanWithWorker(params: {

messages: AgentMessage[];

maxChunkTokens: number;

return value.mode === "split" ? { mode: "split", chunks: value.chunks } : { mode: "single" };

}

/** Builds a history-pruning plan with worker fallback for large transcripts. */

export async function buildHistoryPrunePlanWithWorker(params: {

messagesToSummarize: AgentMessage[];

turnPrefixMessages: AgentMessage[];

};

}

/** Computes the adaptive compaction chunk ratio with worker fallback. */

export async function computeAdaptiveChunkRatioWithWorker(params: {

messages: AgentMessage[];

contextWindow: number;

return value.ratio;

}

/** Test-only worker internals for URL resolution and error-path coverage. */

export const compactionPlanningWorkerTesting = {

resolveCompactionPlanningWorkerUrl,

runCompactionPlanningWorker,