[AI] improve(openai): typeof guard, reasoningTagTextPartitioner for refusal routing, add packages/ai test

hailory · hailory · commit 1484e4e8f4d8 · 2026-07-09T11:24:08.000+08:00
diff --git a/src/agents/openai-transport-stream.ts b/src/agents/openai-transport-stream.ts
@@ -3148,9 +3148,17 @@ async function processOpenAICompletionsStream(
           appendRoutedContentDelta(contentDelta);
         }
       }
-    } else if ((choiceDelta as { refusal?: string }).refusal) {
-      // Safety or structured-output refusal surfaced as assistant visible text.
-      appendTextDelta((choiceDelta as { refusal?: string }).refusal!);
+    } else if (
+      !choiceDelta.content &&
+      typeof (choiceDelta as { refusal?: string }).refusal === "string"
+    ) {
+      const refusalText = (choiceDelta as { refusal?: string }).refusal!;
+      const routedDeltas = hasMirroredReasoning
+        ? reasoningTagTextPartitioner.push(refusalText)
+        : reasoningTagTextPartitioner.pushVisible(refusalText);
+      for (const routedDelta of routedDeltas) {
+        appendPartitionedVisibleDelta(routedDelta);
+      }
     }
     for (const reasoningDelta of reasoningDeltas) {
       if (reasoningDelta.kind === "thinking" && !emitReasoning) {
diff --git a/src/llm/providers/openai-completions.test.ts b/src/llm/providers/openai-completions.test.ts
@@ -248,6 +248,28 @@ describe("OpenAI-compatible completions params", () => {
     expect(capturedPayload?.tools).toEqual([]);
   });
 
+  it("surfaces chat-completions refusal deltas as visible assistant text", async () => {
+    mockChunksRef.chunks = [
+      {
+        id: "chatcmpl-test",
+        choices: [
+          {
+            index: 0,
+            delta: { role: "assistant", content: null, refusal: "I can't help with that." },
+            finish_reason: "stop",
+          },
+        ],
+      },
+    ];
+
+    const result = await streamOpenAICompletions(model, context, {
+      apiKey: "sk-test",
+    }).result();
+
+    expect(result.content).toStrictEqual([{ type: "text", text: "I can't help with that." }]);
+    expect(result.stopReason).toBe("stop");
+  });
+
   it("does not reread an unreadable tool inventory length", async () => {
     let capturedPayload: Record<string, unknown> | undefined;
     const tools = new Proxy([], {
diff --git a/src/llm/providers/openai-completions.ts b/src/llm/providers/openai-completions.ts
@@ -427,8 +427,8 @@ export const streamOpenAICompletions: StreamFunction<
             choice.delta.content.length > 0
           ) {
             appendPartitionedContent(choice.delta.content, Boolean(foundReasoningField));
-          } else if ((choice.delta as { refusal?: string }).refusal) {
-            appendPartitionedContent((choice.delta as { refusal?: string }).refusal!, false);
+          } else if (typeof choice.delta.refusal === "string") {
+            appendPartitionedContent(choice.delta.refusal, Boolean(foundReasoningField));
           }
 
           if (choice?.delta?.tool_calls) {
