wehub-resource-sync
63 lines
2.7 KiB
TypeScript
63 lines
2.7 KiB
TypeScript
/**
|
|
* Guards for B-MODE-ENGINE-DECOUPLE and B-PIPELINE-DIVERGENCE.
|
|
*
|
|
* B-MODE-ENGINE-DECOUPLE: selecting a single MODE must run its engine even if the
|
|
* per-engine `enabled` flag is off — the mode selection IS the enable signal (the
|
|
* per-engine flag still gates STACKED pipeline steps). Previously standard/rtk silently
|
|
* no-op'd when cavemanConfig.enabled / rtkConfig.enabled was false.
|
|
*
|
|
* B-PIPELINE-DIVERGENCE: the global stackedPipeline normalizer stripped
|
|
* session-dedup/ccr/headroom/llmlingua (engines the combo path allows), so those engines
|
|
* could never run via the global setting. The allowlists must agree.
|
|
*/
|
|
import { test } from "node:test";
|
|
import assert from "node:assert/strict";
|
|
import { applyCompression } from "@omniroute/open-sse/services/compression/strategySelector.ts";
|
|
import { normalizeStackedPipeline } from "../../../src/lib/db/compression.ts";
|
|
|
|
test("standard mode compresses even when cavemanConfig.enabled is false (B-MODE-ENGINE-DECOUPLE)", () => {
|
|
const body = {
|
|
messages: [
|
|
{
|
|
role: "user",
|
|
content:
|
|
"Please could you kindly review the configuration of the file. ".repeat(8) +
|
|
"I would really appreciate it, thank you so much for your help here.",
|
|
},
|
|
],
|
|
};
|
|
const res = applyCompression(body, "standard", {
|
|
config: {
|
|
cavemanConfig: { enabled: false, compressRoles: ["user"], intensity: "full", minMessageLength: 0 },
|
|
},
|
|
} as Record<string, unknown>);
|
|
assert.ok(res.compressed, "standard mode must run caveman regardless of cavemanConfig.enabled");
|
|
});
|
|
|
|
test("rtk mode compresses even when rtkConfig.enabled is false (B-MODE-ENGINE-DECOUPLE)", () => {
|
|
const content =
|
|
Array.from({ length: 60 }, (_, i) => `line ${String(i).padStart(3, "0")} routine output`).join(
|
|
"\n"
|
|
) + "\nERROR: boom";
|
|
const res = applyCompression({ messages: [{ role: "tool", content }] }, "rtk", {
|
|
config: { rtkConfig: { enabled: false, intensity: "standard", applyToToolResults: true } },
|
|
} as Record<string, unknown>);
|
|
assert.ok(res.compressed, "rtk mode must run regardless of rtkConfig.enabled");
|
|
});
|
|
|
|
test("normalizeStackedPipeline keeps headroom/ccr/session-dedup/llmlingua (B-PIPELINE-DIVERGENCE)", () => {
|
|
const pipe = normalizeStackedPipeline([
|
|
{ engine: "session-dedup" },
|
|
{ engine: "ccr" },
|
|
{ engine: "headroom" },
|
|
{ engine: "llmlingua" },
|
|
{ engine: "rtk", intensity: "standard" },
|
|
{ engine: "bogus-engine" }, // unknown ids still dropped
|
|
]);
|
|
const engines = pipe.map((s) => s.engine);
|
|
for (const e of ["session-dedup", "ccr", "headroom", "llmlingua", "rtk"]) {
|
|
assert.ok(engines.includes(e), `${e} must survive normalize`);
|
|
}
|
|
assert.ok(!engines.includes("bogus-engine"), "unknown engine ids are still dropped");
|
|
});
|