Polyfill to_id

src/danog/MadelineProto/API.php

@@ -192,6 +192,7 @@ class API extends InternalDoc
             $forceFull = $forceFull || $settings->getIpc()->getSlow();
         }
 
+        /** @psalm-trace $unserialized */
         [$unserialized, $this->unlock] = yield Tools::timeoutWithDefault(
             Serialization::unserialize($this->session, $forceFull),
             30000,

src/danog/MadelineProto/InternalDoc.php

@@ -6153,12 +6153,12 @@ class InternalDoc extends APIFactory
      * @template TReturn
      * @template TGenerator as \Generator<mixed, mixed, mixed, TReturn>
      *
-     * @param Promise<TReturn>|\Generator $promise Promise to which the timeout is applied.
+     * @param Promise|Generator $promise Promise to which the timeout is applied.
      * @param int               $timeout Timeout in milliseconds.
      * @param mixed             $default
      *
      * @psalm-param Promise<TReturn>|TGenerator $promise Promise to which the timeout is applied.
-     * @psalm-param TReturnAlt $timeout
+     * @psalm-param TReturnAlt $default
      *
      * @return Promise<TReturn|TReturnAlt>
      *

src/danog/MadelineProto/Loop/Update/FeedLoop.php

@@ -57,7 +57,7 @@ class FeedLoop extends ResumableSignalLoop
      */
     private ?UpdateLoop $updater = null;
     /**
-     * Update state
+     * Update state.
      */
     private ?UpdatesState $state = null;
     /**

src/danog/MadelineProto/Lua.php

@@ -31,7 +31,6 @@ class Lua
             throw new Exception(\danog\MadelineProto\Lang::$current_lang['script_not_exist']);
         }
         $this->MadelineProto = $MadelineProto;
-        $this->MadelineProto->API->datacenter->sockets[$this->MadelineProto->getSettings()->getConnection()->getDefaultDc()]->startUpdateLoop();
         $this->script = $script;
         $this->__wakeup();
     }
@@ -84,7 +83,7 @@ class Lua
         if ($params === 0) {
             return 0;
         }
-        $result = $this->MadelineProto->API->methodCall($params['_'], $params, ['datacenter' => $this->MadelineProto->API->datacenter->curdc]);
+        $result = $this->MadelineProto->API->methodCall($params['_'], $params);
         if (\is_callable($cb)) {
             $cb($this->MadelineProto->mtproto_to_td($result), $cb_extra);
         }
@@ -92,7 +91,7 @@ class Lua
     }
     public function madelineFunction($params, $cb = null, $cb_extra = null)
     {
-        $result = $this->MadelineProto->API->methodCall($params['_'], $params, ['datacenter' => $this->MadelineProto->API->datacenter->curdc]);
+        $result = $this->MadelineProto->API->methodCall($params['_'], $params);
         if (\is_callable($cb)) {
             $cb($result, $cb_extra);
         }

src/danog/MadelineProto/MTProtoSession/Session.php

@@ -19,12 +19,13 @@
 
 namespace danog\MadelineProto\MTProtoSession;
 
+use danog\MadelineProto\Connection;
 use danog\MadelineProto\MTProto;
 
 /**
  * Manages MTProto session-specific data.
  *
- * @property MTProto $API
+ * @extends Connection
  */
 abstract class Session
 {

src/danog/MadelineProto/MTProtoTools/UpdateHandler.php

@@ -415,6 +415,9 @@ trait UpdateHandler
         if (isset($update['message']['from_id']['user_id']) && $update['message']['from_id']['user_id'] === $this->authorization['user']['id']) {
             $update['message']['out'] = true;
         }
+        if (isset($update['message']['peer_id'])) {
+            $update['message']['to_id'] = $update['message']['peer_id'];
+        }
         // First save to array, then once the feed loop signals resumal of loop, resume and handle
         $this->updates[$this->updates_key++] = $update;
     }

src/danog/MadelineProto/Stream/Async/RawStream.php

@@ -42,10 +42,9 @@ trait RawStream
     {
         if (\method_exists($this, 'endGenerator')) {
             return \danog\MadelineProto\Tools::call($this->endGenerator($finalData));
-        } else {
+        }
         $promise = $this->write($finalData);
         $promise->onResolve(fn () => $this->disconnect());
         return $promise;
     }
-    }
 }

src/danog/MadelineProto/TL/Conversion/TD.php

@@ -200,7 +200,7 @@ trait TD
             if ($key === '_') {
                 $newparams['ID'] = \ucfirst($value);
             } else {
-                if (!\is_numeric($key) && !\preg_match('/_^/', $key)) {
+                if (!\is_numeric($key) && !str_ends_with($key, '_')) {
                     $key = $key.'_';
                 }
                 $newparams[$key] = $this->tdToTdcli($value);

src/danog/MadelineProto/TON/InternalDoc.php

@@ -1424,12 +1424,12 @@ class InternalDoc extends APIFactory
      * @template TReturn
      * @template TGenerator as \Generator<mixed, mixed, mixed, TReturn>
      *
-     * @param Promise<TReturn>|\Generator $promise Promise to which the timeout is applied.
+     * @param Promise|Generator $promise Promise to which the timeout is applied.
      * @param int               $timeout Timeout in milliseconds.
      * @param mixed             $default
      *
      * @psalm-param Promise<TReturn>|TGenerator $promise Promise to which the timeout is applied.
-     * @psalm-param TReturnAlt $timeout
+     * @psalm-param TReturnAlt $default
      *
      * @return Promise<TReturn|TReturnAlt>
      *

src/danog/MadelineProto/Tools.php

@@ -422,7 +422,7 @@ abstract class Tools extends StrTools
      * @template TReturn
      * @template TGenerator as \Generator<mixed, mixed, mixed, TReturn>
      *
-     * @param Promise<TReturn>|\Generator $promise Promise to which the timeout is applied.
+     * @param Promise|Generator $promise Promise to which the timeout is applied.
      * @param int               $timeout Timeout in milliseconds.
      * @param mixed             $default
      *