chore: Manually unsnooze message in DB

Author: valentinperignon

MailCore/Cache/MailboxManager/MailboxManager+Thread.swift

@@ -529,20 +529,18 @@ public extension MailboxManager {
 
                 return isInFolder && isSnoozed && isLastMessageFromThreadNotSnoozed
             }
-        }.freeze()
+        }.freezeIfNeeded()
 
         guard !threadsToUnsnooze.isEmpty else { return }
 
         let unsnoozedMessages: [String] = await Array(threadsToUnsnooze).concurrentCompactMap(customConcurrency: 4) { thread in
-            guard let lastMessageSnoozed = thread.messages.last(where: { $0.isSnoozed }) else {
-                return nil
-            }
+            guard let lastMessageSnoozed = thread.messages.last(where: { $0.isSnoozed }) else { return nil }
 
             do {
                 try await self.apiFetcher.deleteSnooze(message: lastMessageSnoozed, mailbox: self.mailbox)
                 return lastMessageSnoozed.uid
             } catch let error as MailApiError where error == .apiMessageNotSnoozed {
-                self.unsnoozeThreadInRealm()
+                self.manuallyUnsnoozeThreadInRealm(thread: thread)
                 return nil
             } catch {
                 SentrySDK.capture(message: "Impossible to automatically unsnooze thread") { scope in
@@ -571,8 +569,24 @@ public extension MailboxManager {
         }
     }
 
-    private func unsnoozeThreadInRealm() {
+    private func manuallyUnsnoozeThreadInRealm(thread: Thread) {
+        try? writeTransaction { writableRealm in
+            guard let freshThread = thread.fresh(using: writableRealm) else { return }
+
+            let snoozedMessages = freshThread.messages.where { $0.snoozeState == .snoozed }
 
+            for snoozedMessage in snoozedMessages {
+                snoozedMessage.snoozeState = nil
+                snoozedMessage.snoozeUuid = nil
+                snoozedMessage.snoozeEndDate = nil
+            }
+
+            try? freshThread.recomputeOrFail()
+            let duplicatesThreads = Set(freshThread.duplicates.flatMap { $0.threads })
+            for duplicateThread in duplicatesThreads {
+                try? duplicateThread.recomputeOrFail()
+            }
+        }
     }
 
     // MARK: - Utils