native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
2.6 kB · 64 lines
Swift
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465import Foundation
nonisolated enum ClaudeRuntimeDecoder { enum Failure: Error { case unsupported }
struct Record: Decodable { let pid: Int32 let sessionId: String let cwd: String let kind: String let pidDomain: String let procStart: String let status: String let updatedAt: Double let statusUpdatedAt: Double }
static func decode(_ data: Data, process: AgentProcessGeneration) throws -> AgentNativeSnapshot { try snapshot(record(data), process: process) }
static func record(_ data: Data) throws -> Record { guard data.count <= 65_536 else { throw Failure.unsupported } return try JSONDecoder().decode(Record.self, from: data) }
/// The record's session when it belongs to `process`: the same pid and OS start second, /// an interactive Darwin kind, a UUID session id, and an absolute cwd. The status fields /// are not consulted, so a status this decoder does not know still yields the identity /// (the session resolver reads it through `ClaudeSessionRegistry`, docs-ai 079.004). static func sessionID(_ record: Record, process: AgentProcessGeneration) -> String? { guard record.pid == process.pid, record.kind == "interactive", record.pidDomain == "darwin", UUID(uuidString: record.sessionId) != nil, record.cwd.hasPrefix("/"), let start = processStart(record), start.timeIntervalSince1970 == floor(process.startedAt.timeIntervalSince1970) else { return nil } return record.sessionId }
static func snapshot(_ record: Record, process: AgentProcessGeneration) throws -> AgentNativeSnapshot { guard let sessionID = sessionID(record, process: process), let start = processStart(record), record.updatedAt.isFinite, record.statusUpdatedAt.isFinite, record.updatedAt >= record.statusUpdatedAt, record.statusUpdatedAt / 1000 >= start.timeIntervalSince1970 else { throw Failure.unsupported } let state: AgentRawState switch record.status { case "busy", "shell": state = .working case "waiting": state = .blocked case "idle": state = .idle default: throw Failure.unsupported } return AgentNativeSnapshot(sessionID: sessionID, state: state, statusUpdatedAt: record.statusUpdatedAt) }
/// The registry uses `TZ=UTC ps -o lstart`, which has whole-second precision. private static func processStart(_ record: Record) -> Date? { let formatter = DateFormatter() formatter.locale = Locale(identifier: "en_US_POSIX") formatter.timeZone = TimeZone(secondsFromGMT: 0) formatter.dateFormat = "EEE MMM d HH:mm:ss yyyy" return formatter.date(from: record.procStart) }}