fix: refresh mobile home run badges eagerly

Author: Pyiner

mobile/garyx-mobile/App/GaryxMobile/GaryxMobileModel+Composer.swift

@@ -197,8 +197,10 @@ extension GaryxMobileModel {
                     intentId: clientIntentId,
                     error: "Thread is busy"
                 )
+                refreshHomeThreadsAfterLocalRunStateChange()
                 return
             }
+            refreshHomeThreadsAfterLocalRunStart()
             lastError = nil
             if !hasPendingDirectFollowUpAssistant(threadId: thread.id, assistantId: assistantId) {
                 activeAssistantMessageIdsByThread[thread.id] = assistantId
@@ -241,6 +243,7 @@ extension GaryxMobileModel {
                     intentId: clientIntentId,
                     error: displayMessage(for: error)
                 )
+                refreshHomeThreadsAfterLocalRunStateChange()
             }
             lastError = displayMessage(for: error)
         }
@@ -383,6 +386,7 @@ extension GaryxMobileModel {
                 intentId: queued.clientIntentId,
                 text: queued.text
             )
+            refreshHomeThreadsAfterLocalRunStart()
             activeAssistantMessageIdsByThread[queued.threadId] = assistantId
             let workspacePath = Self.firstNonEmpty(
                 thread.workspacePath,
@@ -410,6 +414,7 @@ extension GaryxMobileModel {
                 intentId: queued.clientIntentId,
                 error: displayMessage(for: error)
             )
+            refreshHomeThreadsAfterLocalRunStateChange()
             lastError = displayMessage(for: error)
         }
     }
@@ -449,6 +454,7 @@ extension GaryxMobileModel {
             intentId: clientIntentId,
             runId: result.runId
         )
+        refreshHomeThreadsAfterLocalRunStateChange()
         if !hasPendingDirectFollowUpAssistant(threadId: acceptedThreadId, assistantId: assistantMessageId) {
             activeAssistantMessageIdsByThread[acceptedThreadId] = assistantMessageId
         }

mobile/garyx-mobile/App/GaryxMobile/GaryxMobileModel+Threads.swift

@@ -263,6 +263,31 @@ extension GaryxMobileModel {
         }
     }
 
+    func refreshHomeThreadsAfterLocalRunStart() {
+        refreshHomeThreadsAfterLocalRunStateChange()
+        scheduleHomeThreadsRunStateRefresh(after: 350_000_000)
+    }
+
+    func refreshHomeThreadsAfterLocalRunStateChange() {
+        scheduleHomeThreadsRunStateRefresh()
+    }
+
+    private func scheduleHomeThreadsRunStateRefresh(after delayNanos: UInt64? = nil) {
+        guard hasGatewaySettings else { return }
+        Task { [weak self] in
+            if let delayNanos {
+                try? await Task.sleep(nanoseconds: delayNanos)
+                guard !Task.isCancelled else { return }
+            }
+            await self?.refreshHomeThreadsRunStateIfConnected()
+        }
+    }
+
+    private func refreshHomeThreadsRunStateIfConnected() async {
+        guard hasGatewaySettings, case .ready = connectionState else { return }
+        await refreshThreads(silent: true)
+    }
+
     func applyRecentThreadsPage(_ page: GaryxRecentThreadsPage, preservesLoadedPages: Bool) {
         let pageIds = pendingThreadArchives.visibleThreads(page.threads).map(\.id)
         let returnedEnd = page.offset + page.count
@@ -1311,6 +1336,7 @@ extension GaryxMobileModel {
         } else {
             runTracker.completeCommittedRun(threadId: threadId)
         }
+        refreshHomeThreadsAfterLocalRunStateChange()
     }
 
     func summaryWithCommittedRunState(_ thread: GaryxThreadSummary) -> GaryxThreadSummary {