Ayuriel/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: clear loading state before reconnecting to active stream

Browse Source
This commit is contained in:
kumarabhirup 2026-02-16 22:58:01 -08:00
parent 4965e3ca67
commit 7c2e056437
No known key found for this signature in database
GPG Key ID: DB7CA2289CAB0167
1 changed files with 31 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
apps/web/app/components/chat-panel.tsx
View File

@ -1086,34 +1086,39 @@ export const ChatPanel = forwardRef<ChatPanelHandle, ChatPanelProps>(
)
: sessionMessages;
const uiMessages = completedMessages.map(
(msg) => {
savedMessageIdsRef.current.add(msg.id);
return {
id: msg.id,
role: msg.role,
parts: (msg.parts ?? [
{
type: "text" as const,
text: msg.content,
},
]) as UIMessage["parts"],
};
},
);
const uiMessages = completedMessages.map(
(msg) => {
savedMessageIdsRef.current.add(msg.id);
return {
id: msg.id,
role: msg.role,
parts: (msg.parts ?? [
{
type: "text" as const,
text: msg.content,
},
]) as UIMessage["parts"],
};
},
);
setMessages(uiMessages);
setMessages(uiMessages);
// Always try to reconnect -- the stream endpoint
// returns 404 gracefully if no active run exists,
// and this avoids missing runs whose _streaming
// flag hasn't been persisted yet.
await attemptReconnect(sessionId, uiMessages);
} catch (err) {
console.error("Error loading session:", err);
} finally {
setLoadingSession(false);
}
// Clear loading state *before* reconnecting — the
// persisted messages are now visible. attemptReconnect
// manages its own `isReconnecting` state which shows
// "Resuming stream..." instead of "Loading session...".
setLoadingSession(false);
// Always try to reconnect -- the stream endpoint
// returns 404 gracefully if no active run exists,
// and this avoids missing runs whose _streaming
// flag hasn't been persisted yet.
await attemptReconnect(sessionId, uiMessages);
} catch (err) {
console.error("Error loading session:", err);
setLoadingSession(false);
}
},
[
currentSessionId,