From db989d534bd622e7293287dcf35d39cc208aed7d Mon Sep 17 00:00:00 2001 From: Ali <> Date: Wed, 22 Apr 2020 17:11:23 +0400 Subject: [PATCH] Add more logs [skip ci] --- submodules/TelegramCore/Sources/Account.swift | 1 + submodules/TelegramCore/Sources/PendingMessageManager.swift | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/submodules/TelegramCore/Sources/Account.swift b/submodules/TelegramCore/Sources/Account.swift index a209643aca..96c0cfd61a 100644 --- a/submodules/TelegramCore/Sources/Account.swift +++ b/submodules/TelegramCore/Sources/Account.swift @@ -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) })) diff --git a/submodules/TelegramCore/Sources/PendingMessageManager.swift b/submodules/TelegramCore/Sources/PendingMessageManager.swift index f1dfd809d3..eebe604e11 100644 --- a/submodules/TelegramCore/Sources/PendingMessageManager.swift +++ b/submodules/TelegramCore/Sources/PendingMessageManager.swift @@ -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) { 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) }