Merge branch 'database-refactor' into emoji-reacts

Session/Meta/AppDelegate.swift

@@ -521,7 +521,7 @@ class AppDelegate: UIResponder, UIApplicationDelegate, UNUserNotificationCenterD
             poller.stop()
         }
         
-        ClosedGroupPoller.shared.stop()
+        ClosedGroupPoller.shared.stopAllPollers()
         OpenGroupManager.shared.stopPolling()
     }
     

SessionMessagingKit/Open Groups/OpenGroupManager.swift

@@ -501,7 +501,7 @@ public final class OpenGroupManager: NSObject {
         let sortedMessages: [OpenGroupAPI.Message] = messages
             .filter { $0.deleted != true }
             .sorted { lhs, rhs in lhs.id < rhs.id }
-        let messageServerIdsToRemove: [Int64] = messages
+        var messageServerIdsToRemove: [Int64] = messages
             .filter { $0.deleted == true }
             .map { $0.id }
         let seqNo: Int64? = sortedMessages.map { $0.seqNo }.max()

SessionMessagingKit/Sending & Receiving/Pollers/ClosedGroupPoller.swift

@@ -65,18 +65,12 @@ public final class ClosedGroupPoller {
         setUpPolling(for: groupPublicKey)
     }
 
-    @objc public func stop() {
+    public func stopAllPollers() {
-        Storage.shared
+        let pollers: [String] = Array(isPolling.wrappedValue.keys)
-            .read { db in
+        
-                try ClosedGroup
+        pollers.forEach { groupPublicKey in
-                    .select(.threadId)
+            self.stopPolling(for: groupPublicKey)
-                    .asRequest(of: String.self)
+        }
-                    .fetchAll(db)
-            }
-            .defaulting(to: [])
-            .forEach { [weak self] groupPublicKey in
-                self?.stopPolling(for: groupPublicKey)
-            }
     }
 
     public func stopPolling(for groupPublicKey: String) {