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

chore(mac): drop duplicate job-state tracking

main
Peter Steinberger 2025-12-09 01:06:36 +01:00
parent 15729e9ea0
commit 5b5a79b90b
1 changed files with 1 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
apps/macos/Sources/Clawdis/AgentRPC.swift
View File

@ -29,7 +29,6 @@ actor AgentRPC {
private var waiters: [CheckedContinuation<String, Error>] = [] private var waiters: [CheckedContinuation<String, Error>] = []
private let logger = Logger(subsystem: "com.steipete.clawdis", category: "agent.rpc") private let logger = Logger(subsystem: "com.steipete.clawdis", category: "agent.rpc")
private var starting = false private var starting = false
private var activeJobs = 0
private struct RpcError: Error { let message: String } private struct RpcError: Error { let message: String }
@ -203,10 +202,7 @@ actor AgentRPC {
} }
continue continue
} }
if let jobEvent = self.parseJobStateEvent(from: line) { if self.parseJobStateEvent(from: line) != nil { continue }
Task { await self.updateJobState(jobEvent) }
continue
}
if let waiter = waiters.first { if let waiter = waiters.first {
self.waiters.removeFirst() 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? { private func parseHeartbeatEvent(from line: String) -> HeartbeatEvent? {
guard let data = line.data(using: .utf8) else { return nil } guard let data = line.data(using: .utf8) else { return nil }
guard guard