native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
5.0 kB · 100 lines
Swift
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101import Foundationimport ProwlCLISharedimport XCTest
@testable import prowl
final class WorkflowCommandExecutorTests: XCTestCase { private var root: URL! private var home: URL!
override func setUpWithError() throws { root = FileManager.default.temporaryDirectory .appending(path: "prowl-workflow-executor-\(UUID().uuidString)", directoryHint: .isDirectory) .standardizedFileURL home = root.appending(path: "home", directoryHint: .isDirectory) try FileManager.default.createDirectory(at: home, withIntermediateDirectories: true) }
override func tearDownWithError() throws { try? FileManager.default.removeItem(at: root) }
private func executor(bundledSkillIDs: Set<String>? = ["prowl.adversarial-reviewer"]) -> WorkflowCommandExecutor { WorkflowCommandExecutor(bundledSkillIDs: bundledSkillIDs, homeDirectory: home, currentDirectory: root) }
@discardableResult private func write(_ yaml: String, at relativePath: String) throws -> URL { let url = root.appending(path: relativePath, directoryHint: .notDirectory) try FileManager.default.createDirectory(at: url, withIntermediateDirectories: true) try Data(yaml.utf8).write(to: url.appending(path: "workflow.yaml")) return url }
func testValidateReportsAValidFileWithItsIdentity() throws { let url = try write(WorkflowFixtures.minimal(id: "demo"), at: "flows/demo.pwlworkflow") let payload = try executor().validate(path: "flows/demo.pwlworkflow", scope: nil) XCTAssertTrue(payload.valid) XCTAssertEqual(payload.path, url.path(percentEncoded: false)) XCTAssertEqual(payload.workflow, WorkflowIdentity(id: "demo", name: "Demo")) XCTAssertEqual(payload.diagnostics, []) }
func testValidateReportsErrorsWithPositions() throws { try write(WorkflowFixtures.minimal(id: "demo", extraSteps: " - id: b\n close: ghost"), at: "bad.pwlworkflow") let payload = try executor().validate(path: "bad.pwlworkflow", scope: nil) XCTAssertFalse(payload.valid) XCTAssertEqual(payload.workflow?.id, "demo", "A file that parses keeps its identity") XCTAssertEqual(payload.diagnostics.map(\.code), ["undefined_role"]) XCTAssertEqual(payload.diagnostics.first?.line, 12) }
func testScopeIsInferredFromTheDirectoryUnlessOverridden() throws { try write(WorkflowFixtures.adversarialReview, at: "home/.prowl/workflows/review.pwlworkflow") try write(WorkflowFixtures.adversarialReview, at: "repo/.prowl/workflows/review.pwlworkflow") try write(WorkflowFixtures.adversarialReview, at: "elsewhere/review.pwlworkflow") let executor = executor()
XCTAssertEqual(executor.inferredScope(of: root.appending(path: "home/.prowl/workflows/review.pwlworkflow")), .user) XCTAssertEqual(executor.inferredScope(of: root.appending(path: "repo/.prowl/workflows/review.pwlworkflow")), .repo) XCTAssertEqual(executor.inferredScope(of: root.appending(path: "elsewhere/review.pwlworkflow")), .user)
let inferred = try executor.validate(path: "repo/.prowl/workflows/review.pwlworkflow", scope: nil) XCTAssertEqual(inferred.diagnostics.map(\.code), ["reserved_id"]) let bundle = try executor.validate(path: "repo/.prowl/workflows/review.pwlworkflow", scope: .bundle) XCTAssertTrue(bundle.valid) }
func testSkillsAreUncheckedWithoutABundle() throws { try write(WorkflowFixtures.adversarialReview, at: "review.pwlworkflow") let payload = try executor(bundledSkillIDs: nil).validate(path: "review.pwlworkflow", scope: .bundle) XCTAssertTrue(payload.valid) XCTAssertEqual(payload.diagnostics.map(\.code), ["skill_unchecked"]) }
func testMissingAndDirectoryPathsFailWithTypedErrors() throws { XCTAssertThrowsError(try executor().validate(path: "missing.pwlworkflow", scope: nil)) { error in XCTAssertEqual((error as? ExitError)?.code, CLIErrorCode.pathNotFound) } let invalid = try executor().validate(path: "home", scope: nil) XCTAssertEqual(invalid.diagnostics.map(\.code), ["unsupported_format"]) }
func testSchemaPayloadCarriesTheDefinitionSchema() throws { let payload = try executor().schema() let object = try XCTUnwrap(JSONSerialization.jsonObject(with: payload.schema.bytes) as? [String: Any]) XCTAssertEqual(object["$id"] as? String, WorkflowJSONSchema.identifier) XCTAssertEqual(object["$schema"] as? String, "https://json-schema.org/draft/2020-12/schema") } func testActionSchemaMatchesTheCheckedInContract() throws { let payload = try executor().schema(action: true) let url = URL(filePath: #filePath).deletingLastPathComponent().deletingLastPathComponent() .deletingLastPathComponent() .appending(path: "Sources/ProwlCLIContracts/Resources/action-definition-schema.json") let expected = try JSONSerialization.jsonObject(with: Data(contentsOf: url)) as? NSDictionary let actual = try JSONSerialization.jsonObject(with: payload.schema.bytes) as? NSDictionary XCTAssertEqual(actual, expected) }
}