github/openclaw
1
1
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-02-19 18:39:20 -05:00
Code Issues Packages Projects Releases Wiki Activity

refactor(gateway): dedupe assistant delta parsing

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-15 19:08:47 +00:00
parent 5248b759fe
commit a2ceadcc2a
3 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/gateway/agent-event-assistant-text.ts Normal file
View File

@@ -0,0 +1,7 @@
import type { AgentEventPayload } from "../infra/agent-events.js";
export function resolveAssistantStreamDeltaText(evt: AgentEventPayload): string {
const delta = evt.data.delta;
const text = evt.data.text;
return typeof delta === "string" ? delta : typeof text === "string" ? text : "";
}

5
src/gateway/openai-http.ts
View File

@@ -7,6 +7,7 @@ import { agentCommand } from "../commands/agent.js";
import { emitAgentEvent, onAgentEvent } from "../infra/agent-events.js";
import { logWarn } from "../logger.js";
import { defaultRuntime } from "../runtime.js";
import { resolveAssistantStreamDeltaText } from "./agent-event-assistant-text.js";
import {
buildAgentMessageFromConversationEntries,
type ConversationEntry,
@@ -243,9 +244,7 @@ export async function handleOpenAiHttpRequest(
}
if (evt.stream === "assistant") {
const delta = evt.data?.delta;
const text = evt.data?.text;
const content = typeof delta === "string" ? delta : typeof text === "string" ? text : "";
const content = resolveAssistantStreamDeltaText(evt);
if (!content) {
return;
}

5
src/gateway/openresponses-http.ts
View File

@@ -36,6 +36,7 @@ import {
type InputImageSource,
} from "../media/input-files.js";
import { defaultRuntime } from "../runtime.js";
import { resolveAssistantStreamDeltaText } from "./agent-event-assistant-text.js";
import {
buildAgentMessageFromConversationEntries,
type ConversationEntry,
@@ -727,9 +728,7 @@ export async function handleOpenResponsesHttpRequest(
}
if (evt.stream === "assistant") {
const delta = evt.data?.delta;
const text = evt.data?.text;
const content = typeof delta === "string" ? delta : typeof text === "string" ? text : "";
const content = resolveAssistantStreamDeltaText(evt);
if (!content) {
return;
}