opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: clear status indicator on message processing completion

Browse source 
Send status_end from Run() goroutine defer to ensure the Android status
indicator is cleared on all exit paths (normal, error, cancel).

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
KoheiYamashita 2026-02-20 15:09:22 +09:00
parent d9279c08cc
commit c4a4ba5d4c
2 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
android/core/data/src/main/java/io/picoclaw/android/core/data/repository/ChatRepositoryImpl.kt
View file

@ -47,6 +47,7 @@ class ChatRepositoryImpl(
webSocketClient.incomingMessages.collect { dto -> webSocketClient.incomingMessages.collect { dto ->
when (dto.type) { when (dto.type) {
"status" -> _statusLabel.value = dto.content "status" -> _statusLabel.value = dto.content
"status_end" -> _statusLabel.value = null
else -> { else -> {
_statusLabel.value = null _statusLabel.value = null
val entity = MessageMapper.toEntity(dto) val entity = MessageMapper.toEntity(dto)

7
pkg/agent/loop.go
View file

@ -233,6 +233,13 @@ func (al *AgentLoop) Run(ctx context.Context) error {
go func(m bus.InboundMessage, sk string) { go func(m bus.InboundMessage, sk string) {
defer func() { defer func() {
// Clear status indicator on completion (normal, error, or cancel)
if !constants.IsInternalChannel(m.Channel) {
al.bus.PublishOutbound(bus.OutboundMessage{
Channel: m.Channel, ChatID: m.ChatID,
Type: "status_end",
})
}
close(done) close(done)
al.procsMu.Lock() al.procsMu.Lock()
if cur, ok := al.activeProcs[sk]; ok && cur.done == done { if cur, ok := al.activeProcs[sk]; ok && cur.done == done {