fix(stream): expose encrypted Codex reasoning to chat clients

open-sse/translator/response/openai-responses.ts

@@ -13,6 +13,7 @@ import {
   normalizeOutputIndex,
   normalizeUpstreamFailure,
   extractResponsesReasoningSummaryText,
+  ensureVisibleResponsesReasoningSummary,
 } from "./openai-responses/pureHelpers.ts";
 import { createEventEmitter } from "./openai-responses/eventEmitter.ts";
 
@@ -1070,6 +1071,7 @@ function openaiResponsesToOpenAIResponseStream(chunk, state) {
       !(state.reasoningItemsWithDelta instanceof Set && state.reasoningItemsWithDelta.size > 0);
     if (emittedForItem || emittedWithoutItemId) return null;
 
+    ensureVisibleResponsesReasoningSummary(item);
     const summaryText = extractResponsesReasoningSummaryText(item);
     if (!summaryText) return null;
     return buildResponsesReasoningDeltaChunk(state, summaryText);

open-sse/translator/response/openai-responses/pureHelpers.ts

@@ -163,3 +163,21 @@ export function extractResponsesReasoningSummaryText(item) {
     )
     .join("");
 }
+
+const ENCRYPTED_REASONING_SUMMARY =
+  "Codex is reasoning, but the upstream Responses API exposed this reasoning block only as encrypted private reasoning. OmniRoute cannot recover the plaintext.";
+
+export function ensureVisibleResponsesReasoningSummary(item) {
+  if (
+    !item ||
+    item.type !== "reasoning" ||
+    extractResponsesReasoningSummaryText(item) ||
+    typeof item.encrypted_content !== "string" ||
+    item.encrypted_content.length === 0
+  ) {
+    return false;
+  }
+
+  item.summary = [{ type: "summary_text", text: ENCRYPTED_REASONING_SUMMARY }];
+  return true;
+}

open-sse/utils/stream.ts

@@ -52,6 +52,10 @@ import {
   stripResponsesLifecycleEcho,
 } from "./responsesStreamHelpers.ts";
 import { processBufferedPassthroughLine } from "./passthroughTailProcessor.ts";
+import {
+  ensureVisibleResponsesReasoningSummary as ensureVisibleResponsesReasoningItemSummary,
+  extractResponsesReasoningSummaryText,
+} from "../translator/response/openai-responses/pureHelpers.ts";
 import {
   getAnyReasoningValue,
   getReadableReasoningValue,
@@ -1006,47 +1010,12 @@ export function createSSEStream(options: StreamOptions = {}) {
     return responseId !== null && outputIndex !== null ? `${responseId}:${outputIndex}` : null;
   };
 
-  const getResponsesReasoningSummaryText = (item: Record<string, unknown>): string => {
-    return Array.isArray(item.summary)
-      ? item.summary
-          .map((part) => {
-            if (!part || typeof part !== "object" || Array.isArray(part)) {
-              return "";
-            }
-            return typeof (part as Record<string, unknown>).text === "string"
-              ? ((part as Record<string, unknown>).text as string)
-              : "";
-          })
-          .join("")
-      : "";
-  };
-
   const ensureVisibleResponsesReasoningSummary = (payload: Record<string, unknown>): boolean => {
     const item =
       payload.item && typeof payload.item === "object" && !Array.isArray(payload.item)
         ? (payload.item as Record<string, unknown>)
         : null;
-    if (!item || item.type !== "reasoning") {
-      return false;
-    }
-
-    if (getResponsesReasoningSummaryText(item)) {
-      return false;
-    }
-
-    const hasEncryptedReasoning =
-      typeof item.encrypted_content === "string" && item.encrypted_content.length > 0;
-    if (!hasEncryptedReasoning) {
-      return false;
-    }
-
-    item.summary = [
-      {
-        type: "summary_text",
-        text: "Codex is reasoning, but the upstream Responses API exposed this reasoning block only as encrypted state. OmniRoute cannot recover the private reasoning text.",
-      },
-    ];
-    return true;
+    return ensureVisibleResponsesReasoningItemSummary(item);
   };
 
   const emitSyntheticResponsesReasoningSummary = (
@@ -1061,8 +1030,8 @@ export function createSSEStream(options: StreamOptions = {}) {
       return;
     }
 
-    ensureVisibleResponsesReasoningSummary(payload);
-    const visibleSummary = getResponsesReasoningSummaryText(item);
+    ensureVisibleResponsesReasoningItemSummary(item);
+    const visibleSummary = extractResponsesReasoningSummaryText(item);
 
     if (!visibleSummary) {
       return;