pjandro/OmniRoute
1
0
Fork 0
mirror of https://github.com/diegosouzapw/OmniRoute.git synced 2026-07-31 04:12:10 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix(sse): repair RTK engine defaults so dedup and direct calls work (#2825)

Browse Source 
Integrated into release/v3.8.6
This commit is contained in:
Lenine Júnior
2026-05-29 04:28:32 -04:00
committed by GitHub
parent 53ac23cfe6
commit 8f4fc8bcda
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
open-sse/services/compression/engines/rtk/index.ts
View File

@@ -316,13 +316,11 @@ export function processRtkText(
}
}
if (config.intensity !== "minimal") {
const deduped = deduplicateRepeatedLines(result, { threshold: config.deduplicateThreshold });
if (deduped.collapsed > 0) {
result = deduped.text;
techniquesUsed.push("rtk-dedup");
rulesApplied.push("rtk:dedup");
}
const deduped = deduplicateRepeatedLines(result, { threshold: config.deduplicateThreshold });
if (deduped.collapsed > 0) {
result = deduped.text;
techniquesUsed.push("rtk-dedup");
rulesApplied.push("rtk:dedup");
}
const truncated = smartTruncate(result, {
@@ -441,7 +439,10 @@ export function applyRtkCompression(
options.stepConfig && options.stepConfig.enabled === undefined
? { enabled: true, ...options.stepConfig }
: options.stepConfig;
const config = mergeRtkConfig(options.config, stepConfig);
const explicitConfig = options.config && Object.keys(options.config).length > 0;
const baseConfig =
!explicitConfig && !stepConfig ? { enabled: true } : (options.config ?? {});
const config = mergeRtkConfig(baseConfig, stepConfig);
if (!config.enabled) return { body, compressed: false, stats: null };
const adapter = adaptBodyForCompression(body);