GeneralBots/botui
2
0
Fork 0
Code Activity Actions

fix: robust signal extraction in frontend
All checks were successful
BotUI CI/CD / build (push) Successful in 37s
Details

Browse source
This commit is contained in:
Rodrigo Rodriguez (Pragmatismo) 2026-04-14 17:57:56 -03:00
parent d813fc2a25
commit d8984b8112
1 changed files with 25 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
ui/suite/chat/chat.html
View file

@ -816,33 +816,36 @@ function finalizeStreaming() {
}
function processMessage(data) {
// If content is a JSON string or contains it, try to intercept internal signals
if (data.content && typeof data.content === "string") {
var jsonStart = data.content.indexOf('{"type":"thinking');
if (jsonStart !== -1) {
// If content contains JSON signals, extract and handle them
if (data.content && typeof data.content === "string" && data.content.includes('{')) {
var signalRegex = /\{[^{}]*"type"\s*:\s*"(thinking|thinking_clear)"[^{}]*\}/g;
var match;
var hasAnySignal = false;
while ((match = signalRegex.exec(data.content)) !== null) {
try {
// Extract only the JSON part
var remaining = data.content.substring(jsonStart);
var jsonEnd = remaining.indexOf("}") + 1;
if (jsonEnd > 0) {
var jsonStr = remaining.substring(0, jsonEnd);
var inner = JSON.parse(jsonStr);
if (inner.type === "thinking") {
showThinkingIndicator(inner.content);
// If there is text before or after, keep processing that as content
data.content = data.content.replace(jsonStr, "").trim();
if (data.content === "") return;
} else if (inner.type === "thinking_clear") {
hideThinkingIndicator();
data.content = data.content.replace(jsonStr, "").trim();
if (data.content === "") return;
}
var jsonStr = match[0];
var inner = JSON.parse(jsonStr);
hasAnySignal = true;
if (inner.type === "thinking") {
showThinkingIndicator(inner.content);
} else if (inner.type === "thinking_clear") {
hideThinkingIndicator();
}
// Remove this signal from the content
data.content = data.content.replace(jsonStr, "");
// Reset regex index since we modified the string
signalRegex.lastIndex = 0;
} catch (e) {
console.error("Failed to parse embedded signal:", e);
console.error("Failed to parse signal:", e);
}
}
if (hasAnySignal && data.content.trim() === "" && !data.is_complete) {
return;
}
}
// Fallback for direct type matches