Swiftgram/submodules/Postbox/Postbox/MessagesView.swift
Peter 4459dc5b47 Add 'submodules/Postbox/' from commit '534443c710e63ff4ea595b5dc7be94550c467734'
git-subtree-dir: submodules/Postbox
git-subtree-mainline: 373769682ef152a8d5ef41ccb064a8387b2ca6f0
git-subtree-split: 534443c710e63ff4ea595b5dc7be94550c467734
2019-06-11 18:56:39 +01:00

67 lines
2.1 KiB
Swift

import Foundation
final class MutableMessagesView: MutablePostboxView {
fileprivate let ids: Set<MessageId>
private let peerIds: Set<PeerId>
fileprivate var messages: [MessageId: Message] = [:]
init(postbox: Postbox, ids: Set<MessageId>) {
self.ids = ids
self.peerIds = Set(ids.map { $0.peerId })
for id in ids {
if let message = postbox.getMessage(id) {
self.messages[message.id] = message
}
}
}
func replay(postbox: Postbox, transaction: PostboxTransaction) -> Bool {
var updatedIds = Set<MessageId>()
for peerId in self.peerIds {
if let operations = transaction.currentOperationsByPeerId[peerId] {
for operation in operations {
switch operation {
case let .InsertMessage(message):
if self.ids.contains(message.id) {
updatedIds.insert(message.id)
}
case let .Remove(indices):
for index in indices {
if self.ids.contains(index.0.id) {
updatedIds.insert(index.0.id)
}
}
default:
break
}
}
}
}
if !updatedIds.isEmpty {
for id in updatedIds {
if let message = postbox.getMessage(id) {
self.messages[message.id] = message
} else {
self.messages.removeValue(forKey: id)
}
}
return true
} else {
return false
}
}
func immutableView() -> PostboxView {
return MessagesView(self)
}
}
public final class MessagesView: PostboxView {
public var messages: [MessageId: Message] = [:]
init(_ view: MutableMessagesView) {
self.messages = view.messages
}
}