native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
24 kB · 646 lines
Swift
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647import Networkimport SwiftUI
struct ContentView: View { @Environment(\.scenePhase) private var scenePhase @State private var sessions: [MirrorSession] = [] @State private var selectedID: UUID? @State private var showsConnection = false @State private var columns: NavigationSplitViewVisibility @State private var compactColumn: NavigationSplitViewColumn @State private var wasBackgrounded = false
/// iPhone starts on the detail column with the session list hidden; larger devices show both. static func initialLayout(for idiom: UIUserInterfaceIdiom) -> ( columns: NavigationSplitViewVisibility, compactColumn: NavigationSplitViewColumn ) { idiom == .phone ? (.detailOnly, .detail) : (.all, .sidebar) }
init() { let layout = Self.initialLayout(for: UIDevice.current.userInterfaceIdiom) _columns = State(initialValue: layout.columns) _compactColumn = State(initialValue: layout.compactColumn) #if DEBUG if CommandLine.arguments.contains("--mirror-ui-fixture") { let multiple = CommandLine.arguments.contains("--mirror-ui-multiple-fixtures") let fixture = MirrorUIFixture.session(longOutput: multiple) let fixtures = multiple ? [fixture, MirrorUIFixture.session(name: "Second Fixture")] : [fixture] _sessions = State(initialValue: fixtures) _selectedID = State(initialValue: fixture.id) } #endif }
#if DEBUG @State private var fixtureCreatedPane: MirrorPaneDescriptor? #endif
var body: some View { #if DEBUG if CommandLine.arguments.contains("--mirror-ui-launch-fixture") { NavigationStack { if let pane = fixtureCreatedPane { Text("Created mirror: \(pane.title)").accessibilityIdentifier("created-mirror") } else { MirrorLaunchView(execute: MirrorUIFixture.launchCommand) { fixtureCreatedPane = $0 } } } } else { sessionContent } #else sessionContent #endif }
private var sessionContent: some View { NavigationSplitView(columnVisibility: $columns, preferredCompactColumn: $compactColumn) { List(selection: $selectedID) { ForEach(sessions) { session in HStack { VStack(alignment: .leading, spacing: 4) { Text( session.pane?.projectName ?? session.pane?.title ?? session.configuration.address ) .font(.headline) Text(session.pane?.subtitle ?? session.configuration.address).font(.caption) Text(session.status.label).font(.caption).foregroundStyle(session.status.displayColor) } Spacer(minLength: 8) Button { close(session) } label: { Image(systemName: "xmark.circle") .padding(8).contentShape(Rectangle()) } .buttonStyle(.borderless) .accessibilityLabel( "Close mirror \(session.pane?.projectName ?? session.configuration.address)" ) .accessibilityIdentifier( "close-mirror-\(session.pane?.projectName ?? session.configuration.address)" ) .help("Remove this mirror; the Host terminal keeps running") } .tag(session.id) .contextMenu { Button("Close Mirror", role: .destructive) { close(session) } } } } .navigationTitle("Prowl Mirror") .toolbar { Button("Add Remote Pane", systemImage: "plus") { showsConnection = true } .accessibilityIdentifier("add-remote-pane") } .overlay { if sessions.isEmpty { ContentUnavailableView( "Connect to Prowl", systemImage: "network", description: Text("Add a Host, then choose an open pane.")) } } } detail: { if let session = sessions.first(where: { $0.id == selectedID }) { MirrorReadingView(session: session) .id(session.id) } else { ContentUnavailableView { Label("Choose a Remote Pane", systemImage: "rectangle.split.2x1") } description: { Text("Your Host keeps running the terminal. This device mirrors its current text.") } actions: { Button("Add Remote Pane") { showsConnection = true }.buttonStyle(.borderedProminent) } } } .onChange(of: selectedID) { _, new in if new != nil { compactColumn = .detail } } .sheet(isPresented: $showsConnection) { AddConnectionView { session in sessions.append(session) selectedID = session.id showsConnection = false } } .onChange(of: scenePhase) { _, new in if new == .background { wasBackgrounded = true } if new == .active, wasBackgrounded { wasBackgrounded = false for session in sessions { session.foreground() } } } }
private func close(_ session: MirrorSession) { session.disconnect() sessions.removeAll { $0.id == session.id } if selectedID == session.id { selectedID = sessions.first?.id } }}
extension MirrorSession.Status { var displayColor: Color { switch self { case .live: .green case .disconnected, .takenOver, .hostStopped, .paneClosed, .incompatible: .red case .connecting, .choosingPane, .subscribing: .secondary } }}
private struct AddConnectionView: View { @Environment(\.dismiss) private var dismiss let onSelect: (MirrorSession) -> Void @State private var address = "" @State private var port = "7880" @State private var key = "" @State private var error: String? @State private var session: MirrorSession? @State private var added = false @State private var showsScanner = false
var body: some View { NavigationStack { Form { if let session, session.status == .choosingPane { if session.supportsLaunch { Section { NavigationLink { MirrorLaunchView(session: session) { pane in session.select(pane) added = true onSelect(session) } } label: { Label("New Agent Pane", systemImage: "plus.rectangle") } .accessibilityIdentifier("new-agent-pane") } } Section("Select a Host pane") { if session.panes.isEmpty { Text("No open panes. Open a terminal on Host, then refresh.") } ForEach(session.panes) { pane in Button { session.select(pane) added = true onSelect(session) } label: { HStack { VStack(alignment: .leading) { Text(pane.projectName ?? pane.title).font(.headline) Text(pane.subtitle ?? pane.directory).font(.caption).foregroundStyle(.secondary) } Spacer() Text(pane.busy ? "Take Over" : "Mirror") } } } Button("Refresh Panes") { session.refreshPanes() } } } else { Section("Host connection") { Button { showsScanner = true } label: { Label("Scan QR Code", systemImage: "qrcode.viewfinder") } .disabled(session?.status == .connecting) .accessibilityIdentifier("scan-pairing-qr") TextField("Host IP", text: $address) .textInputAutocapitalization(.never).autocorrectionDisabled() .accessibilityIdentifier("host-address") TextField("Port", text: $port).keyboardType(.numberPad) MirrorPairingCodeField(key: $key) Button(session?.status == .connecting ? "Connecting…" : "Connect") { connect() } .disabled(session?.status == .connecting) } } if let error = error ?? session?.error { Section { Text(error).foregroundStyle(.red).textSelection(.enabled) } } } .navigationTitle("Remote Mirror Pane") .toolbar { Button("Cancel") { dismiss() } } .onAppear { #if DEBUG if CommandLine.arguments.contains("--mirror-ui-connection-fixture") { if session == nil { let fixture = MirrorUIFixture.connectionSession() session = fixture fixture.connect() } return } #endif do { if let saved = try MirrorSavedConnection.load() { address = saved.address port = String(saved.port) key = saved.pairingKey } } catch { self.error = error.localizedDescription } } } .sheet(isPresented: $showsScanner) { MirrorPairingScanner { text in showsScanner = false do { let payload = try MirrorPairingPayload.parse(text) address = payload.address port = String(payload.port) key = payload.code connect() } catch { self.error = error.localizedDescription } } } .onDisappear { if !added { session?.disconnect() } } }
private func connect() { let host = address.trimmingCharacters(in: .whitespacesAndNewlines) guard let number = UInt16(port), number > 0, IPv4Address(host) != nil || IPv6Address(host) != nil else { error = "Enter an IP address and a port between 1 and 65535." return } error = nil session?.disconnect() let config = MirrorSavedConnection( address: host, port: number, pairingKey: key.trimmingCharacters(in: .whitespacesAndNewlines)) let newSession = MirrorSession(configuration: config) newSession.onVerifiedConnection = { verified in do { try verified.save() } catch { self.error = error.localizedDescription } } session = newSession newSession.connect() }}
/// The row tops and the visible top of the live reader. It is not observable: it changes on every/// scroll, and no view shows it.private final class MirrorLiveReadingLayout { var rowTops: [MirrorDocument.Row.ID: CGFloat] = [:] var visibleTop: CGFloat = 0}
private struct MirrorReadingView: View { @Bindable var session: MirrorSession @State private var showsConnectionEditor = false @State private var position = ScrollPosition(edge: .top) @State private var layout = MirrorLiveReadingLayout() /// The anchor to restore when the live reader appears. While it is set, scrolling does not /// replace the stored anchor. @State private var restoring: MirrorReadingAnchor? @State private var isEditing = false
init(session: MirrorSession) { self.session = session _restoring = State(initialValue: session.liveReadingAnchor) }
var body: some View { VStack(spacing: 0) { HStack { Label( session.status.label, systemImage: session.status == .live ? "checkmark.circle" : "network.slash" ) .foregroundStyle(session.status.displayColor) .fontWeight(session.status == .live ? .regular : .semibold) Spacer() if session.status == .takenOver { Button("Take Over") { session.retry(takeover: true) } } else if session.status == .disconnected || session.status == .hostStopped { Button("Retry") { session.retry() } } } .font(.callout).padding() if let error = session.error { Text(error).font(.caption).foregroundStyle(.secondary).padding(.horizontal) } if session.status == .choosingPane { List(session.panes) { pane in Button { session.select(pane) } label: { VStack(alignment: .leading) { Text(pane.projectName ?? pane.title) Text(pane.subtitle ?? pane.directory).font(.caption) Text(pane.busy ? "Take Over" : "Mirror") } } } Button("Refresh Panes") { session.refreshPanes() } } if session.showsHistory { MirrorHistoryView(session: session) } else { ScrollViewReader { proxy in ScrollView { VStack(alignment: .leading, spacing: 12) { MirrorDocumentView(text: session.text, onRowTop: rowTopChanged) .frame(maxWidth: .infinity, alignment: .leading) .accessibilityIdentifier("mirror-live-text") Color.clear.frame(height: 1).id("latest") } .padding() .coordinateSpace(MirrorDocumentView.rowSpace) } .scrollPosition($position) .accessibilityIdentifier("mirror-live-scroll") .onDisappear { restoring = session.liveReadingAnchor } .onAppear { if session.followsLatest { restoring = nil position.scrollTo(edge: .bottom) } else if let restoring { restore(restoring, with: proxy) } } .onScrollGeometryChange(for: CGFloat.self) { geometry in max(0, geometry.contentOffset.y + geometry.contentInsets.top) } action: { _, top in layout.visibleTop = top storeAnchor() } .onScrollPhaseChange { _, phase in guard phase == .interacting else { return } session.followsLatest = false restoring = nil } .onChange(of: session.revision) { _, _ in if session.followsLatest { proxy.scrollTo("latest", anchor: .bottom) } } .onChange(of: session.completedScroll) { _, completion in guard completion != nil else { return } restoring = nil position.scrollTo(edge: .top) } .safeAreaInset(edge: .top) { VStack(alignment: .leading, spacing: 8) { HStack { Button("Scroll Up", systemImage: "arrow.up") { session.scroll(.upward) } .disabled(!session.canScroll(.upward)) .accessibilityIdentifier("mirror-scroll-up") .help("Scroll the Host pane toward earlier output") Spacer() if session.isScrolling { ProgressView("Scrolling…").accessibilityIdentifier("mirror-scroll-progress") } Spacer() Button("Scroll Down", systemImage: "arrow.down") { session.scroll(.downward) } .disabled(!session.canScroll(.downward)) .accessibilityIdentifier("mirror-scroll-down") .help("Scroll the Host pane toward later output") } if let error = session.scrollError { Text(error).foregroundStyle(.secondary) } else if session.status == .live && !session.supportsRemoteScroll { Text("Update Host to enable remote scrolling.").foregroundStyle(.secondary) } } .font(.caption).padding(.horizontal).padding(.vertical, 8).background(.bar) } .safeAreaInset(edge: .bottom) { HStack { Toggle("Follow latest", isOn: $session.followsLatest).toggleStyle(.button) Spacer() Button("Latest") { session.followsLatest = true proxy.scrollTo("latest", anchor: .bottom) } } .disabled(session.isScrolling) .font(.caption).padding(.horizontal).padding(.vertical, 8).background(.bar) } } } Divider() VStack(alignment: .leading) { MirrorComposer(session: session, isEditing: $isEditing) .fixedSize(horizontal: false, vertical: true) .overlay(alignment: .topLeading) { if session.draft.isEmpty { Text("Write a message").foregroundStyle(.secondary) .padding(.horizontal, 5).padding(.vertical, 8).allowsHitTesting(false) } } .accessibilityLabel("Write a message") .accessibilityIdentifier("mirror-message-input") HStack { Text(session.submissionHint) .font(.caption).foregroundStyle(.secondary) Spacer() if isEditing { Button("Hide Keyboard", systemImage: "keyboard.chevron.compact.down") { isEditing = false } .labelStyle(.iconOnly) .accessibilityIdentifier("mirror-dismiss-keyboard") } if session.submission?.outcome.status == .unknown || session.submission?.outcome.status == .pending { Button("Check Receipt") { session.querySubmission() } .disabled(session.status != .live) } if session.submission?.outcome.status == .unknown { Button("I've Checked Host Output") { session.acknowledgeUnknownSubmission() } } Button("Send", systemImage: "arrow.up") { session.submitDraft() } .disabled(!session.canSubmit) } if let submission = session.submission, submission.outcome.status == .pending || submission.outcome.status == .unknown { DisclosureGroup("Submitted message") { ScrollView { Text(submission.text).textSelection(.enabled) } .frame(maxHeight: 120) } .font(.caption) } } .padding() } .navigationTitle(session.pane?.title ?? "Remote Mirror") .navigationBarTitleDisplayMode(.inline) .toolbar { Button(session.showsHistory ? "Live Output" : "History", systemImage: "clock") { if session.showsHistory { session.showsHistory = false } else { session.loadHistory(refresh: true) } } .disabled(!session.showsHistory && (!session.supportsHistory || session.status != .live)) Button("Edit Connection", systemImage: "network") { showsConnectionEditor = true } .help("Update the Host address, port or pairing key") } .sheet(isPresented: $showsConnectionEditor) { MirrorConnectionEditor(configuration: session.configuration) { configuration in session.updateConnection(configuration) } } }
private func restore(_ anchor: MirrorReadingAnchor, with proxy: ScrollViewProxy) { if let top = layout.rowTops[anchor.row] { restoring = nil position.scrollTo(y: top + anchor.offset) } else if MirrorDocument(session.text).rows.contains(where: { $0.id == anchor.row }) { // Lay out the anchor row first. `rowTopChanged` then applies the offset in the row. proxy.scrollTo(anchor.row, anchor: .top) } else { restoring = nil position.scrollTo(edge: .bottom) } }
private func rowTopChanged(_ row: MirrorDocument.Row.ID, _ top: CGFloat?) { layout.rowTops[row] = top guard let top else { return } if let anchor = restoring { guard anchor.row == row else { return } restoring = nil position.scrollTo(y: top + anchor.offset) } else { storeAnchor() } }
private func storeAnchor() { guard restoring == nil, let anchor = MirrorReadingAnchor(top: layout.visibleTop, rowTops: layout.rowTops) else { return } session.liveReadingAnchor = anchor }}
private struct MirrorConnectionEditor: View { @Environment(\.dismiss) private var dismiss let configuration: MirrorSavedConnection let onConnect: (MirrorSavedConnection) -> Void @State private var address = "" @State private var port = "" @State private var key = "" @State private var error: String?
var body: some View { NavigationStack { Form { TextField("Host IP", text: $address) .textInputAutocapitalization(.never).autocorrectionDisabled() TextField("Port", text: $port).keyboardType(.numberPad) MirrorPairingCodeField(key: $key) Text("Reconnect only if the pane is free. Changing Host opens pane selection.") .font(.caption).foregroundStyle(.secondary) if let error { Text(error).foregroundStyle(.red) } Button("Reconnect") { let host = address.trimmingCharacters(in: .whitespacesAndNewlines) guard let number = UInt16(port), number > 0, IPv4Address(host) != nil || IPv6Address(host) != nil else { error = "Enter a valid IP address and port." return } let secret = key.trimmingCharacters(in: .whitespacesAndNewlines) do { if !secret.isEmpty { _ = try MirrorPairingCode.normalized(secret) } } catch { self.error = error.localizedDescription return } onConnect( .init( address: host, port: number, pairingKey: secret, credential: secret.isEmpty ? configuration.credential : nil)) dismiss() } } .navigationTitle("Edit Connection") .toolbar { Button("Cancel") { dismiss() } } .onAppear { address = configuration.address port = String(configuration.port) key = configuration.pairingKey } } }}
private struct MirrorHistoryView: View { @Bindable var session: MirrorSession @State private var position: ScrollPosition @State private var observedInitialPosition = false
init(session: MirrorSession) { self.session = session _position = State(initialValue: ScrollPosition(y: session.historyReadingOffset)) } var body: some View { VStack(alignment: .leading) { HStack { if let capturedAt = session.historyCapturedAt { Text("Captured \(capturedAt.formatted(date: .omitted, time: .standard))") } Spacer() Button("Refresh History") { session.loadHistory(refresh: true) } .disabled(session.isLoadingHistory || session.status != .live) }.font(.caption) if session.historyTruncated { Text("Older lines omitted. The first retained line may begin mid-paragraph.") .font(.caption).foregroundStyle(.secondary) } Text( "Loaded lines \(session.historyOffset + 1)–\(session.historyOffset + session.historyLines.count)" ) .font(.caption).foregroundStyle(.secondary) ScrollViewReader { proxy in ScrollView { VStack(alignment: .leading) { Button("Load Earlier 200 Lines") { session.loadHistory() } .disabled( session.historyOffset == 0 || session.isLoadingHistory || session.status != .live) // iOS 27 sends no taps to a button in the same stack as selectable text rows. LazyVStack(alignment: .leading) { ForEach( session.historyOffset..<(session.historyOffset + session.historyLines.count), id: \.self ) { index in let line = session.historyLines[index - session.historyOffset] Text(line.isEmpty ? " " : line).textSelection(.enabled) .frame(maxWidth: .infinity, alignment: .leading) .id(index) } } } } .scrollPosition($position) .accessibilityIdentifier("mirror-history-scroll") .onAppear { position.scrollTo(y: session.historyReadingOffset) } .onScrollGeometryChange(for: CGFloat.self) { geometry in max(0, geometry.contentOffset.y + geometry.contentInsets.top) } action: { _, offset in if observedInitialPosition { session.historyReadingOffset = offset } observedInitialPosition = true } .onChange(of: session.historyCapturedAt) { _, _ in position.scrollTo(y: session.historyReadingOffset) } .onChange(of: session.historyOffset) { old, new in if old > new { proxy.scrollTo(old, anchor: .top) } } } if session.isLoadingHistory { ProgressView("Loading history…") } }.padding() }}