Revert FS Stream Filtering Changes

Author: thecoolwinter

CodeEdit/Features/CEWorkspace/Models/CEWorkspaceFileManager+DirectoryEvents.swift

@@ -9,35 +9,24 @@ import Foundation
 
 /// This extension handles the file system events triggered by changes in the root folder.
 extension CEWorkspaceFileManager {
-    struct ResolvedFSEvent: Hashable {
-        let file: CEWorkspaceFile
-        let eventType: FSEvent
-    }
-
     /// Called by `fsEventStream` when an event occurs.
     ///
     /// This method may be called on a background thread, but all work done by this function will be queued on the main
     /// thread.
     /// - Parameter events: An array of events that occurred.
     func fileSystemEventReceived(events: [DirectoryEventStream.Event]) {
         DispatchQueue.main.async {
-            var files: Set<ResolvedFSEvent> = []
+            var files: Set<CEWorkspaceFile> = []
             for event in events {
                 // Event returns file/folder that was changed, but in tree we need to update it's parent
-                guard let eventFileUrl = URL(string: event.path, relativeTo: self.folderUrl) else {
-                    continue
-                }
-                let parentUrl = eventFileUrl.deletingLastPathComponent()
-                guard let parentFileItem = self.flattenedFileItems[parentUrl.path] else {
+                guard let parentUrl = URL(string: event.path, relativeTo: self.folderUrl)?.deletingLastPathComponent(),
+                      let parentFileItem = self.flattenedFileItems[parentUrl.path] else {
                     continue
                 }
 
                 switch event.eventType {
                 case .changeInDirectory, .itemChangedOwner, .itemModified:
                     continue
-//                    if let fileItem = self.flattenedFileItems[eventFileUrl.path] {
-//                        files.insert(ResolvedFSEvent(file: fileItem, eventType: event.eventType))
-//                    }
                 case .rootChanged:
                     // TODO: #1880 - Handle workspace root changing.
                     continue
@@ -48,7 +37,7 @@ extension CEWorkspaceFileManager {
                         // swiftlint:disable:next line_length
                         self.logger.error("Failed to rebuild files for event: \(event.eventType.rawValue), path: \(event.path, privacy: .sensitive)")
                     }
-                    files.insert(ResolvedFSEvent(file: parentFileItem, eventType: event.eventType))
+                    files.insert(parentFileItem)
                 }
             }
             if !files.isEmpty {
@@ -192,17 +181,13 @@ extension CEWorkspaceFileManager {
     }
 
     /// Notify observers that an update occurred in the watched files.
-    func notifyObservers(updatedItems: Set<ResolvedFSEvent>) {
+    func notifyObservers(updatedItems: Set<CEWorkspaceFile>) {
         observers.allObjects.reversed().forEach { delegate in
             guard let delegate = delegate as? CEWorkspaceFileManagerObserver else {
                 observers.remove(delegate)
                 return
             }
-            let eventsFilter = delegate.fileManagerEventsFilter()
-            let events = updatedItems.compactMap({ eventsFilter.contains($0.eventType) ? $0.file : nil })
-            if !events.isEmpty {
-                delegate.fileManagerUpdated(updatedItems: Set(events))
-            }
+            delegate.fileManagerUpdated(updatedItems: updatedItems)
         }
     }
 

CodeEdit/Features/CEWorkspace/Models/CEWorkspaceFileManager+FileManagement.swift

@@ -38,10 +38,7 @@ extension CEWorkspaceFileManager {
             )
 
             try rebuildFiles(fromItem: file.isFolder ? file : file.parent ?? file)
-            notifyObservers(updatedItems: [ResolvedFSEvent(
-                file: file.isFolder ? file : file.parent ?? file,
-                eventType: .itemCreated
-            )])
+            notifyObservers(updatedItems: [file.isFolder ? file : file.parent ?? file])
 
             guard let newFolder = getFile(folderUrl.path(), createIfNotFound: true) else {
                 throw FileManagerError.fileNotFound
@@ -106,10 +103,7 @@ extension CEWorkspaceFileManager {
             }
 
             try rebuildFiles(fromItem: file.isFolder ? file : file.parent ?? file)
-            notifyObservers(updatedItems: [ResolvedFSEvent(
-                file: file.isFolder ? file : file.parent ?? file,
-                eventType: .itemCreated
-            )])
+            notifyObservers(updatedItems: [file.isFolder ? file : file.parent ?? file])
 
             // Create if not found here because this should be indexed if we're creating it.
             // It's not often a user makes a file and then doesn't use it.
@@ -290,13 +284,13 @@ extension CEWorkspaceFileManager {
 
             if let parent = file.parent {
                 try rebuildFiles(fromItem: parent)
-                notifyObservers(updatedItems: [ResolvedFSEvent(file: parent, eventType: .changeInDirectory)])
+                notifyObservers(updatedItems: [parent])
             }
 
             // If we have the new parent file, let's rebuild that directory too
             if let newFileParent = getFile(newLocation.deletingLastPathComponent().path) {
                 try rebuildFiles(fromItem: newFileParent)
-                notifyObservers(updatedItems: [ResolvedFSEvent(file: newFileParent, eventType: .changeInDirectory)])
+                notifyObservers(updatedItems: [newFileParent])
             }
 
             return getFile(newLocation.absoluteURL.path)

CodeEdit/Features/CEWorkspace/Models/CEWorkspaceFileManager.swift

@@ -11,16 +11,9 @@ import AppKit
 import OSLog
 
 protocol CEWorkspaceFileManagerObserver: AnyObject {
-    func fileManagerEventsFilter() -> Set<FSEvent>
     func fileManagerUpdated(updatedItems: Set<CEWorkspaceFile>)
 }
 
-extension CEWorkspaceFileManagerObserver {
-    func fileManagerEventsFilter() -> Set<FSEvent> {
-        FSEvent.all()
-    }
-}
-
 /// This class is used to load, modify, and listen to files on a user's machine.
 ///
 /// The workspace file manager provides an API for:

CodeEdit/Features/CEWorkspace/Models/DirectoryEventStream.swift

@@ -16,19 +16,6 @@ enum FSEvent: String {
     case itemModified
     case itemRemoved
     case itemRenamed
-
-    static func all() -> Set<FSEvent> {
-        [
-            .changeInDirectory,
-            .rootChanged,
-            .itemChangedOwner,
-            .itemCreated,
-            .itemCloned,
-            .itemModified,
-            .itemRemoved,
-            .itemRenamed
-        ]
-    }
 }
 
 /// Creates a stream of events using the File System Events API.

CodeEdit/Features/Editor/Models/Restoration/UndoManagerRegistration.swift

@@ -49,10 +49,6 @@ final class UndoManagerRegistration: ObservableObject {
 }
 
 extension UndoManagerRegistration: CEWorkspaceFileManagerObserver {
-    func fileManagerEventsFilter() -> Set<FSEvent> {
-        [.itemModified, .itemRemoved]
-    }
-
     /// Managers need to be cleared when the following is true:
     /// - The file is not open in any editors
     /// - The file is updated externally

CodeEdit/Features/SourceControl/SourceControlManager+GitClient.swift

@@ -135,7 +135,7 @@ extension SourceControlManager {
             return
         }
 
-        var updatedStatusFor: Set<CEWorkspaceFileManager.ResolvedFSEvent> = []
+        var updatedStatusFor: Set<CEWorkspaceFile> = []
         // Refresh status of file manager files
         for changedFile in changedFiles {
             guard let file = fileManager.getFile(changedFile.ceFileKey) else {
@@ -144,13 +144,13 @@ extension SourceControlManager {
             if file.gitStatus != changedFile.anyStatus() {
                 file.gitStatus = changedFile.anyStatus()
             }
-            updatedStatusFor.insert(.init(file: file, eventType: .itemModified))
+            updatedStatusFor.insert(file)
         }
 
         for (_, file) in fileManager.flattenedFileItems
-        where !updatedStatusFor.contains(.init(file: file, eventType: .itemModified)) && file.gitStatus != nil {
+        where !updatedStatusFor.contains(file) && file.gitStatus != nil {
             file.gitStatus = nil
-            updatedStatusFor.insert(.init(file: file, eventType: .itemModified))
+            updatedStatusFor.insert(file)
         }
 
         if updatedStatusFor.isEmpty {