From fca4904d0f7fbad067ca40a3f64e78fe98947e35 Mon Sep 17 00:00:00 2001
From: Lonami Exo <totufals@hotmail.com>
Date: Wed, 7 Mar 2018 11:30:03 +0100
Subject: [PATCH] Add more logging calls when confirming a request

---
 telethon/network/mtproto_sender.py | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/telethon/network/mtproto_sender.py b/telethon/network/mtproto_sender.py
index cbcdc76d..532a8da7 100644
--- a/telethon/network/mtproto_sender.py
+++ b/telethon/network/mtproto_sender.py
@@ -69,6 +69,7 @@ class MtProtoSender:
 
     def disconnect(self):
         """Disconnects from the server."""
+        __log__.info('Disconnecting MtProtoSender...')
         self.connection.close()
         self._need_confirmation.clear()
         self._clear_all_pending()
@@ -244,6 +245,7 @@ class MtProtoSender:
                 if r:
                     r.result = True  # Telegram won't send this value
                     r.confirm_received.set()
+                    __log__.debug('Confirmed %s through ack', type(r).__name__)
 
             return True
 
@@ -252,6 +254,7 @@ class MtProtoSender:
             if r:
                 r.result = obj
                 r.confirm_received.set()
+                __log__.debug('Confirmed %s through salt', type(r).__name__)
 
         # If the object isn't any of the above, then it should be an Update.
         self.session.process_entities(obj)
@@ -308,6 +311,7 @@ class MtProtoSender:
         """
         for r in self._pending_receive.values():
             r.request.confirm_received.set()
+            __log__.info('Abruptly confirming %s', type(r).__name__)
         self._pending_receive.clear()
 
     def _resend_request(self, msg_id):
@@ -337,6 +341,7 @@ class MtProtoSender:
         if request:
             request.result = pong
             request.confirm_received.set()
+            __log__.debug('Confirmed %s through pong', type(request).__name__)
 
         return True
 
@@ -490,6 +495,9 @@ class MtProtoSender:
             if request:
                 request.rpc_error = error
                 request.confirm_received.set()
+
+            __log__.debug('Confirmed %s through error %s',
+                          type(request).__name__, error)
             # else TODO Where should this error be reported?
             # Read may be async. Can an error not-belong to a request?
             return True  # All contents were read okay
@@ -505,6 +513,10 @@ class MtProtoSender:
 
             self.session.process_entities(request.result)
             request.confirm_received.set()
+            __log__.debug(
+                'Confirmed %s through normal result %s',
+                type(request).__name__, type(request.result).__name__
+            )
             return True
 
         # If it's really a result for RPC from previous connection