native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
Swift
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179import AppKitimport ComposableArchitectureimport Foundationimport ProwlCLISharedimport UniformTypeIdentifiers
struct WorkflowHistoryOperations: DependencyKey, Sendable { var preview: @Sendable () async throws -> WorkflowHistoryPreview /// Removes one finished run on explicit request (Workflow History › Delete Run). var delete: @Sendable (URL) async throws -> Void /// Removes every finished run that is not in use (Settings › Clear History). var clear: @Sendable () async throws -> WorkflowHistoryCleanup var export: @MainActor @Sendable (URL) async throws -> URL?
static var liveValue: Self { Self( preview: { let storage = WorkflowHistoryStorage.configured @Dependency(\.date.now) var now let timestamp = now return try await Task.detached(priority: .utility) { try WorkflowHistory(storage: storage).preview(now: timestamp) }.value }, delete: { directory in let storage = WorkflowHistoryStorage.configured @Dependency(\.date.now) var now let timestamp = now try await Task.detached(priority: .utility) { try WorkflowHistory(storage: storage).delete(directory, now: timestamp) }.value }, clear: { let storage = WorkflowHistoryStorage.configured @Dependency(\.date.now) var now let timestamp = now return try await Task.detached(priority: .utility) { try WorkflowHistory(storage: storage).clear(now: timestamp) }.value }, export: { directory in let panel = NSSavePanel() panel.allowedContentTypes = [.zip] panel.nameFieldStringValue = "workflow-\(directory.lastPathComponent).zip" guard await panel.begin() == .OK, let destination = panel.url else { return nil } let storage = WorkflowHistoryStorage.configured try await Task.detached(priority: .utility) { try WorkflowHistory(storage: storage).export(directory, to: destination) }.value return destination }) }
static let testValue = Self( preview: { WorkflowHistoryPreview(entries: [], now: Date(timeIntervalSince1970: 0)) }, delete: { _ in }, clear: { WorkflowHistoryCleanup() }, export: { _ in nil })}
/// The Settings › Workflows history summary: how much the archive holds and a way to clear it./// Retention itself is automatic (`WorkflowHistoryPreview.retention`) and not a user setting.@Reducerstruct WorkflowHistoryFeature { @ObservableState struct State: Equatable { var preview = WorkflowHistoryPreview(entries: [], now: Date(timeIntervalSince1970: 0)) var hasLoaded = false var isBusy = false var error: String? var result: String? @Presents var alert: AlertState<Alert>?
var runCount: Int { preview.entries.count } var totalBytes: Int64 { preview.totalBytes } /// Finished runs an explicit Clear may remove; live runs stay. var removableCount: Int { preview.entries.count(where: \.removable) } }
enum Action: Equatable { case refresh case loaded(WorkflowHistoryPreview) case failed(String) case clearTapped case cleared(WorkflowHistoryCleanup) case alert(PresentationAction<Alert>) }
enum Alert: Equatable { case confirmClear }
@Dependency(WorkflowHistoryOperations.self) var operations
var body: some Reducer<State, Action> { Reduce<State, Action> { state, action in switch action { case .refresh: guard !state.isBusy else { return .none } state.isBusy = true state.error = nil return .run { send in do { await send(.loaded(try await operations.preview())) } catch { await send(.failed(String(describing: error))) } } case .loaded(let preview): state.error = nil state.isBusy = false state.hasLoaded = true state.preview = preview return .none case .failed(let message): state.isBusy = false state.error = message return .none case .clearTapped: guard !state.isBusy, state.removableCount > 0 else { return .none } let count = state.removableCount state.alert = AlertState { TextState(String(localized: "Clear Workflow History?")) } actions: { ButtonState(role: .cancel) { TextState(String(localized: "Cancel")) } ButtonState(role: .destructive, action: .confirmClear) { TextState(String(localized: "Clear History")) } } message: { let message = if count == 1 { String( localized: "1 finished run will be deleted. Runs that are still active are kept. This cannot be undone.", comment: "Clear workflow history confirmation: singular (1 run)" ) } else { String( format: String( localized: "%lld finished runs will be deleted. Runs that are still active are kept. This cannot be undone.", comment: "Clear workflow history confirmation: plural (N runs)" ), count ) } return TextState(message) } return .none case .alert(.presented(.confirmClear)): guard !state.isBusy else { return .none } state.isBusy = true state.error = nil state.result = nil return .run { send in do { await send(.cleared(try await operations.clear())) } catch { await send(.failed(String(describing: error))) } } case .alert: return .none case .cleared(let cleanup): state.isBusy = true let count = cleanup.removed.count state.result = if count == 1 { String(localized: "Removed 1 run.", comment: "Workflow history clear result: singular") } else { String( format: String(localized: "Removed %lld runs.", comment: "Workflow history clear result: plural"), count ) } state.error = cleanup.failures.isEmpty ? nil : cleanup.failures.joined(separator: "\n") return .run { send in do { await send(.loaded(try await operations.preview())) } catch { await send(.failed(String(describing: error))) } } } } .ifLet(\.$alert, action: \.alert) }}