Final fix

Author: danog

src/DataCenterConnection.php

@@ -422,7 +422,7 @@ private function restoreBackup(): void
                 $message->setMsgId(null);
             }
             $message->connection = $connection = $this->getConnection();
-            $this->API->logger("Resending $message to DC {$this->datacenter}");
+            $this->API->logger("Restoring $message to DC {$this->datacenter}");
             EventLoop::queue($connection->sendMessage(...), $message);
         }
     }

src/Loop/Connection/WriteLoop.php

@@ -22,7 +22,6 @@
 
 use Amp\ByteStream\StreamException;
 use Amp\DeferredFuture;
-use AssertionError;
 use danog\Loop\Loop;
 use danog\MadelineProto\Connection;
 use danog\MadelineProto\Logger;

src/MTProto/MTProtoOutgoingMessage.php

@@ -220,9 +220,22 @@ public function sent(): void
     }
     public function unlink(): void
     {
-        $this->next->prev = $this->prev;
-        $this->prev->next = $this->next;
+        if (isset($this->next)) {
+            $this->next->prev = $this->prev;
+            $this->prev->next = $this->next;
+            unset($this->next, $this->prev);
+
+        }
+
         $this->connection->pendingOutgoingGauge?->dec();
+
+        if ($this->unencrypted) {
+            unset($this->connection->unencryptedPendingOutgoing->check_queue[$this]);
+        } elseif ($this->specialMethodType === SpecialMethodType::UNAUTHED_METHOD) {
+            unset($this->connection->uninitedPendingOutgoing->check_queue[$this]);
+        } else {
+            unset($this->connection->mainPendingOutgoing->check_queue[$this]);
+        }
     }
     private function check(): void
     {

src/MTProtoSession/ResponseHandler.php

@@ -341,7 +341,7 @@ private function handleRpcError(MTProtoOutgoingMessage $request, array $response
             case 400:
                 if ($response['error_message'] === 'CONNECTION_NOT_INITED') {
                     $this->shared->auth->connectionState->publish(ConnectionState::ENCRYPTED_NOT_INITED);
-                    $this->API->logger("Resending $request...");
+                    $this->API->logger("Resending $request due to CONNECTION_NOT_INITED...");
                     $this->methodRecall($request, $this->datacenter);
                     return null;
                 }

src/MTProtoSession/Session.php

@@ -189,9 +189,9 @@ public function createSession(): void
                 10000_000_000,
             ]
         );
-        $this->mainPendingOutgoing ??= new LinkedList;
-        $this->unencryptedPendingOutgoing ??= new LinkedList;
-        $this->uninitedPendingOutgoing ??= new LinkedList;
+        $this->mainPendingOutgoing ??= new LinkedList($this->datacenter, $this->API);
+        $this->unencryptedPendingOutgoing ??= new LinkedList($this->datacenter, $this->API);
+        $this->uninitedPendingOutgoing ??= new LinkedList($this->datacenter, $this->API);
         if ($this->session_id === null) {
             $this->resetSession("creating initial session");
         }
@@ -209,10 +209,9 @@ public function backupSession(): array
             $message = $list;
             while ($message !== null) {
                 $message = $message->prev;
-                if ($message === $list) {
+                if (!$message instanceof MTProtoOutgoingMessage) {
                     break;
                 }
-                \assert($message instanceof MTProtoOutgoingMessage);
                 $message->unlink();
                 $pending []= $message;
             }