pjandro/OmniRoute
1
0
Fork 0
mirror of https://github.com/diegosouzapw/OmniRoute.git synced 2026-09-21 06:12:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix(codex): normalize non-stream responses (#11951)

Browse Source 
Boarded with #11954/#11953/#11952/#11948 in one combined worktree: typecheck:core, check:file-size, check:changelog-integrity, check:complexity, check:cognitive-complexity, check:cycles all green; 85/85 focused tests pass. Confirmed the codex registry entry was missing forceStream: true while every other JSON-only-client provider (cline, clinepass, ghe-copilot, kimi, zed-hosted, chatgpt-web-codex) already has it. Clean reuse of the existing bridge, no Codex-specific response handling needed. Thanks!
This commit is contained in:
Bl0ck
2026-08-30 11:09:48 +03:00
committed by GitHub
parent 70af41b9f6
commit 097226b617
2 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
open-sse/config/providers/registry/codex/index.ts
View File

@@ -11,6 +11,9 @@ export const codexProvider: RegistryEntry = {
alias: "cx",
format: "openai-responses",
executor: "codex",
// Codex /responses is upstream-streaming even when the client requested stream:false.
// Mark it forceStream so chatCore drains terminal SSE into JSON instead of waiting for EOF.
forceStream: true,
baseUrl: "https://chatgpt.com/backend-api/codex/responses",
reasoningTransport: "opaque",
authType: "oauth",

16
tests/unit/cline-force-stream.test.ts
View File

@@ -22,14 +22,20 @@ test("clinepass provider is flagged forceStream (streaming-only upstream)", () =
assert.equal(REGISTRY.clinepass?.forceStream, true);
});
test("codex provider is flagged forceStream because /responses always streams upstream", () => {
assert.equal(REGISTRY.codex?.forceStream, true);
});
test("upstreamStream is forced true for a forceStream provider even when the client sent stream:false", () => {
// Mirror the chatCore wiring: providerRequiresStreaming derives from the
// registry flag, and upstreamStream ORs it in so the upstream always streams.
const providerRequiresStreaming = REGISTRY.cline?.forceStream === true;
const isClaudeCodeCompatible = false;
const clientStream = false; // client asked for JSON
const upstreamStream = clientStream || isClaudeCodeCompatible || providerRequiresStreaming;
assert.equal(upstreamStream, true);
for (const provider of ["cline", "codex"] as const) {
const providerRequiresStreaming = REGISTRY[provider]?.forceStream === true;
const isClaudeCodeCompatible = false;
const clientStream = false; // client asked for JSON
const upstreamStream = clientStream || isClaudeCodeCompatible || providerRequiresStreaming;
assert.equal(upstreamStream, true, provider);
}
});
test("client-facing stream stays false for a stream:false JSON caller (so SSE→JSON conversion runs)", () => {