vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-17 20:21:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

gateway: fix bounded SSE sanitization and rawTranscriptSeq init

Browse Source 
Apply sanitizeChatHistoryMessages before pagination in the bounded SSE
history refresh path, consistent with the unbounded path. Initialize
rawTranscriptSeq from the raw transcript's last __openclaw.seq value
instead of the sanitized history length, preventing seq drift when
sanitization drops messages.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Eva
2026-04-06 17:48:31 +07:00
committed by Peter Steinberger
parent 029ed5d32a
commit 3d9c6affce
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/gateway/sessions-history-http.ts
View File

@@ -18,6 +18,10 @@ import {
resolveTrustedHttpOperatorScopes,
} from "./http-utils.js";
import { authorizeOperatorScopesForMethod } from "./method-scopes.js";
import {
DEFAULT_CHAT_HISTORY_TEXT_MAX_CHARS,
sanitizeChatHistoryMessages,
} from "./server-methods/chat.js";
import {
attachOpenClawTranscriptMeta,
readSessionMessages,
@@ -25,10 +29,6 @@ import {
resolveGatewaySessionStoreTarget,
resolveSessionTranscriptCandidates,
} from "./session-utils.js";
import {
DEFAULT_CHAT_HISTORY_TEXT_MAX_CHARS,
sanitizeChatHistoryMessages,
} from "./server-methods/chat.js";
const MAX_SESSION_HISTORY_LIMIT = 1000;
@@ -248,7 +248,13 @@ export async function handleSessionHistoryHttpRequest(
: new Set<string>();
let sentHistory = history;
let rawTranscriptSeq = resolveMessageSeq(sentHistory.items.at(-1)) ?? 0;
// Initialize rawTranscriptSeq from the raw transcript's last __openclaw.seq
// value, not the sanitized history tail, so seq numbering stays correct even
// when sanitization drops messages (e.g. silent replies).
const rawMessages = entry?.sessionId
? readSessionMessages(entry.sessionId, target.storePath, entry.sessionFile)
: [];
let rawTranscriptSeq = resolveMessageSeq(rawMessages.at(-1)) ?? rawMessages.length;
setSseHeaders(res);
res.write("retry: 1000\n\n");
sseWrite(res, "history", {
@@ -296,6 +302,8 @@ export async function handleSessionHistoryHttpRequest(
return;
}
}
// Bounded SSE history refreshes: apply sanitizeChatHistoryMessages before
// pagination, consistent with the unbounded path.
sentHistory = paginateSessionMessages(
sanitizeChatHistoryMessages(
readSessionMessages(entry.sessionId, target.storePath, entry.sessionFile),