Better logging

src/danog/MadelineProto/DataCenterConnection.php

@@ -108,7 +108,7 @@ class DataCenterConnection implements JsonSerializable
     private $decWrite = 10;
 
     /**
-     * Backed up messages
+     * Backed up messages.
      *
      * @var array
      */
@@ -389,13 +389,19 @@ class DataCenterConnection implements JsonSerializable
             $this->robinLoop->signal(true);
             $this->robinLoop = null;
         }
-        $before = count($this->backup);
+        $before = \count($this->backup);
+        $list = '';
         foreach ($this->connections as $connection) {
-            $this->backup = \array_merge($this->backup, $connection->backupSession());
+            $backup = $connection->backupSession();
+            foreach ($backup as $message) {
+                $list .= $message['_'] ?? '-';
+                $list .= ', ';
+            }
+            $this->backup = \array_merge($this->backup, $backup);
             $connection->disconnect();
         }
-        $count = count($this->backup) - $before;
-        $this->API->logger->logger("Backed up $count messages from DC {$this->datacenter}");
+        $count = \count($this->backup) - $before;
+        $this->API->logger->logger("Backed up $count (added {$list}to $before existing messages) from DC {$this->datacenter}");
 
         $this->connections = [];
         $this->availableConnections = [];
@@ -414,7 +420,7 @@ class DataCenterConnection implements JsonSerializable
     }
 
     /**
-     * Restore backed up messages
+     * Restore backed up messages.
      *
      * @return void
      */
@@ -422,7 +428,7 @@ class DataCenterConnection implements JsonSerializable
     {
         $backup = $this->backup;
         $this->backup = [];
-        $count = count($backup);
+        $count = \count($backup);
         $this->API->logger->logger("Restoring $count messages to DC {$this->datacenter}");
         foreach ($backup as $message) {
             Tools::callFork($this->getConnection()->sendMessage($message, false));

src/danog/MadelineProto/Loop/Connection/ReadLoop.php

@@ -153,7 +153,7 @@ class ReadLoop extends SignalLoop
             $API->logger->logger($e->getReason());
             if (\strpos($e->getReason(), '       ') === 0) {
                 $payload = -\substr($e->getReason(), 7);
-                $API->logger->logger("Received $payload from DC ".$datacenter, \danog\MadelineProto\Logger::ULTRA_VERBOSE);
+                $API->logger->logger("Received $payload from DC ".$datacenter, \danog\MadelineProto\Logger::ERROR);
 
                 return $payload;
             }

src/danog/MadelineProto/MTProto/PermAuthKey.php

@@ -78,4 +78,18 @@ class PermAuthKey extends AuthKey
             'authorized' => $this->authorized
         ];
     }
+    /**
+     * Sleep function.
+     *
+     * @return array
+     */
+    public function __sleep()
+    {
+        return [
+            'authKey',
+            'id',
+            'serverSalt',
+            'authorized'
+        ];
+    }
 }

src/danog/MadelineProto/MTProto/TempAuthKey.php

@@ -170,4 +170,21 @@ class TempAuthKey extends AuthKey implements JsonSerializable
             'connection_inited' => $this->inited
         ];
     }
+
+    /**
+     * Sleep function
+     *
+     * @return array
+     */
+    public function __sleep()
+    {
+        return [
+            'authKey',
+            'id',
+            'serverSalt',
+            'bound',
+            'expires',
+            'inited'
+        ];
+    }
 }

src/danog/MadelineProto/MTProtoSession/CallHandler.php

