From 39c9ec735741122bb48a4a06b7199b92a3577b92 Mon Sep 17 00:00:00 2001 From: Ryan ZHAO <> Date: Tue, 14 Nov 2023 09:56:34 +1100 Subject: [PATCH] clean --- .../Database/Models/SessionThread.swift | 28 ------------------- .../Open Groups/OpenGroupManager.swift | 25 ----------------- 2 files changed, 53 deletions(-) diff --git a/SessionMessagingKit/Database/Models/SessionThread.swift b/SessionMessagingKit/Database/Models/SessionThread.swift index 59abf77aa..699eb0786 100644 --- a/SessionMessagingKit/Database/Models/SessionThread.swift +++ b/SessionMessagingKit/Database/Models/SessionThread.swift @@ -462,34 +462,6 @@ public extension SessionThread { ) } - func isMessageRequestFromCommunity(_ db: Database, openGroupId: String) -> Bool { - var isMessageRequestFromCommunity: Bool = false - if let currentUserBlinded15PublicKey: String = Self.getUserHexEncodedBlindedKey( - db, - threadId: openGroupId, - threadVariant: .community, - blindingPrefix: .blinded15 - ) { - isMessageRequestFromCommunity = isMessageRequestFromCommunity || ((try? Interaction - .filter(Interaction.Columns.threadId == self.id) - .filter(Interaction.Columns.openGroupWhisperTo == currentUserBlinded15PublicKey) - .isNotEmpty(db)) ?? false) - } - if let currentUserBlinded25PublicKey: String = Self.getUserHexEncodedBlindedKey( - db, - threadId: openGroupId, - threadVariant: .community, - blindingPrefix: .blinded25 - ) { - isMessageRequestFromCommunity = isMessageRequestFromCommunity || ((try? Interaction - .filter(Interaction.Columns.threadId == self.id) - .filter(Interaction.Columns.openGroupWhisperTo == currentUserBlinded25PublicKey) - .isNotEmpty(db)) ?? false) - } - - return isMessageRequestFromCommunity - } - func isNoteToSelf(_ db: Database? = nil) -> Bool { return ( variant == .contact && diff --git a/SessionMessagingKit/Open Groups/OpenGroupManager.swift b/SessionMessagingKit/Open Groups/OpenGroupManager.swift index 2ab473109..a023ab5f7 100644 --- a/SessionMessagingKit/Open Groups/OpenGroupManager.swift +++ b/SessionMessagingKit/Open Groups/OpenGroupManager.swift @@ -370,31 +370,6 @@ public final class OpenGroupManager { } } - private func cleanMessageRequests( - _ db: Database, - openGroupId: String, - openGroupServer: String?, - calledFromConfigHandling: Bool, - using dependencies: Dependencies = Dependencies() - ) { - // Remove threads with only message requests from open group - _ = try? SessionThread - .filter(SessionThread.isMessageRequest(userPublicKey: getUserHexEncodedPublicKey(db, using: dependencies))) - .fetchAll(db) - .filter { $0.isMessageRequestFromCommunity(db, openGroupId: openGroupId)} - .map { try $0.delete(db)} - - if !calledFromConfigHandling, let server: String = openGroupServer { - //Remove inbox messages - if let data = try? OpenGroupAPI.preparedClearInbox(db, on: server) { - OpenGroupAPI - .send(data: data) - .map { _ in [server: true] } - .sinkUntilComplete() - } - } - } - // MARK: - Response Processing internal static func handleCapabilities(