diff --git a/SessionMessagingKit/Open Groups/OpenGroupManager.swift b/SessionMessagingKit/Open Groups/OpenGroupManager.swift index e315d36d4..7bebcd39b 100644 --- a/SessionMessagingKit/Open Groups/OpenGroupManager.swift +++ b/SessionMessagingKit/Open Groups/OpenGroupManager.swift @@ -380,31 +380,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(