Add cancel in-flight real-time suggestion request on keyboard or mouse events

Author: intitni

Core/Sources/Service/AutoTrigger.swift

@@ -32,8 +32,18 @@ actor AutoTrigger {
                 for await _ in stream {
                     triggerTask?.cancel()
                     if Task.isCancelled { break }
+                    guard await Environment.isXcodeActive() else { continue }
+
+                    await withTaskGroup(of: Void.self) { group in
+                        for (_, workspace) in await workspaces {
+                            group.addTask {
+                                await workspace.cancelAllRealtimeSuggestionFulfillmentTasks()
+                            }
+                        }
+                    }
+
                     triggerTask = Task { @ServiceActor in
-                        try? await Task.sleep(nanoseconds: 3_000_000_000)
+                        try? await Task.sleep(nanoseconds: 2_500_000_000)
                         if Task.isCancelled { return }
                         let fileURL = try? await Environment.fetchCurrentFileURL()
                         guard let folderURL = try? await Environment.fetchCurrentProjectRootURL(fileURL),

Core/Sources/Service/CGEventObserver.swift

@@ -15,7 +15,7 @@ final class CGEventObserver: CGEventObserverType {
 
     private var continuation: AsyncStream<Void>.Continuation
     private var port: CFMachPort?
-    private let eventsOfInterest: Set<CGEventType> = [.keyUp, .leftMouseUp, .mouseMoved]
+    private let eventsOfInterest: Set<CGEventType> = [.keyUp, .leftMouseUp, .rightMouseUp]
     private let tapLocation: CGEventTapLocation = .cghidEventTap
     private let tapPlacement: CGEventTapPlacement = .tailAppendEventTap
     private let tapOptions: CGEventTapOptions = .listenOnly

Core/Sources/Service/Environment.swift

@@ -16,6 +16,23 @@ private struct FailedToFetchFileURLError: Error, LocalizedError {
 
 enum Environment {
     static var now = { Date() }
+    
+    static var isXcodeActive: () async ->  Bool = {
+        var activeXcodes = [NSRunningApplication]()
+        var retryCount = 0
+        // Sometimes runningApplications returns 0 items.
+        while activeXcodes.isEmpty, retryCount < 3 {
+            activeXcodes = NSRunningApplication
+                .runningApplications(withBundleIdentifier: "com.apple.dt.Xcode")
+                .sorted { lhs, _ in
+                    if lhs.isActive { return true }
+                    return false
+                }
+            if retryCount > 0 { try? await Task.sleep(nanoseconds: 1_000_000) }
+            retryCount += 1
+        }
+        return !activeXcodes.isEmpty
+    }
 
     static var fetchCurrentProjectRootURL: (_ fileURL: URL?) async throws -> URL? = { fileURL in
         let appleScript = """