@@ -62,7 +62,7 @@ trait CallHandler
                 $this->ack_outgoing_message_id($message_id);
                 $this->got_response_for_outgoing_message_id($message_id);
             } else {
-                $this->logger->logger('Could not resend '.isset($this->outgoing_messages[$message_id]['_']) ? $this->outgoing_messages[$message_id]['_'] : $message_id);
+                $this->logger->logger('Could not resend '.(isset($this->outgoing_messages[$message_id]['_']) ? $this->outgoing_messages[$message_id]['_'] : $message_id));
             }
         }
         if (!$postpone) {

src/danog/MadelineProto/MTProtoSession/Session.php

@@ -70,13 +70,13 @@ abstract class Session
     }
 
     /**
-     * Backup eventual unsent messages before session deletion
+     * Backup eventual unsent messages before session deletion.
      *
      * @return array
      */
     public function backupSession(): array
     {
-        $pending = array_values($this->pending_outgoing);
+        $pending = \array_values($this->pending_outgoing);
         foreach ($this->new_outgoing as $id) {
             $pending[] = $this->outgoing_messages[$id];
         }

src/danog/MadelineProto/MTProtoTools/AuthKeyHandler.php

@@ -636,6 +636,7 @@ trait AuthKeyHandler
     public function init_authorization_async(): \Generator
     {
         if ($this->pending_auth) {
+            $this->logger("Pending auth, not initing auth");
             return;
         }
         $initing = $this->initing_authorization;

src/danog/MadelineProto/Magic.php

@@ -25,7 +25,6 @@ use Amp\DoH\Rfc8484StubResolver;
 use Amp\Loop;
 use Amp\Loop\Driver;
 use ReflectionClass;
-use ReflectionObject;
 
 use function Amp\ByteStream\getInputBufferStream;
 use function Amp\ByteStream\getStdin;
@@ -244,7 +243,7 @@ class Magic
             $reflectionClass = new ReflectionClass(Driver::class);
             $reflectionProperty = $reflectionClass->getProperty('watchers');
             $reflectionProperty->setAccessible(true);
-            foreach (array_keys($reflectionProperty->getValue($driver)) as $key) {
+            foreach (\array_keys($reflectionProperty->getValue($driver)) as $key) {
                 $driver->unreference($key);
             }
         }

src/danog/MadelineProto/TL/PrettyException.php

@@ -19,6 +19,8 @@
 
 namespace danog\MadelineProto\TL;
 
+use danog\MadelineProto\Tools;
+
 trait PrettyException
 {
     public $tl_trace;

src/danog/MadelineProto/Tools.php

@@ -25,6 +25,8 @@ use Amp\Loop;
 use Amp\Promise;
 use Amp\Success;
 use phpseclib\Math\BigInteger;
+use ReflectionGenerator;
+
 use function Amp\ByteStream\getOutputBufferStream;
 use function Amp\ByteStream\getStdin;
 use function Amp\ByteStream\getStdout;
@@ -447,4 +449,47 @@ trait Tools
             $var instanceof Traversable &&
             $var instanceof Countable);
     }
+
+    /**
+     * Custom backtrace for working with generators
+     *
+     * @param boolean $ignoreArgs Whether to ignore method arguments
+     * @param array   $trace      Trace to work with
+     * 
+     * @return array
+     */
+    public static function backtrace(bool $ignoreArgs = false, array $trace = []): array
+    {
+        return iterator_to_array(self::backtraceGenerator($ignoreArgs, $trace));
+    }
+    /**
+     * Custom backtrace for working with generators
+     *
+     * @param boolean $ignoreArgs Whether to ignore method arguments
+     * @param array   $trace      Trace to work with
+     * 
+     * @return \Generator
+     */
+    public static function backtraceGenerator(bool $ignoreArgs = false, array $trace = []): \Generator
+    {
+        $flags = DEBUG_BACKTRACE_PROVIDE_OBJECT;
+        if ($ignoreArgs) {
+            $flags |= DEBUG_BACKTRACE_IGNORE_ARGS;
+        }
+        if (!$trace) {
+            $trace = debug_backtrace($flags);
+            array_shift($trace);
+        }
+
+        foreach ($trace as $frame) {
+            if (isset($frame['object']) && $frame['object'] instanceof \Generator) {
+                $reflection = new ReflectionGenerator($frame['object']);
+                yield from self::backtrace($ignoreArgs, $reflection->getTrace($flags));
+                return;
+            }
+            //var_dump(get_class($frame['object'] ?? new class {}));
+            unset($frame['object']);
+            yield $frame;
+        }
+    }
 }