fix opening transactions in filter.

pull/376/head
Ryan ZHAO 3 years ago
parent b334ad3446
commit 4fd34005dc

@ -376,18 +376,19 @@ public final class SnodeAPI : NSObject {
private static func removeDuplicates(from rawMessages: [JSON], associatedWith publicKey: String) -> [JSON] { private static func removeDuplicates(from rawMessages: [JSON], associatedWith publicKey: String) -> [JSON] {
var receivedMessages = SNSnodeKitConfiguration.shared.storage.getReceivedMessages(for: publicKey) var receivedMessages = SNSnodeKitConfiguration.shared.storage.getReceivedMessages(for: publicKey)
return rawMessages.filter { rawMessage in let result = rawMessages.filter { rawMessage in
guard let hash = rawMessage["hash"] as? String else { guard let hash = rawMessage["hash"] as? String else {
SNLog("Missing hash value for message: \(rawMessage).") SNLog("Missing hash value for message: \(rawMessage).")
return false return false
} }
let isDuplicate = receivedMessages.contains(hash) let isDuplicate = receivedMessages.contains(hash)
receivedMessages.insert(hash) receivedMessages.insert(hash)
return !isDuplicate
}
SNSnodeKitConfiguration.shared.storage.writeSync { transaction in SNSnodeKitConfiguration.shared.storage.writeSync { transaction in
SNSnodeKitConfiguration.shared.storage.setReceivedMessages(to: receivedMessages, for: publicKey, using: transaction) SNSnodeKitConfiguration.shared.storage.setReceivedMessages(to: receivedMessages, for: publicKey, using: transaction)
} }
return !isDuplicate return result
}
} }
// MARK: Error Handling // MARK: Error Handling

Loading…
Cancel
Save