Clean up progress logic

ios/App/App/plugins/AbsDownloader.swift

@@ -106,38 +106,34 @@ public class AbsDownloader: CAPPlugin, URLSessionDownloadDelegate {
         self.progressStatusWorkItem = DispatchWorkItem { [weak self] in
             // Clean up the work item when done
             defer { self?.progressStatusWorkItem = nil }
-            var downloadItemProgress = [String: DownloadItem]()
             
-            // Get the latest progress
+            // Fetch active downloads in a thread-safe way
-            self?.progressStatusQueue.sync {
+            func fetchActiveDownloads() -> [String: DownloadItem]? {
-                if let progressItems = self?.downloadItemProgress {
+                self?.progressStatusQueue.sync { self?.downloadItemProgress }
-                    downloadItemProgress = progressItems
-                }
             }
             
-            while !downloadItemProgress.isEmpty {
+            // Remove a completed download item in a thread-safe way
-                for item in downloadItemProgress.values {
+            func handleDoneDownloadItem(_ item: DownloadItem) {
-                    try? self?.notifyListeners("onItemDownloadUpdate", data: item.asDictionary())
-                    
-                    // Clean up a completed download
-                    if item.isDoneDownloading() {
                 self?.progressStatusQueue.async(flags: .barrier) {
+                    defer {
+                        Database.shared.removeDownloadItem(item)
                         self?.downloadItemProgress.removeValue(forKey: item.id!)
                     }
-                        defer { Database.shared.removeDownloadItem(item) }
                     self?.handleDownloadTaskCompleteFromDownloadItem(item)
                 }
             }
             
+            // While there are active download items, emit status updates
+            while !(fetchActiveDownloads()?.isEmpty ?? false) {
+                if let activeDownloads = fetchActiveDownloads() {
+                    for item in activeDownloads.values {
+                        try? self?.notifyListeners("onItemDownloadUpdate", data: item.asDictionary())
+                        if item.isDoneDownloading() { handleDoneDownloadItem(item) }
+                    }
+                }
+                
                 // Wait 200ms before reporting status again
                 Thread.sleep(forTimeInterval: TimeInterval(0.2))
-                
-                // Get the latest progress
-                self?.progressStatusQueue.sync {
-                    if let progressItems = self?.downloadItemProgress {
-                        downloadItemProgress = progressItems
-                    }
-                }
             }
         }