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

fix(ios): refresh history after external final sync

Browse Source 
Follow up on review feedback by reconciling history even when an external final event includes a decodable assistant message. This preserves the immediate append for responsiveness while still pulling in the user prompt and persisted tool results from the canonical history.
This commit is contained in:
Eulices Lopez 2026-03-19 11:25:03 -04:00
parent b76dd70375
commit c8137f5dc7
2 changed files with 49 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/shared/OpenClawKit/Sources/OpenClawChatUI/ChatViewModel.swift
View File

@ -855,7 +855,8 @@ public final class OpenClawChatViewModel {
}
if let message = self.decodedAssistantMessage(from: chat.message) {
self.messages.append(message)
} else if shouldResetExternalLiveState {
}
if shouldResetExternalLiveState {
Task { await self.refreshHistoryAfterRun() }
}
case "error":

47
apps/shared/OpenClawKit/Tests/OpenClawKitTests/ChatViewModelTests.swift
View File

@ -623,6 +623,53 @@ extension TestChatTransportState {
#expect(await MainActor.run { vm.streamingAssistantText } == nil)
}
@Test func externalFinalMessageStillRefreshesHistory() async throws {
let now = Date().timeIntervalSince1970 * 1000
let history1 = historyPayload(messages: [])
let history2 = historyPayload(
messages: [
chatTextMessage(role: "user", text: "prompt from another client", timestamp: now),
chatTextMessage(role: "assistant", text: "final from external event", timestamp: now + 1),
])
let (transport, vm) = await makeViewModel(historyResponses: [history1, history2])
await MainActor.run { vm.load() }
try await waitUntil("bootstrap history loaded") { await MainActor.run { vm.messages.isEmpty } }
#expect(await transport.historyRequestCount() == 1)
let finalMessage = AnyCodable([
"role": "assistant",
"content": [["type": "text", "text": "final from external event"]],
"timestamp": now + 1,
])
transport.emit(
.chat(
OpenClawChatEventPayload(
runId: "external-run",
sessionKey: "agent:main:main",
state: "final",
message: finalMessage,
errorMessage: nil)))
try await waitUntil("final message appended immediately") {
await MainActor.run {
vm.messages.contains(where: { message in
message.role == "assistant" && message.content.contains(where: { $0.text == "final from external event" })
})
}
}
try await waitUntil("history refreshed after external final message") {
await transport.historyRequestCount() == 2
}
try await waitUntil("user prompt synced from history") {
await MainActor.run {
vm.messages.contains(where: { message in
message.role == "user" && message.content.contains(where: { $0.text == "prompt from another client" })
})
}
}
}
@Test func preservesMessageIDsAcrossHistoryRefreshes() async throws {
let now = Date().timeIntervalSince1970 * 1000
let history1 = historyPayload(messages: [chatTextMessage(role: "user", text: "hello", timestamp: now)])