ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-01 20:28:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add more logs [skip ci]

Browse Source
This commit is contained in:
Ali 2020-04-22 17:11:23 +04:00
parent 210e47df00
commit db989d534b
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
submodules/TelegramCore/Sources/Account.swift
View File

@ -1019,6 +1019,7 @@ public class Account {
self.managedServiceViewsDisposable.set(serviceTasksMaster.start())
let pendingMessageManager = self.pendingMessageManager
Logger.shared.log("Account", "Begin watching unsent message ids")
self.managedOperationsDisposable.add(postbox.unsentMessageIdsView().start(next: { [weak pendingMessageManager] view in
pendingMessageManager?.updatePendingMessageIds(view.ids)
}))

5
submodules/TelegramCore/Sources/PendingMessageManager.swift
View File

@ -160,6 +160,7 @@ public final class PendingMessageManager {
var transformOutgoingMessageMedia: TransformOutgoingMessageMedia?
init(network: Network, postbox: Postbox, accountPeerId: PeerId, auxiliaryMethods: AccountAuxiliaryMethods, stateManager: AccountStateManager, localInputActivityManager: PeerInputActivityManager, messageMediaPreuploadManager: MessageMediaPreuploadManager, revalidationContext: MediaReferenceRevalidationContext) {
Logger.shared.log("PendingMessageManager", "create instance")
self.network = network
self.postbox = postbox
self.accountPeerId = accountPeerId
@ -176,6 +177,8 @@ public final class PendingMessageManager {
func updatePendingMessageIds(_ messageIds: Set<MessageId>) {
self.queue.async {
Logger.shared.log("PendingMessageManager", "update: \(messageIds)")
let addedMessageIds = messageIds.subtracting(self.pendingMessageIds)
let removedMessageIds = self.pendingMessageIds.subtracting(messageIds)
let removedSecretMessageIds = Set(removedMessageIds.filter({ $0.peerId.namespace == Namespaces.Peer.SecretChat }))
@ -256,7 +259,7 @@ public final class PendingMessageManager {
peersWithPendingMessages.insert(id.peerId)
}
Logger.shared.log("PendingMessageManager", "pengine messages: \(self.pendingMessageIds)")
Logger.shared.log("PendingMessageManager", "pending messages: \(self.pendingMessageIds)")
self._hasPendingMessages.set(peersWithPendingMessages)
}