native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
Swift
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576import ComposableArchitectureimport DependenciesTestSupportimport Foundationimport ProwlCLISharedimport Sharingimport Testing
@testable import Prowl
@MainActorstruct WorkflowsSettingsFeatureTests { private static let review = """ schema: prowl.workflow/v1 id: review name: Review roles: author: source: current reviewer: source: launch agents: [codex] steps: - id: launch launch: reviewer prompt: "Review." """
private static let codexProfile = AgentProfile( id: UUID(uuidString: "00000000-0000-0000-0000-000000000001")!, name: "Codex Review", runtime: .codex) private static let baseSettings = UserGlobalSettings( customCommands: [], agentProfiles: [codexProfile])
/// Temp user and repo directories, a client that scans them for real, and hooks to observe reveals /// and drive the directory watcher. private final class Fixture: @unchecked Sendable { let root: URL let userDirectory: URL let repoRoot: URL let revealed = LockIsolated<[URL]>([]) let opened = LockIsolated<[URL]>([]) let watchContinuations = LockIsolated<[AsyncStream<Void>.Continuation]>([]) let runTargets = LockIsolated<[WorkflowSettingsRunTarget]>([]) var scanError: WorkflowSettingsError?
init() throws { root = FileManager.default.temporaryDirectory .appending( path: "prowl-workflows-settings-\(UUID().uuidString)", directoryHint: .isDirectory) userDirectory = root.appending(path: "home/.prowl/workflows", directoryHint: .isDirectory) repoRoot = root.appending(path: "repo", directoryHint: .isDirectory) try FileManager.default.createDirectory(at: userDirectory, withIntermediateDirectories: true) try FileManager.default.createDirectory(at: repoRoot, withIntermediateDirectories: true) }
func cleanUp() { try? FileManager.default.removeItem(at: root) }
func write(_ yaml: String, to name: String) throws { let bundle = userDirectory.appending(path: name, directoryHint: .isDirectory) try FileManager.default.createDirectory(at: bundle, withIntermediateDirectories: true) try Data(yaml.utf8).write(to: bundle.appending(path: "workflow.yaml")) }
func scan() throws -> WorkflowSettingsScan { if let scanError { throw scanError } let context = { (scope: WorkflowScope) in WorkflowValidationContext(scope: scope) } let repoDirectory = WorkflowSources.repoDirectory(root: repoRoot) return WorkflowSettingsScan( bundleDirectory: nil, userDirectory: userDirectory, entries: try WorkflowDiscovery.catalog( sources: WorkflowSources(bundle: nil, user: userDirectory, repo: nil), context: context), repositories: [ WorkflowSettingsRepositoryScan( repositoryID: "repo", name: "Repo", rootPath: repoRoot.path(percentEncoded: false), directory: repoDirectory, entries: try WorkflowDiscovery.catalog( sources: WorkflowSources(bundle: nil, user: userDirectory, repo: repoDirectory), context: context)) ]) }
var client: WorkflowSettingsClient { WorkflowSettingsClient( scan: { _ in try self.scan() }, createWorkflow: { directory, request in try WorkflowStarterTemplate.write(request, in: directory) }, runTargets: { _ in self.runTargets.value }, reveal: { url in self.revealed.withValue { $0.append(url) } }, watch: { _ in let (stream, continuation) = AsyncStream<Void>.makeStream() self.watchContinuations.withValue { $0.append(continuation) } return stream }) }
func finishWatchers() { watchContinuations.withValue { continuations in for continuation in continuations { continuation.finish() } continuations.removeAll() } }
/// The rows for explicit settings — the TestStore's expectation closure reads `@Shared` /// as it was before the action, so expectations are built from the settings they expect. func expectedCatalog(_ settings: UserGlobalSettings = baseSettings) throws -> WorkflowSettingsCatalog { WorkflowSettingsCatalog.build(scan: try scan(), settings: settings) } }
private func makeStore( _ fixture: Fixture, storage: SettingsTestStorage, clock: TestClock<Duration> = TestClock(), serviceStatus: CLIServiceStatus = .listening(path: "/tmp/cli.sock"), installStatus: CLIInstallStatus = .installed(path: "/usr/local/bin/prowl"), cliUsable: Bool = true ) -> TestStoreOf<WorkflowsSettingsFeature> { withDependencies { $0.settingsFileStorage = storage.storage } operation: { @Shared(.userGlobalSettings) var settings $settings.withLock { $0 = Self.baseSettings } return TestStore( initialState: WorkflowsSettingsFeature.State(userDirectory: fixture.userDirectory) ) { WorkflowsSettingsFeature() } withDependencies: { $0[WorkflowSettingsClient.self] = fixture.client $0[OpenURLClient.self].open = { url in fixture.opened.withValue { $0.append(url) } } $0[CLIServiceStatusClient.self].current = { serviceStatus } $0[CLIInstallClient.self].installationStatus = { _ in installStatus } $0[CLIInstallClient.self].isUsable = { _ in cliUsable } $0.continuousClock = clock } } }
@Test func scopeSelectsOnlyTheRowsOwnedByThatSettingsSurface() throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let repoDirectory = WorkflowSources.repoDirectory(root: fixture.repoRoot) try FileManager.default.createDirectory(at: repoDirectory, withIntermediateDirectories: true) let repoBundle = repoDirectory.appending(path: "repo-review.pwlworkflow") try FileManager.default.createDirectory(at: repoBundle, withIntermediateDirectories: true) try Data(Self.review.utf8).write(to: repoBundle.appending(path: "workflow.yaml")) let catalog = WorkflowSettingsCatalog.build( scan: try fixture.scan(), settings: Self.baseSettings) var global = WorkflowsSettingsFeature.State(userDirectory: fixture.userDirectory) global.catalog = catalog var repository = WorkflowsSettingsFeature.State( scope: .repository( WorkflowSettingsRepositoryContext( repositoryID: "repo", name: "Repo", rootURL: fixture.repoRoot)), userDirectory: fixture.userDirectory) repository.catalog = catalog
#expect(global.displayedRows.map(\.scope) == [.user]) #expect(repository.displayedRows.map(\.scope) == [.repo]) #expect(repository.workflowDirectory == repoDirectory) }
@Test(.dependencies) func taskLoadsRowsAndCLIStatuses() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let store = makeStore(fixture, storage: SettingsTestStorage())
await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } let row = try #require(store.state.catalog.user.first) #expect(row.settingsKey == "user/review") #expect(row.isEnabled) #expect(row.launchRoles.first?.candidates.map(\.name) == ["Codex Review"]) #expect(store.state.cliBlocker == nil) #expect(store.state.catalog.repositories.isEmpty) // Files are watched too: an in-place edit touches the file's vnode, not the directory's. #expect(store.state.watchedPaths.contains(row.url)) #expect(store.state.watchedPaths.contains(fixture.userDirectory))
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func socketFailureAndMissingCLIBecomeTheBanner() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } let store = makeStore( fixture, storage: SettingsTestStorage(), serviceStatus: .failed(.socketAlreadyOwned, path: "/x"))
await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .failed(.socketAlreadyOwned, path: "/x") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } #expect( store.state.cliBlocker == .socketUnavailable( CLIServiceStatus.failed(.socketAlreadyOwned, path: "/x").failureDescription!))
var missing = WorkflowsSettingsFeature.State(userDirectory: fixture.userDirectory) missing.cliInstallStatus = .notInstalled missing.cliUsable = false missing.cliServiceStatus = .listening(path: "/x") #expect(missing.cliBlocker == .cliUnusable(.notInstalled)) // A dangling link, or a real file that is not an executable, is not a usable `prowl` either. missing.cliInstallStatus = .broken(path: "/usr/local/bin/prowl", destination: "/gone") #expect( missing.cliBlocker == .cliUnusable(.broken(path: "/usr/local/bin/prowl", destination: "/gone"))) missing.cliInstallStatus = .installedDifferentSource( path: "/usr/local/bin/prowl", destination: nil) #expect( missing.cliBlocker == .cliUnusable(.installedDifferentSource(path: "/usr/local/bin/prowl", destination: nil))) // Another build's executable `prowl` is usable (C2's rule); the socket rules first, and a // stopped server is unreachable even though it is not a failure. missing.cliInstallStatus = .installedDifferentSource( path: "/usr/local/bin/prowl", destination: "/other") missing.cliUsable = true #expect(missing.cliBlocker == nil) missing.cliServiceStatus = .stopped #expect( missing.cliBlocker == .socketUnavailable(CLIServiceStatus.stopped.unreachableDescription!))
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func disablingWritesTheKeyAndUpdatesTheRow() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let storage = SettingsTestStorage() let store = makeStore(fixture, storage: storage) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() }
var disabled = Self.baseSettings disabled.disabledWorkflowIDs = ["user/review"] await store.send(.setEnabled(settingsKey: "user/review", isEnabled: false)) { $0.catalog = try fixture.expectedCatalog(disabled) } #expect(store.state.catalog.user.first?.isEnabled == false) let stored = withDependencies { $0.settingsFileStorage = storage.storage } operation: { @Shared(.userGlobalSettings) var settings return settings } #expect(stored.disabledWorkflowIDs == ["user/review"]) #expect(stored.agentProfiles == [Self.codexProfile])
await store.send(.setEnabled(settingsKey: "user/review", isEnabled: true)) { $0.catalog = try fixture.expectedCatalog() } #expect(store.state.catalog.user.first?.isEnabled == true)
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func bindModeAndRememberedBindingPersist() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let storage = SettingsTestStorage() let store = makeStore(fixture, storage: storage) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } let key = try #require(store.state.catalog.user.first?.launchRoles.first?.memoryKey)
var expected = Self.baseSettings expected.setWorkflowBindMode(.auto, for: "user/review") await store.send(.setBindMode(settingsKey: "user/review", mode: .auto)) { [expected] in $0.catalog = try fixture.expectedCatalog(expected) } #expect(store.state.catalog.user.first?.bindModeOverride == .auto)
expected.remember(workflowBinding: key, profileID: Self.codexProfile.id) await store.send(.setRememberedBinding(key, profileID: Self.codexProfile.id)) { [expected] in $0.catalog = try fixture.expectedCatalog(expected) } #expect( store.state.catalog.user.first?.launchRoles.first?.rememberedProfileID == Self.codexProfile.id )
expected.forget(workflowBinding: key) await store.send(.setRememberedBinding(key, profileID: nil)) { [expected] in $0.catalog = try fixture.expectedCatalog(expected) } #expect(store.state.catalog.user.first?.launchRoles.first?.rememberedProfileID == nil)
expected.setWorkflowBindMode(nil, for: "user/review") await store.send(.setBindMode(settingsKey: "user/review", mode: nil)) { [expected] in $0.catalog = try fixture.expectedCatalog(expected) } let stored = withDependencies { $0.settingsFileStorage = storage.storage } operation: { @Shared(.userGlobalSettings) var settings return settings } #expect(stored.workflowBindModeOverrides.isEmpty) #expect(stored.workflowBindings.isEmpty)
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func newWorkflowWritesTheStarterOpensItAndReloads() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } let store = makeStore(fixture, storage: SettingsTestStorage()) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() }
await store.send(.newWorkflowTapped) { $0.newWorkflow = NewWorkflowDraft() } #expect(store.state.newWorkflowProblem == "Enter a name.") await store.send(.newWorkflowNameChanged("Daily Check")) { $0.newWorkflow?.name = "Daily Check" $0.newWorkflow?.id = "daily-check" } await store.send(.newWorkflowKindChanged(.multiAgent)) { $0.newWorkflow?.kind = .multiAgent } await store.send(.newWorkflowIconChanged(" calendar ")) { $0.newWorkflow?.icon = "calendar" } #expect(store.state.newWorkflowProblem == nil)
let expectedURL = fixture.userDirectory.appending( path: "daily-check.pwlworkflow", directoryHint: .isDirectory) await store.send(.createWorkflowTapped) { $0.newWorkflow = nil $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } await store.receive( .delegate(.notice(.workflowCreated(path: expectedURL.path(percentEncoded: false)))))
let row = try #require(store.state.catalog.user.first) #expect(row.workflowID == "daily-check") #expect(row.name == "Daily Check") #expect(row.icon == "calendar") #expect(row.roles.map(\.source) == [.current, .launch]) #expect(row.isValid) #expect(fixture.opened.value == [expectedURL.appending(path: "workflow.yaml")]) #expect(fixture.revealed.value.isEmpty)
// The same id again is refused by the form before anything touches the disk. await store.send(.newWorkflowTapped) { $0.newWorkflow = NewWorkflowDraft() } await store.send(.newWorkflowNameChanged("Daily Check")) { $0.newWorkflow?.name = "Daily Check" $0.newWorkflow?.id = "daily-check" } #expect(store.state.newWorkflowProblem == "A workflow with this ID already exists here.") await store.send(.createWorkflowTapped) await store.send(.newWorkflowIDChanged("prowl.daily")) { $0.newWorkflow?.id = "prowl.daily" $0.newWorkflow?.idEdited = true } #expect(store.state.newWorkflowProblem?.contains("reserved") == true) await store.send(.newWorkflowIDChanged("Daily Check")) { $0.newWorkflow?.id = "Daily Check" } #expect(store.state.newWorkflowProblem?.contains("lowercase") == true) await store.send(.newWorkflowIDChanged("")) { $0.newWorkflow?.id = "daily-check" $0.newWorkflow?.idEdited = false } await store.send(.dismissNewWorkflow) { $0.newWorkflow = nil }
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func anOpenDetailBecomesUnavailableWhenItsFileDisappears() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let store = makeStore(fixture, storage: SettingsTestStorage()) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } let row = try #require(store.state.catalog.user.first) await store.send(.showDetails(rowID: row.id)) { $0.path.append($0.detailState(for: row)) } let pathID = try #require(store.state.path.ids.first) try FileManager.default.removeItem(at: row.url)
await store.send(.reload) { $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() $0.path[id: pathID]?.row = nil }
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func confirmedDeletionReturnsToTheRefreshedIndex() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let store = makeStore(fixture, storage: SettingsTestStorage()) store.dependencies[WorkflowSettingsClient.self].trashWorkflow = { url in try FileManager.default.removeItem(at: url) } store.exhaustivity = .off await store.send(.task) let row = try #require(store.state.catalog.user.first) await store.send(.showDetails(rowID: row.id)) let id = try #require(store.state.path.ids.first) await store.send(.path(.element(id: id, action: .deleteTapped))) await store.send(.path(.element(id: id, action: .alert(.presented(.confirmDeletion(row.url)))))) await store.receive(.path(.element(id: id, action: .delegate(.deleted)))) await store.receive(.reload) #expect(store.state.path.isEmpty) #expect(store.state.catalog.user.isEmpty) fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func directoryChangesReloadAfterTheQuietPeriod() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } let clock = TestClock() let store = makeStore(fixture, storage: SettingsTestStorage(), clock: clock) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() }
// Two bursts inside the quiet period coalesce into one reload that sees the new file. let continuation = try #require(fixture.watchContinuations.value.last) continuation.yield() await store.receive(.directoriesChanged) await clock.advance(by: .milliseconds(100)) continuation.yield() await store.receive(.directoriesChanged) try fixture.write(Self.review, to: "review.pwlworkflow") await clock.advance(by: WorkflowsSettingsFeature.reloadDebounce) await store.receive(.reload) { $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } #expect(store.state.catalog.user.map(\.workflowID) == ["review"])
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func teardownStopsTheWatcherAndAPendingReload() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } let clock = TestClock() let store = makeStore(fixture, storage: SettingsTestStorage(), clock: clock) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } let continuation = try #require(fixture.watchContinuations.value.last) continuation.yield() await store.receive(.directoriesChanged)
// Neither the watcher nor the debounced reload survives the page going away. await store.send(.teardown) await clock.advance(by: WorkflowsSettingsFeature.reloadDebounce) await store.finish() }
@Test(.dependencies) func scanFailureIsReportedAndKeepsTheLastRows() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } fixture.scanError = WorkflowSettingsError(message: "Could not read a workflow folder.") let store = makeStore(fixture, storage: SettingsTestStorage())
await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.loadError = "Could not read a workflow folder." } #expect(store.state.scan == nil)
fixture.finishWatchers() await store.finish() }
@Test(.dependencies) func manageProfilesAndAskAgentDelegateOrPresent() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } let store = makeStore(fixture, storage: SettingsTestStorage())
await store.send(.manageProfilesTapped) await store.receive(.delegate(.openProfiles)) await store.send(.askAgentTapped) { $0.isAuthoringPromptPresented = true } await store.send(.setAuthoringPromptPresented(false)) { $0.isAuthoringPromptPresented = false } }}
extension WorkflowsSettingsFeatureTests { @Test(.dependencies) func anAppearingDetailRefreshesTheRunTargets() async throws { let fixture = try Fixture() defer { fixture.cleanUp() } try fixture.write(Self.review, to: "review.pwlworkflow") let store = makeStore(fixture, storage: SettingsTestStorage()) await store.send(.task) { $0.cliInstallStatus = .installed(path: "/usr/local/bin/prowl") $0.cliUsable = true $0.cliServiceStatus = .listening(path: "/tmp/cli.sock") $0.scan = try fixture.scan() $0.catalog = try fixture.expectedCatalog() } let row = try #require(store.state.catalog.user.first) await store.send(.showDetails(rowID: row.id)) { $0.path.append(WorkflowSettingsDetailFeature.State(row: row, runTargets: [])) } let detailID = try #require(store.state.path.ids.first)
// The main window selected another worktree while Settings stayed open. let target = WorkflowSettingsRunTarget( id: "wt-b", name: "feature", repositoryName: "Prowl", rootPath: "/tmp/prowl", isPreferred: true) fixture.runTargets.withValue { $0 = [target] } await store.send(.path(.element(id: detailID, action: .appeared))) { $0.runTargets = [target] $0.path[id: detailID]?.runTargets = [target] } #expect(store.state.path[id: detailID]?.preferredRunTarget?.displayName == "Prowl · feature")
fixture.finishWatchers() await store.finish() }}