fix deepseek responses uuid item ids for codex

Make openai-responses passthrough optionally rewrite non-canonical message/reasoning ids, fold reasoning_text into encrypted_content, and keep SSE rewrite consumers alive when events are dropped so DeepSeek Responses works with Codex CLI/TUI.

Author: mouzhi

src/config.ts

@@ -488,6 +488,7 @@ const providerConfigSchema = z.object({
     message: z.array(z.string().min(1)).optional(),
     reasoning: z.array(z.string().min(1)).optional(),
     repairMissingTerminalIds: z.boolean().optional(),
+    rewriteNonCanonicalIds: z.boolean().optional(),
   }).strict().optional(),
 }).passthrough();
 

src/server/relay-eager.ts

@@ -123,14 +123,16 @@ export function relaySseEagerBounded(
       if (!next) break;
       const payload = sseDataPayload(next.block);
       const rewrittenPayload = payload === null ? null : rewrite!(payload);
+      frameBuffer = next.rest;
+      // Returning null from rewrite drops the entire SSE event.
+      if (payload !== null && rewrittenPayload === null) continue;
       // Replace only on an actual change: replaceSseDataPayload collapses
       // multi-data-line events and normalizes newline style even when the
       // payload is identical, which corrupts valid streams.
-      const block = payload !== null && rewrittenPayload !== payload
-        ? replaceSseDataPayload(next.block, rewrittenPayload!)
+      const block = payload !== null && rewrittenPayload !== null && rewrittenPayload !== payload
+        ? replaceSseDataPayload(next.block, rewrittenPayload)
         : next.block;
       out += block + next.delimiter;
-      frameBuffer = next.rest;
     }
     if (rewriteBudget) {
       const remaining = rewriteEncoder!.encode(frameBuffer).byteLength;
@@ -149,6 +151,14 @@ export function relaySseEagerBounded(
     const payload = sseDataPayload(tail);
     if (payload !== null) {
       const rewrittenPayload = rewrite(payload);
+      if (rewrittenPayload === null) {
+        frameBuffer = "";
+        if (rewriteBudget && frameBufferBytes > 0) {
+          rewriteBudget.releaseRetained(frameBufferBytes, { kind: "live_transient" });
+        }
+        frameBufferBytes = 0;
+        return rewriteEncoder!.encode("");
+      }
       if (rewrittenPayload !== payload) tail = replaceSseDataPayload(tail, rewrittenPayload);
     }
     frameBuffer = "";