mirror of
https://github.com/diegosouzapw/OmniRoute.git
synced 2026-09-16 11:52:26 +03:00
65e81158ab
Landed with the design call resolved per the owner's pick — **option 1**: the synced store is now endpoint-agnostic (persistDiscoveredModels and managedModelImport no longer drop non-chat models at write time), and chat selectability moved to read time (auto-pool expansion in autoStrategy applies filterChatSelectableModels; the models-route projection already had its chatOnly filter). Your discovery test now passes end-to-end (3/3): /api/show capabilities persist per connection and image/embedding requests route through the advertising host. Reconciliation notes: conflicted areas merged onto the current tip (adobe discovery import, requestedModel preflight signature, resolvedProvider fast-path coexists with the synced-route override — explicit resolution wins); carried base-red drains (#10055 memoization, #11071 test variants) dropped as already-landed; the managed-model-import exclusion test was propagated to the new contract (image/video models persist; the read filter still hides them from chat pickers — pinned by a new assertion). Full battery: 205/206 focused (the one red is a confirmed periodic-timer timing flake on the loaded devbox — 20/20 isolated), autoCombo vitest 30/30, combo suites 46/46, gates + typecheck clean. Thank you @yourspraveen — the capability probe + routing design was right; it just needed the store contract opened up. Fixes #11087.
43 lines
1.6 KiB
TypeScript
43 lines
1.6 KiB
TypeScript
/**
|
|
* chatCore executor client-header normalizer (Quality Gate v2 / Fase 9 — chatCore god-file
|
|
* decomposition, #3501).
|
|
*
|
|
* Pure helper extracted from chatCore: normalizes a Headers instance or a plain header object into a
|
|
* lowercased-tolerant Record<string,string>, and backfills the client User-Agent (both casings) when
|
|
* one is supplied and not already present. Returns null when nothing was collected. Side-effect-free;
|
|
* behaviour is byte-identical to the previous module-level function.
|
|
*/
|
|
|
|
export function buildExecutorClientHeaders(
|
|
headers: Headers | Record<string, unknown> | null | undefined,
|
|
userAgent?: string | null
|
|
) {
|
|
const normalized: Record<string, string> = {};
|
|
const isLeaseControlHeader = (key: string) => {
|
|
const lowerKey = key.toLowerCase();
|
|
return lowerKey === "x-omniroute-lease-owner" || lowerKey === "x-omniroute-lease-generation";
|
|
};
|
|
|
|
if (headers instanceof Headers) {
|
|
headers.forEach((value, key) => {
|
|
if (isLeaseControlHeader(key)) return;
|
|
normalized[key] = value;
|
|
});
|
|
} else if (headers && typeof headers === "object") {
|
|
for (const [key, value] of Object.entries(headers)) {
|
|
if (isLeaseControlHeader(key)) continue;
|
|
if (typeof value === "string") {
|
|
normalized[key] = value;
|
|
}
|
|
}
|
|
}
|
|
|
|
const normalizedUserAgent = typeof userAgent === "string" ? userAgent.trim() : "";
|
|
if (normalizedUserAgent && !normalized["user-agent"] && !normalized["User-Agent"]) {
|
|
normalized["user-agent"] = normalizedUserAgent;
|
|
normalized["User-Agent"] = normalizedUserAgent;
|
|
}
|
|
|
|
return Object.keys(normalized).length > 0 ? normalized : null;
|
|
}
|