From 4134cdc8049daf99da2dca3615d726f8e6d3570e Mon Sep 17 00:00:00 2001
From: morethanwords <thanwords24@gmail.com>
Date: Tue, 20 Apr 2021 09:20:48 +0400
Subject: [PATCH] [WARN] Fix resending acked message w/o response

---
 src/lib/mtproto/networker.ts | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/lib/mtproto/networker.ts b/src/lib/mtproto/networker.ts
index 155303c9..8ccb4b28 100644
--- a/src/lib/mtproto/networker.ts
+++ b/src/lib/mtproto/networker.ts
@@ -840,7 +840,7 @@ export default class MTPNetworker {
 
       //if(!value || value <= currentTime) {
         const message = this.sentMessages[messageId];
-        if(message) {
+        if(message && message.body) {
           /* if(message.fileUpload) {
             this.log('performScheduledRequest message:', message, message.body.length, (message.body as Uint8Array).byteLength, (message.body as Uint8Array).buffer.byteLength);
           } */
@@ -851,7 +851,7 @@ export default class MTPNetworker {
             this.log.warn('lengthOverflow', message, messages);
             lengthOverflow = true;
 
-            if(outMessage) { // if it is a first message
+            if(outMessage) { // if it's not a first message
               break;
             }
           }
@@ -1363,7 +1363,7 @@ export default class MTPNetworker {
   public processMessageAck(messageId: string) {
     const sentMessage = this.sentMessages[messageId];
     if(sentMessage && !sentMessage.acked) {
-      delete sentMessage.body;
+      //delete sentMessage.body;
       sentMessage.acked = true;
     }
   }
@@ -1595,7 +1595,7 @@ export default class MTPNetworker {
                 this.log.debug('Rpc response', message.result, sentMessage);
               } */
 
-              sentMessage.deferred.resolve(message.result);
+              deferred.resolve(message.result);
             }
 
             if(sentMessage.isAPI && !this.connectionInited) {