From 0150816aaa655d9ed9d1ac8d0350267c2377c8e2 Mon Sep 17 00:00:00 2001
From: Ryan Zhao <ryanzhaors@qq.com>
Date: Thu, 6 Jul 2023 15:38:33 +1000
Subject: [PATCH] clean

---
 .../MessageReceiver+VisibleMessages.swift     | 32 -------------------
 1 file changed, 32 deletions(-)

diff --git a/SessionMessagingKit/Sending & Receiving/Message Handling/MessageReceiver+VisibleMessages.swift b/SessionMessagingKit/Sending & Receiving/Message Handling/MessageReceiver+VisibleMessages.swift
index 46ef8d7c5..2e06419a1 100644
--- a/SessionMessagingKit/Sending & Receiving/Message Handling/MessageReceiver+VisibleMessages.swift	
+++ b/SessionMessagingKit/Sending & Receiving/Message Handling/MessageReceiver+VisibleMessages.swift	
@@ -215,15 +215,6 @@ extension MessageReceiver {
             syncTarget: message.syncTarget
         )
         
-        startDisappearingMessagesIfNeed(
-            db,
-            threadId: threadId,
-            interactionId: interactionId,
-            variant: interaction.variant,
-            wasRead: interaction.wasRead,
-            shouldExpire: (interaction.isExpiringMessage && interaction.expiresStartedAtMs == nil)
-        )
-        
         // Parse & persist attachments
         let attachments: [Attachment] = try dataMessage.attachments
             .compactMap { proto -> Attachment? in
@@ -416,29 +407,6 @@ extension MessageReceiver {
         return interactionId
     }
     
-    private static func startDisappearingMessagesIfNeed(
-        _ db: Database,
-        threadId: String,
-        interactionId: Int64,
-        variant: Interaction.Variant,
-        wasRead: Bool,
-        shouldExpire: Bool
-    ) {
-        // Only start a disappearing message job when the incoming message is already read
-        // according to user config
-        guard variant == .standardIncoming && wasRead && shouldExpire else { return }
-        
-        JobRunner.upsert(
-            db,
-            job: DisappearingMessagesJob.updateNextRunIfNeeded(
-                db,
-                interactionIds: [interactionId],
-                startedAtMs: TimeInterval(SnodeAPI.currentOffsetTimestampMs()),
-                threadId: threadId
-            )
-        )
-    }
-    
     private static func updateRecipientAndReadStatesForOutgoingInteraction(
         _ db: Database,
         thread: SessionThread,