Language server installation menu

CodeEdit.xcodeproj/project.pbxproj

@@ -11,6 +11,7 @@
 		283BDCBD2972EEBD002AFF81 /* Package.resolved in Resources */ = {isa = PBXBuildFile; fileRef = 283BDCBC2972EEBD002AFF81 /* Package.resolved */; };
 		284DC8512978BA2600BF2770 /* .all-contributorsrc in Resources */ = {isa = PBXBuildFile; fileRef = 284DC8502978BA2600BF2770 /* .all-contributorsrc */; };
 		2BE487F428245162003F3F64 /* OpenWithCodeEdit.appex in Embed Foundation Extensions */ = {isa = PBXBuildFile; fileRef = 2BE487EC28245162003F3F64 /* OpenWithCodeEdit.appex */; settings = {ATTRIBUTES = (RemoveHeadersOnCopy, ); }; };
+		302AD7FF2D8054D500231E16 /* ZIPFoundation in Frameworks */ = {isa = PBXBuildFile; productRef = 30818CB42D4E563900967860 /* ZIPFoundation */; };
 		30CB64912C16CA8100CC8A9E /* LanguageServerProtocol in Frameworks */ = {isa = PBXBuildFile; productRef = 30CB64902C16CA8100CC8A9E /* LanguageServerProtocol */; };
 		30CB64942C16CA9100CC8A9E /* LanguageClient in Frameworks */ = {isa = PBXBuildFile; productRef = 30CB64932C16CA9100CC8A9E /* LanguageClient */; };
 		583E529C29361BAB001AB554 /* SnapshotTesting in Frameworks */ = {isa = PBXBuildFile; productRef = 583E529B29361BAB001AB554 /* SnapshotTesting */; };
@@ -164,6 +165,7 @@
 			isa = PBXFrameworksBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
+				302AD7FF2D8054D500231E16 /* ZIPFoundation in Frameworks */,
 				6C85BB402C2105ED00EB5DEF /* CodeEditKit in Frameworks */,
 				6C66C31329D05CDC00DE9ED2 /* GRDB in Frameworks */,
 				58F2EB1E292FB954004A9BDE /* Sparkle in Frameworks */,
@@ -318,8 +320,7 @@
 				6CD3CA542C8B508200D83DCD /* CodeEditSourceEditor */,
 				6CB94D022CA1205100E8651C /* AsyncAlgorithms */,
 				6CC00A8A2CBEF150004E8134 /* CodeEditSourceEditor */,
-				6C73A6D22D4F1E550012D95C /* CodeEditSourceEditor */,
-				6C9DB9E32D55656300ACD86E /* CodeEditSourceEditor */,
+				30818CB42D4E563900967860 /* ZIPFoundation */,
 			);
 			productName = CodeEdit;
 			productReference = B658FB2C27DA9E0F00EA4DBD /* CodeEdit.app */;
@@ -422,7 +423,8 @@
 				303E88462C276FD600EEA8D9 /* XCRemoteSwiftPackageReference "LanguageServerProtocol" */,
 				6C4E37FA2C73E00700AEE7B5 /* XCRemoteSwiftPackageReference "SwiftTerm" */,
 				6CB94D012CA1205100E8651C /* XCRemoteSwiftPackageReference "swift-async-algorithms" */,
-				6C9DB9E22D55656300ACD86E /* XCRemoteSwiftPackageReference "CodeEditSourceEditor" */,
+				30818CB32D4E563900967860 /* XCRemoteSwiftPackageReference "ZIPFoundation" */,
+				30C549D82D77BDF8008DDEF8 /* XCRemoteSwiftPackageReference "CodeEditSourceEditor" */,
 			);
 			preferredProjectObjectVersion = 55;
 			productRefGroup = B658FB2D27DA9E0F00EA4DBD /* Products */;
@@ -1647,6 +1649,22 @@
 				minimumVersion = 0.13.2;
 			};
 		};
