danog/MadelineProto
1
0
Fork 0
mirror of https://github.com/danog/MadelineProto.git synced 2024-11-30 06:59:01 +01:00
Code Issues Projects Releases Wiki Activity

Migrate usernames

Browse Source
This commit is contained in:
Daniil Gentili 2024-04-06 22:25:31 +02:00
parent f49717bf1d
commit a3eedc9504
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/MTProtoTools/PeerDatabase.php
View File

@ -25,6 +25,7 @@ use Amp\Sync\LocalMutex;
use AssertionError;
use danog\AsyncOrm\Annotations\OrmMappedArray;
use danog\AsyncOrm\DbArray;
use danog\AsyncOrm\DbArrayBuilder;
use danog\AsyncOrm\KeyType;
use danog\AsyncOrm\ValueType;
use danog\MadelineProto\Exception;
@ -49,7 +50,7 @@ final class PeerDatabase implements TLCallback
{
use LegacyMigrator;
private const V = 0;
private const V = 1;
/**
* Chats.
@ -66,7 +67,7 @@ final class PeerDatabase implements TLCallback
/**
* @var DbArray<string, int>
*/
#[OrmMappedArray(KeyType::STRING, ValueType::INT, tablePostfix: 'MTProto_usernames')]
#[OrmMappedArray(KeyType::STRING, ValueType::INT)]
private DbArray $usernames;
private bool $hasInfo = true;
private bool $hasUsernames = true;
@ -121,6 +122,19 @@ final class PeerDatabase implements TLCallback
if (!$this->API->settings->getDb()->getEnableUsernameDb()) {
$this->usernames->clear();
} elseif ($this->v === 0) {
$old = new DbArrayBuilder(
$this->API->getDbPrefix().'_MTProto_usernames',
$this->API->getDbSettings(),
KeyType::STRING,
ValueType::SCALAR
);
$old = $old->build();
foreach ($old as $k => $v) {
$this->usernames[$k] = $v;
}
$old->clear();
$this->v = self::V;
}
EventLoop::queue(function (): void {