Prevent auto trigger from triggering when the current window does not have realtime suggestion on

Author: intitni

Core/Sources/Service/AutoTrigger.swift

@@ -19,9 +19,13 @@ actor AutoTrigger {
                 for await _ in stream {
                     triggerTask?.cancel()
                     if Task.isCancelled { break }
-                    triggerTask = Task {
+                    triggerTask = Task { @ServiceActor in
                         try? await Task.sleep(nanoseconds: 2_000_000_000)
                         if Task.isCancelled { return }
+                        guard let folderURL = try? await Environment.fetchCurrentProjectRootURL(),
+                              let workspace = workspaces[folderURL],
+                              workspace.isRealtimeSuggestionEnabled
+                        else { return }
                         try? await Environment.triggerAction("Realtime Suggestions")
                     }
                 }

Core/Sources/Service/XPCService.swift

@@ -9,24 +9,25 @@ import XPCShared
     public static let shared = TheActor()
 }
 
+@ServiceActor
+var workspaces = [URL: Workspace]()
+
 public class XPCService: NSObject, XPCServiceProtocol {
     @ServiceActor
     lazy var authService: CopilotAuthServiceType = Environment.createAuthService()
-    @ServiceActor
-    var workspaces = [URL: Workspace]()
 
     override public init() {
         super.init()
         let identifier = ObjectIdentifier(self)
         Task {
             await AutoTrigger.shared.start(by: identifier)
         }
-        Task { @ServiceActor [weak self] in
-            while let self, !Task.isCancelled {
+        Task { @ServiceActor in
+            while !Task.isCancelled {
                 try await Task.sleep(nanoseconds: 8 * 60 * 60 * 1_000_000_000)
-                for (url, workspace) in self.workspaces {
+                for (url, workspace) in workspaces {
                     if workspace.isExpired {
-                        self.workspaces[url] = nil
+                        workspaces[url] = nil
                     } else {
                         workspace.cleanUp()
                     }
@@ -106,7 +107,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let updatedContent = try await workspace.getSuggestedCode(
                     forFileAt: fileURL,
                     content: editor.content,
@@ -133,7 +134,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let updatedContent = workspace.getNextSuggestedCode(
                     forFileAt: fileURL,
                     content: editor.content,
@@ -157,7 +158,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let updatedContent = workspace.getPreviousSuggestedCode(
                     forFileAt: fileURL,
                     content: editor.content,
@@ -181,7 +182,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let updatedContent = workspace.getSuggestionRejectedCode(
                     forFileAt: fileURL,
                     content: editor.content,
@@ -205,7 +206,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let updatedContent = workspace.getSuggestionAcceptedCode(
                     forFileAt: fileURL,
                     content: editor.content,
@@ -229,7 +230,7 @@ public class XPCService: NSObject, XPCServiceProtocol {
                 let editor = try JSONDecoder().decode(EditorContent.self, from: editorContent)
                 let fileURL = try await Environment.fetchCurrentFileURL()
                 let workspace = try await fetchOrCreateWorkspaceIfNeeded(fileURL: fileURL)
-                
+
                 let canAutoTrigger = workspace.canAutoTriggerGetSuggestions(
                     forFileAt: fileURL,
                     lines: editor.lines,