From 284bdab9f84a64b29fd587a504e61a0007d44261 Mon Sep 17 00:00:00 2001 From: ryanzhao Date: Tue, 30 May 2023 17:17:08 +1000 Subject: [PATCH] WIP: refactor on fixing disappear after read --- .../ConversationVC+Interaction.swift | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/Session/Conversations/ConversationVC+Interaction.swift b/Session/Conversations/ConversationVC+Interaction.swift index 1f5f8dbb1..14ccf7c5a 100644 --- a/Session/Conversations/ConversationVC+Interaction.swift +++ b/Session/Conversations/ConversationVC+Interaction.swift @@ -536,13 +536,13 @@ extension ConversationVC: ) // Trigger disappear after read - try Interaction.markAsRead( + JobRunner.upsert( db, - interactionId: interactionId, - threadId: threadId, - threadVariant: threadVariant, - includingOlder: false, - trySendReadReceipt: false + job: DisappearingMessagesJob.updateNextRunIfNeeded( + db, + interaction: interaction, + startedAtMs: TimeInterval(SnodeAPI.currentOffsetTimestampMs()) + ) ) } .subscribe(on: DispatchQueue.global(qos: .userInitiated)) @@ -647,13 +647,13 @@ extension ConversationVC: ) // Trigger disappear after read - try Interaction.markAsRead( + JobRunner.upsert( db, - interactionId: interactionId, - threadId: threadId, - threadVariant: threadVariant, - includingOlder: false, - trySendReadReceipt: false + job: DisappearingMessagesJob.updateNextRunIfNeeded( + db, + interaction: interaction, + startedAtMs: TimeInterval(SnodeAPI.currentOffsetTimestampMs()) + ) ) } .subscribe(on: DispatchQueue.global(qos: .userInitiated))