+		30818CB32D4E563900967860 /* XCRemoteSwiftPackageReference "ZIPFoundation" */ = {
+			isa = XCRemoteSwiftPackageReference;
+			repositoryURL = "https://github.com/weichsel/ZIPFoundation";
+			requirement = {
+				kind = upToNextMajorVersion;
+				minimumVersion = 0.9.19;
+			};
+		};
+		30C549D82D77BDF8008DDEF8 /* XCRemoteSwiftPackageReference "CodeEditSourceEditor" */ = {
+			isa = XCRemoteSwiftPackageReference;
+			repositoryURL = "https://github.com/CodeEditApp/CodeEditSourceEditor.git";
+			requirement = {
+				kind = upToNextMajorVersion;
+				minimumVersion = 0.10.0;
+			};
+		};
 		30CB648F2C16CA8100CC8A9E /* XCRemoteSwiftPackageReference "LanguageServerProtocol" */ = {
 			isa = XCRemoteSwiftPackageReference;
 			repositoryURL = "https://github.com/ChimeHQ/LanguageServerProtocol";
@@ -1759,6 +1777,11 @@
 			package = 2816F592280CF50500DD548B /* XCRemoteSwiftPackageReference "CodeEditSymbols" */;
 			productName = CodeEditSymbols;
 		};
+		30818CB42D4E563900967860 /* ZIPFoundation */ = {
+			isa = XCSwiftPackageProductDependency;
+			package = 30818CB32D4E563900967860 /* XCRemoteSwiftPackageReference "ZIPFoundation" */;
+			productName = ZIPFoundation;
+		};
 		30CB64902C16CA8100CC8A9E /* LanguageServerProtocol */ = {
 			isa = XCSwiftPackageProductDependency;
 			package = 30CB648F2C16CA8100CC8A9E /* XCRemoteSwiftPackageReference "LanguageServerProtocol" */;

CodeEdit.xcodeproj/project.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -31,7 +31,7 @@
     {
       "identity" : "codeeditsourceeditor",
       "kind" : "remoteSourceControl",
-      "location" : "https://github.com/CodeEditApp/CodeEditSourceEditor",
+      "location" : "https://github.com/CodeEditApp/CodeEditSourceEditor.git",
       "state" : {
         "revision" : "6b2c945501f0a5c15d8aa6d159fb2550c391bdd0",
         "version" : "0.10.0"
@@ -278,6 +278,15 @@
         "revision" : "d97db6d63507eb62c536bcb2c4ac7d70c8ec665e",
         "version" : "0.23.2"
       }
+    },
+    {
+      "identity" : "zipfoundation",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/weichsel/ZIPFoundation",
+      "state" : {
+        "revision" : "02b6abe5f6eef7e3cbd5f247c5cc24e246efcfe0",
+        "version" : "0.9.19"
+      }
     }
   ],
   "version" : 3

CodeEdit/Features/LSP/Registry/InstallationQueueManager.swift

