diff --git a/apps/macos/Sources/Clawdis/AgentRPC.swift b/apps/macos/Sources/Clawdis/AgentRPC.swift index 2466fe494..a3155191e 100644 --- a/apps/macos/Sources/Clawdis/AgentRPC.swift +++ b/apps/macos/Sources/Clawdis/AgentRPC.swift @@ -29,7 +29,6 @@ actor AgentRPC { private var waiters: [CheckedContinuation] = [] private let logger = Logger(subsystem: "com.steipete.clawdis", category: "agent.rpc") private var starting = false - private var activeJobs = 0 private struct RpcError: Error { let message: String } @@ -203,10 +202,7 @@ actor AgentRPC { } continue } - if let jobEvent = self.parseJobStateEvent(from: line) { - Task { await self.updateJobState(jobEvent) } - continue - } + if self.parseJobStateEvent(from: line) != nil { continue } if let waiter = waiters.first { self.waiters.removeFirst() @@ -215,21 +211,6 @@ actor AgentRPC { } } - private func updateJobState(_ evt: JobStateEvent) async { - switch evt.state.lowercased() { - case "started", "streaming": - self.activeJobs &+= 1 - case "done", "error": - self.activeJobs = max(0, self.activeJobs - 1) - default: - break - } - let working = self.activeJobs > 0 - await MainActor.run { - AppStateStore.shared.setWorking(working) - } - } - private func parseHeartbeatEvent(from line: String) -> HeartbeatEvent? { guard let data = line.data(using: .utf8) else { return nil } guard