native macOS codings agent orchestrator prowl.onev.cat
Something went wrong. Try again.
9.0 kB · 243 lines
Swift
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244import ComposableArchitectureimport SwiftUI
extension RepositoriesFeature { // swiftlint:disable:next cyclomatic_complexity function_body_length func reduceWorktreeOrdering( state: inout State, action: WorktreeOrderingAction ) -> Effect<Action> { switch action { case .repositoriesMoved(let source, let destination): var orderedRepositoryIDs = state.orderedRepositoryIDs() orderedRepositoryIDs.move(fromOffsets: source, toOffset: destination) state.repositoryOrderIDs = orderedRepositoryIDs let repositoryOrderIDs = state.repositoryOrderIDs return .run { _ in await repositoryPersistence.saveRepositoryOrderIDs(repositoryOrderIDs) }
case .pinnedWorktreesMoved(let repositoryID, let source, let destination): guard let repository = state.repositories[id: repositoryID] else { return .none } var orderedPinnedWorktreeIDs = state.orderedPinnedWorktreeIDs(in: repository) orderedPinnedWorktreeIDs.move(fromOffsets: source, toOffset: destination) state.pinnedWorktreeIDs = state.replacingPinnedWorktreeIDs( in: repository, with: orderedPinnedWorktreeIDs ) let pinnedWorktreeIDs = state.pinnedWorktreeIDs return .run { _ in await repositoryPersistence.savePinnedWorktreeIDs(pinnedWorktreeIDs) }
case .unpinnedWorktreesMoved(let repositoryID, let source, let destination): guard let repository = state.repositories[id: repositoryID] else { return .none } var orderedUnpinnedWorktreeIDs = state.orderedUnpinnedWorktreeIDs(in: repository) orderedUnpinnedWorktreeIDs.move(fromOffsets: source, toOffset: destination) if orderedUnpinnedWorktreeIDs.isEmpty { state.worktreeOrderByRepository.removeValue(forKey: repositoryID) } else { state.worktreeOrderByRepository[repositoryID] = orderedUnpinnedWorktreeIDs } let worktreeOrderByRepository = state.worktreeOrderByRepository return .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) }
case .pinWorktree(let worktreeID): if let worktree = state.worktree(for: worktreeID), state.isMainWorktree(worktree) { let wasPinned = state.pinnedWorktreeIDs.contains(worktreeID) state.pinnedWorktreeIDs.removeAll { $0 == worktreeID } var didUpdateWorktreeOrder = false if let repositoryID = state.repositoryID(containing: worktreeID), var order = state.worktreeOrderByRepository[repositoryID] { order.removeAll { $0 == worktreeID } if order.isEmpty { state.worktreeOrderByRepository.removeValue(forKey: repositoryID) } else { state.worktreeOrderByRepository[repositoryID] = order } didUpdateWorktreeOrder = true } var effects: [Effect<Action>] = [] if wasPinned { let pinnedWorktreeIDs = state.pinnedWorktreeIDs effects.append( .run { _ in await repositoryPersistence.savePinnedWorktreeIDs(pinnedWorktreeIDs) } ) } if didUpdateWorktreeOrder { let worktreeOrderByRepository = state.worktreeOrderByRepository effects.append( .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) } ) } return .merge(effects) } analyticsClient.capture("worktree_pinned", [String: Any]?.none) state.pinnedWorktreeIDs.removeAll { $0 == worktreeID } state.pinnedWorktreeIDs.insert(worktreeID, at: 0) var didUpdateWorktreeOrder = false if let repositoryID = state.repositoryID(containing: worktreeID), var order = state.worktreeOrderByRepository[repositoryID] { order.removeAll { $0 == worktreeID } if order.isEmpty { state.worktreeOrderByRepository.removeValue(forKey: repositoryID) } else { state.worktreeOrderByRepository[repositoryID] = order } didUpdateWorktreeOrder = true } let pinnedWorktreeIDs = state.pinnedWorktreeIDs var effects: [Effect<Action>] = [ .run { _ in await repositoryPersistence.savePinnedWorktreeIDs(pinnedWorktreeIDs) } ] if didUpdateWorktreeOrder { let worktreeOrderByRepository = state.worktreeOrderByRepository effects.append( .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) } ) } return .merge(effects)
case .unpinWorktree(let worktreeID): analyticsClient.capture("worktree_unpinned", [String: Any]?.none) state.pinnedWorktreeIDs.removeAll { $0 == worktreeID } var didUpdateWorktreeOrder = false if let repositoryID = state.repositoryID(containing: worktreeID) { var order = state.worktreeOrderByRepository[repositoryID] ?? [] order.removeAll { $0 == worktreeID } order.insert(worktreeID, at: 0) state.worktreeOrderByRepository[repositoryID] = order didUpdateWorktreeOrder = true } let pinnedWorktreeIDs = state.pinnedWorktreeIDs var effects: [Effect<Action>] = [ .run { _ in await repositoryPersistence.savePinnedWorktreeIDs(pinnedWorktreeIDs) } ] if didUpdateWorktreeOrder { let worktreeOrderByRepository = state.worktreeOrderByRepository effects.append( .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) } ) } return .merge(effects)
case .worktreeNotificationReceived(let worktreeID): guard notificationReorderTarget(for: worktreeID, state: state) != nil else { return .none } if state.isSidebarDragActive { state.pendingSidebarNotifyReorderIDs.removeAll { $0 == worktreeID } state.pendingSidebarNotifyReorderIDs.append(worktreeID) return .none } guard applyNotificationReorder(for: worktreeID, state: &state, animated: true) else { return .none } let worktreeOrderByRepository = state.worktreeOrderByRepository return .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) }
case .setSidebarDragActive(let isActive): guard state.isSidebarDragActive != isActive else { return .none } state.isSidebarDragActive = isActive guard !isActive else { return .none } let pendingWorktreeIDs = state.pendingSidebarNotifyReorderIDs state.pendingSidebarNotifyReorderIDs = [] guard !pendingWorktreeIDs.isEmpty else { return .none } var didReorder = false for worktreeID in pendingWorktreeIDs { didReorder = applyNotificationReorder(for: worktreeID, state: &state, animated: false) || didReorder } guard didReorder else { return .none } let worktreeOrderByRepository = state.worktreeOrderByRepository return .run { _ in await repositoryPersistence.saveWorktreeOrderByRepository(worktreeOrderByRepository) }
case .setMoveNotifiedWorktreeToTop(let isEnabled): state.moveNotifiedWorktreeToTop = isEnabled return .none } }
var worktreeOrderingReducer: some ReducerOf<Self> { Reduce { state, action in guard case .worktreeOrdering(let action) = action else { return .none } return reduceWorktreeOrdering(state: &state, action: action) } }}
private func notificationReorderTarget( for worktreeID: Worktree.ID, state: RepositoriesFeature.State) -> (repositoryID: Repository.ID, repository: Repository)? { guard state.moveNotifiedWorktreeToTop, let repositoryID = state.repositoryID(containing: worktreeID), let repository = state.repositories[id: repositoryID], let worktree = repository.worktrees[id: worktreeID], !state.isWorktreeArchived(worktree.id), !state.isMainWorktree(worktree), !state.isWorktreePinned(worktree) else { return nil } return (repositoryID, repository)}
private func applyNotificationReorder( for worktreeID: Worktree.ID, state: inout RepositoriesFeature.State, animated: Bool) -> Bool { guard let target = notificationReorderTarget(for: worktreeID, state: state) else { return false } let reordered = reorderedUnpinnedWorktreeIDs( for: worktreeID, in: target.repository, state: state ) guard state.worktreeOrderByRepository[target.repositoryID] != reordered else { return false } if animated { withAnimation(.snappy(duration: 0.2)) { state.worktreeOrderByRepository[target.repositoryID] = reordered } } else { state.worktreeOrderByRepository[target.repositoryID] = reordered } return true}