Prevent reasoning deltas from leaking into content

Author: gitcommit90

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "rerouted",
-  "version": "0.4.9",
+  "version": "0.4.10",
   "description": "A macOS menu-bar router for accounts, models, and automatic fallback.",
   "author": "gitcommit90",
   "license": "MIT",

package.json

@@ -483,19 +483,15 @@ async function pipeResponsesSse(
       }
 
       let delta = "";
-      if (type === "response.output_text.delta" && typeof data.delta === "string") delta = data.delta;
-      else if (type === "response.output_text.delta" && data.delta?.text) delta = data.delta.text;
-      else if (type === "response.output_text.delta" && typeof data.text === "string")
-        delta = data.text;
-      else if (data.delta?.content) {
-        for (const c of data.delta.content) {
-          if (c.type === "output_text" || c.type === "text") delta += c.text || "";
+      if (type === "response.output_text.delta") {
+        if (typeof data.delta === "string") delta = data.delta;
+        else if (data.delta?.text) delta = data.delta.text;
+        else if (typeof data.text === "string") delta = data.text;
+        else if (Array.isArray(data.delta?.content)) {
+          for (const c of data.delta.content) {
+            if (c.type === "output_text" || c.type === "text") delta += c.text || "";
+          }
         }
-      } else if (
-        type !== "response.function_call_arguments.delta" &&
-        typeof data.delta === "string"
-      ) {
-        delta = data.delta;
       }
 
       if (delta) {

src/lib/providers/chatgpt.js

@@ -311,6 +311,56 @@ describe("ChatGPT Responses tool translation", () => {
     assert.equal(next.input[1].encrypted_content, "encrypted-json-reasoning");
   });
 
+  it("keeps structured reasoning out of visible JSON and streaming content", async () => {
+    const json = chatgpt.fromResponsesJson(
+      {
+        output: [
+          {
+            id: "rs_hidden",
+            type: "reasoning",
+            summary: [{ type: "summary_text", text: "Private planning" }],
+          },
+          {
+            type: "message",
+            role: "assistant",
+            content: [{ type: "output_text", text: "Visible answer" }],
+          },
+        ],
+      },
+      "gpt-5.6-sol"
+    );
+    assert.equal(json.choices[0].message.content, "Visible answer");
+
+    const events = [
+      {
+        type: "response.reasoning_summary_text.delta",
+        delta: "Private streamed planning",
+      },
+      { type: "response.output_text.delta", delta: "Visible streamed answer" },
+      { type: "response.completed" },
+    ].map((event) => `data: ${JSON.stringify(event)}\n\n`);
+
+    const collected = await chatgpt.pipeResponsesSse(
+      Readable.from(events),
+      null,
+      "gpt-5.6-sol",
+      { collect: true }
+    );
+    assert.equal(collected.choices[0].message.content, "Visible streamed answer");
+
+    const writes = [];
+    await chatgpt.pipeResponsesSse(
+      Readable.from(events),
+      { write(chunk) { writes.push(chunk); } },
+      "gpt-5.6-sol"
+    );
+    const visibleContent = parseSseWrites(writes)
+      .map((chunk) => chunk.choices[0].delta.content || "")
+      .join("");
+    assert.equal(visibleContent, "Visible streamed answer");
+    assert.doesNotMatch(writes.join(""), /Private streamed planning/);
+  });
+
   it("replays multiple reasoning phases once in their original call order", () => {
     const first = chatgpt.fromResponsesJson(
       {

tests/chatgpt-tools.test.js

@@ -197,6 +197,7 @@ describe("xAI OAuth Responses transport", () => {
   it("collects non-stream output and relays streaming output and errors", async () => {
     const events = [
       'event: response.created\ndata: {"type":"response.created"}\n\n',
+      'event: response.reasoning_summary_text.delta\ndata: {"type":"response.reasoning_summary_text.delta","delta":"Private planning"}\n\n',
       'event: response.output_text.delta\ndata: {"type":"response.output_text.delta","delta":"Hel"}\n\n',
       'event: response.output_text.delta\ndata: {"type":"response.output_text.delta","delta":"lo"}\n\n',
       'event: response.completed\ndata: {"type":"response.completed"}\n\n',
@@ -216,6 +217,7 @@ describe("xAI OAuth Responses transport", () => {
     const output = chunks.join("");
     assert.match(output, /chat\.completion\.chunk/);
     assert.match(output, /\[DONE\]/);
+    assert.doesNotMatch(output, /Private planning/);
 
     await assert.rejects(
       xai.pipeResponsesSse(