From f08d0470e570d7781c63fdefb7432d4c4271850d Mon Sep 17 00:00:00 2001
From: ryanzhao <ryanzhaors@qq.com>
Date: Fri, 10 Sep 2021 13:48:07 +1000
Subject: [PATCH] expire sync messages if needed

---
 .../Sending & Receiving/MessageReceiver+Handling.swift        | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/SessionMessagingKit/Sending & Receiving/MessageReceiver+Handling.swift b/SessionMessagingKit/Sending & Receiving/MessageReceiver+Handling.swift
index e06c502b9..72e7a94a8 100644
--- a/SessionMessagingKit/Sending & Receiving/MessageReceiver+Handling.swift	
+++ b/SessionMessagingKit/Sending & Receiving/MessageReceiver+Handling.swift	
@@ -318,6 +318,10 @@ extension MessageReceiver {
             tsMessage.openGroupServerMessageID = serverID
             tsMessage.save(with: transaction)
         }
+        // Start expiration for sync messages
+        if let tsOutgoingMessage = TSMessage.fetch(uniqueId: tsMessageID, transaction: transaction) as? TSOutgoingMessage {
+            OWSDisappearingMessagesJob.shared().startAnyExpiration(for: tsOutgoingMessage, expirationStartedAt: NSDate.millisecondTimestamp(), transaction: transaction)
+        }
         // Notify the user if needed
         guard (isMainAppAndActive || isBackgroundPoll), let tsIncomingMessage = TSMessage.fetch(uniqueId: tsMessageID, transaction: transaction) as? TSIncomingMessage,
             let thread = TSThread.fetch(uniqueId: threadID, transaction: transaction) else { return tsMessageID }