异步同步数据到Widget，减少APP启动时间

Author: Finb

Bark/AppDelegate+Realm.swift

@@ -138,7 +138,7 @@ extension AppDelegate {
                     realm.add(message, update: .all)
                 }
             }
-            WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+            WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
         } catch {
             // 一般不会失败，真失败了算你小子运气差
         }

Bark/AppDelegate.swift

@@ -127,7 +127,7 @@ class AppDelegate: UIResponder, UIApplicationDelegate, UNUserNotificationCenterD
             try? realm.write {
                 realm.delete(message)
             }
-            WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+            WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
         }
 
         completionHandler(.newData)

Common/WidgetHistorySnapshotStore.swift

@@ -6,14 +6,16 @@
 //
 
 import Foundation
-
+import RealmSwift
 #if canImport(WidgetKit)
 import WidgetKit
 #endif
 
 final class WidgetHistorySnapshotStore {
     static let shared = WidgetHistorySnapshotStore()
 
+    private let accessQueue = DispatchQueue(label: "me.fin.bark.widget-history-snapshot", qos: .utility)
+
     private let encoder: JSONEncoder = {
         let encoder = JSONEncoder()
         encoder.dateEncodingStrategy = .iso8601
@@ -31,12 +33,28 @@ final class WidgetHistorySnapshotStore {
     }
     private init() {}
 
-    func syncFromMessages(_ messages: [WidgetHistoryMessage], limit: Int = WidgetHistoryConstants.snapshotRetentionLimit) {
+    func refreshFromRealmAsync(limit: Int = WidgetHistoryConstants.snapshotRetentionLimit) {
+        accessQueue.async {
+            guard let realm = try? Realm() else {
+                return
+            }
+            let messages = realm.widgetSnapshotItems(limit: limit)
+            self.syncFromMessagesLocked(messages, limit: limit)
+        }
+    }
+
+    func prependMessage(_ message: WidgetHistoryMessage, limit: Int = WidgetHistoryConstants.snapshotRetentionLimit) {
+        accessQueue.sync {
+            prependMessageLocked(message, limit: limit)
+        }
+    }
+
+    private func syncFromMessagesLocked(_ messages: [WidgetHistoryMessage], limit: Int) {
         let items = Array(messages.sorted { $0.createDate > $1.createDate }.prefix(limit))
         write(WidgetHistorySnapshot(messages: items))
     }
 
-    func prependMessage(_ message: WidgetHistoryMessage, limit: Int = WidgetHistoryConstants.snapshotRetentionLimit) {
+    private func prependMessageLocked(_ message: WidgetHistoryMessage, limit: Int) {
         var items = load()?.messages ?? []
         items.removeAll { $0.id == message.id }
         items.insert(message, at: 0)

Controller/MessageListViewModel.swift

@@ -323,7 +323,7 @@ class MessageListViewModel: ViewModel, ViewModelType {
                     try? realm.write {
                         realm.delete(message)
                     }
-                    WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+                    WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
                 }
                 // 删除 cell item
                 section.messages.removeAll { cellItem in
@@ -345,7 +345,7 @@ class MessageListViewModel: ViewModel, ViewModelType {
                         try? realm.write {
                             realm.delete(messageResult)
                         }
-                        WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+                        WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
                     }
                 }
                 // 删除 cell item
@@ -377,7 +377,7 @@ class MessageListViewModel: ViewModel, ViewModelType {
                 try? realm.write {
                     realm.delete(message)
                 }
-                WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+                WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
             }
 
             if let index = section.messages.firstIndex(where: { item in
@@ -416,7 +416,7 @@ class MessageListViewModel: ViewModel, ViewModelType {
                 try? realm.write {
                     realm.delete(messages)
                 }
-                WidgetHistorySnapshotStore.shared.syncFromMessages(realm.widgetSnapshotItems())
+                WidgetHistorySnapshotStore.shared.refreshFromRealmAsync()
             }
 
             self.page = 0