@@ -0,0 +1,185 @@
+//
+//  InstallationQueueManager.swift
+//  CodeEdit
+//
+//  Created by Abe Malla on 3/13/25.
+//
+
+import Foundation
+
+/// A class to manage queued installations of language servers
+final class InstallationQueueManager {
+    static let shared: InstallationQueueManager = .init()
+
+    /// The maximum number of concurrent installations allowed
+    private let maxConcurrentInstallations: Int = 2
+    /// Queue of pending installations
+    private var installationQueue: [(RegistryItem, (Result<Void, Error>) -> Void)] = []
+    /// Currently running installations
+    private var runningInstallations: Set<String> = []
+    /// Installation status dictionary
+    private var installationStatus: [String: PackageInstallationStatus] = [:]
+
+    /// Add a package to the installation queue
+    func queueInstallation(package: RegistryItem, completion: @escaping (Result<Void, Error>) -> Void) {
+        // If we're already at max capacity and this isn't already running, mark as queued
+        if runningInstallations.count >= maxConcurrentInstallations && !runningInstallations.contains(package.name) {
+            installationStatus[package.name] = .queued
+            installationQueue.append((package, completion))
+
+            // Notify UI that package is queued
+            DispatchQueue.main.async {
+                NotificationCenter.default.post(
+                    name: .installationStatusChanged,
+                    object: nil,
+                    userInfo: ["packageName": package.name, "status": PackageInstallationStatus.queued]
+                )
+            }
+        } else {
+            startInstallation(package: package, completion: completion)
+        }
+    }
+
+    /// Starts the actual installation process for a package
+    private func startInstallation(package: RegistryItem, completion: @escaping (Result<Void, Error>) -> Void) {
+        installationStatus[package.name] = .installing
+        runningInstallations.insert(package.name)
+
+        // Notify UI that installation is now in progress
+        DispatchQueue.main.async {
+            NotificationCenter.default.post(
+                name: .installationStatusChanged,
+                object: nil,
+                userInfo: ["packageName": package.name, "status": PackageInstallationStatus.installing]
+            )
+        }
+
+        Task {
+            do {
+                try await RegistryManager.shared.installPackage(package: package)
+
+                // Notify UI that installation is complete
+                installationStatus[package.name] = .installed
+                DispatchQueue.main.async {
+                    NotificationCenter.default.post(
+                        name: .installationStatusChanged,
+                        object: nil,
+                        userInfo: ["packageName": package.name, "status": PackageInstallationStatus.installed]
+                    )
+                    completion(.success(()))
+                }
+            } catch {
+                // Notify UI that installation failed
+                installationStatus[package.name] = .failed(error)
+                DispatchQueue.main.async {
+                    NotificationCenter.default.post(
+                        name: .installationStatusChanged,
+                        object: nil,
+                        userInfo: ["packageName": package.name, "status": PackageInstallationStatus.failed(error)]
+                    )
+                    completion(.failure(error))
+                }
+            }
+
+            runningInstallations.remove(package.name)
+            processNextInstallations()
+        }
+    }
+
+    /// Process next installations from the queue if possible
+    private func processNextInstallations() {
+        while runningInstallations.count < maxConcurrentInstallations && !installationQueue.isEmpty {
+            let (package, completion) = installationQueue.removeFirst()
+            if runningInstallations.contains(package.name) {
+                continue
+            }
+
+            startInstallation(package: package, completion: completion)
+        }
+    }
+
+    /// Cancel an installation if it's in the queue
+    func cancelInstallation(packageName: String) {
+        installationQueue.removeAll { $0.0.name == packageName }
+        installationStatus[packageName] = .cancelled
+        runningInstallations.remove(packageName)
+
+        // Notify UI that installation was cancelled
+        DispatchQueue.main.async {
+            NotificationCenter.default.post(
+                name: .installationStatusChanged,
+                object: nil,
+                userInfo: ["packageName": packageName, "status": PackageInstallationStatus.cancelled]
+            )
+        }
+        processNextInstallations()
+    }
+
+    /// Get the current status of an installation
+    func getInstallationStatus(packageName: String) -> PackageInstallationStatus {
+        return installationStatus[packageName] ?? .notQueued
+    }
+
+    /// Cleans up installation status by removing completed or failed installations
+    func cleanUpInstallationStatus() {
+        let statusKeys = installationStatus.keys.map { $0 }
+        for packageName in statusKeys {
+            if let status = installationStatus[packageName] {
+                switch status {
+                case .installed, .failed, .cancelled:
+                    installationStatus.removeValue(forKey: packageName)
+                case .queued, .installing, .notQueued:
+                    break
+                }
+            }
+        }
+
+        // If an item is in runningInstallations but not in an active state in the status dictionary,
+        // it might be a stale reference
+        let currentRunning = runningInstallations.map { $0 }
+        for packageName in currentRunning {
+            let status = installationStatus[packageName]
+            if status != .installing {
+                runningInstallations.remove(packageName)
+            }
+        }
+
+        // Check for orphaned queue items
+        installationQueue = installationQueue.filter { item, _ in
+            return installationStatus[item.name] == .queued
+        }
+    }
+}
+
+/// Status of a package installation
+enum PackageInstallationStatus: Equatable {
+    case notQueued
+    case queued
+    case installing
+    case installed
+    case failed(Error)
+    case cancelled
+
+    static func == (lhs: PackageInstallationStatus, rhs: PackageInstallationStatus) -> Bool {
+        switch (lhs, rhs) {
+        case (.notQueued, .notQueued):
+            return true
+        case (.queued, .queued):
+            return true
+        case (.installing, .installing):
+            return true
+        case (.installed, .installed):
+            return true
+        case (.cancelled, .cancelled):
+            return true
+        case (.failed, .failed):
+            return true
+        default:
+            return false
+        }
+    }
+}
+
+extension Notification.Name {
+    static let installationStatusChanged = Notification.Name("installationStatusChanged")
+}