From 5acbd51bbe449d14c2806402c71d866000453824 Mon Sep 17 00:00:00 2001
From: Ali <>
Date: Wed, 22 Apr 2020 13:08:52 +0400
Subject: [PATCH] Add more logging [skip ci]

---
 .../TelegramCore/Sources/PendingMessageManager.swift  | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/submodules/TelegramCore/Sources/PendingMessageManager.swift b/submodules/TelegramCore/Sources/PendingMessageManager.swift
index 9cb6459e60..f1dfd809d3 100644
--- a/submodules/TelegramCore/Sources/PendingMessageManager.swift
+++ b/submodules/TelegramCore/Sources/PendingMessageManager.swift
@@ -180,6 +180,10 @@ public final class PendingMessageManager {
             let removedMessageIds = self.pendingMessageIds.subtracting(messageIds)
             let removedSecretMessageIds = Set(removedMessageIds.filter({ $0.peerId.namespace == Namespaces.Peer.SecretChat }))
             
+            if !removedMessageIds.isEmpty {
+                Logger.shared.log("PendingMessageManager", "removed messages: \(removedMessageIds)")
+            }
+            
             var updateUploadingPeerIds = Set<PeerId>()
             var updateUploadingGroupIds = Set<Int64>()
             for id in removedMessageIds {
@@ -207,6 +211,7 @@ public final class PendingMessageManager {
             }
             
             if !addedMessageIds.isEmpty {
+                Logger.shared.log("PendingMessageManager", "added messages: \(addedMessageIds)")
                 self.beginSendingMessages(Array(addedMessageIds).sorted())
             }
             
@@ -251,6 +256,8 @@ public final class PendingMessageManager {
                 peersWithPendingMessages.insert(id.peerId)
             }
             
+            Logger.shared.log("PendingMessageManager", "pengine messages: \(self.pendingMessageIds)")
+            
             self._hasPendingMessages.set(peersWithPendingMessages)
         }
     }
@@ -333,6 +340,8 @@ public final class PendingMessageManager {
             }
         }
         
+        Logger.shared.log("PendingMessageManager", "begin sending: \(ids)")
+        
         let disposable = MetaDisposable()
         let messages = self.postbox.messagesAtIds(ids)
         |> deliverOn(self.queue)
@@ -346,6 +355,8 @@ public final class PendingMessageManager {
             if let strongSelf = self {
                 assert(strongSelf.queue.isCurrent())
                 
+                Logger.shared.log("PendingMessageManager", "begin sending, continued: \(ids)")
+                
                 for message in messages.filter({ !$0.flags.contains(.Sending) }).sorted(by: { $0.id < $1.id }) {
                     guard let messageContext = strongSelf.messageContexts[message.id] else {
                         continue