danog/MadelineProto
1
0
Fork 0
mirror of https://github.com/danog/MadelineProto.git synced 2024-11-27 07:14:39 +01:00
Code Issues Projects Releases Wiki Activity

Fix: async database upgrade

Browse Source
This commit is contained in:
Alexander Pankratov 2023-07-10 00:27:24 +02:00
parent c57a63b365
commit 7cbeb4c9cb
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/MTProto.php
View File

@ -957,12 +957,20 @@ final class MTProto implements TLCallback, LoggerGetter
}
}
foreach ($this->chats as $id => $chat) {
$id = (int) $id;
if (!($chat['min'] ?? false)) {
$this->minDatabase->clearPeer($id);
async(function() {
$counter = 0;
foreach ($this->chats as $id => $chat) {
$id = (int) $id;
$counter ++;
if ($counter % 1000 === 0) {
$this->logger->logger("Upgrading chats: $counter", Logger::WARNING);
}
if (!($chat['min'] ?? false)) {
$this->minDatabase->clearPeer($id);
}
}
}
});
}
/**
* Post-deserialization initialization function.