diff --git a/src/danog/MadelineProto/Loop/Update/FeedLoop.php b/src/danog/MadelineProto/Loop/Update/FeedLoop.php index 7688dc4d..9e8494b0 100644 --- a/src/danog/MadelineProto/Loop/Update/FeedLoop.php +++ b/src/danog/MadelineProto/Loop/Update/FeedLoop.php @@ -110,7 +110,7 @@ class FeedLoop extends ResumableSignalLoop unset($updates[$key]); if ($update['_'] === 'updateChannelTooLong') { $this->API->logger->logger('Got channel too long update, getting difference...', \danog\MadelineProto\Logger::VERBOSE); - $this->API->updaters[$this->channelId]->resume(); + yield $this->updater->resume(); continue; } diff --git a/src/danog/MadelineProto/MTProtoTools/UpdatesState.php b/src/danog/MadelineProto/MTProtoTools/UpdatesState.php index a4cd12e2..64304b91 100644 --- a/src/danog/MadelineProto/MTProtoTools/UpdatesState.php +++ b/src/danog/MadelineProto/MTProtoTools/UpdatesState.php @@ -138,7 +138,7 @@ class UpdatesState */ public function pts($set = 0) { - if ($set !== 0) { + if ($set !== 0 && $set > $this->pts) { $this->pts = $set; } return $this->pts; @@ -151,7 +151,7 @@ class UpdatesState */ public function qts($set = 0) { - if ($set !== 0) { + if ($set !== 0 && $set > $this->qts) { $this->qts = $set; } return $this->qts; @@ -164,7 +164,7 @@ class UpdatesState */ public function seq($set = 0) { - if ($set !== 0) { + if ($set !== 0 && $set > $this->seq) { $this->seq = $set; } return $this->seq;