Pyrofork: Clean usernames database before updating usernames database

Signed-off-by: wulan17 <wulan17@nusantararom.org>

pyrogram/storage/mongo_storage.py

@@ -4,7 +4,7 @@
 from typing import List, Tuple, Any
 
 from .dummy_client import DummyMongoClient
-from pymongo import MongoClient, UpdateOne
+from pymongo import MongoClient, UpdateOne, DeleteMany
 from pyrogram.storage.storage import Storage
 from pyrogram.storage.sqlite_storage import get_input_peer
 
@@ -124,6 +124,11 @@ async def update_peers(self, peers: List[Tuple[int, int, str, str, str]]):
 
     async def update_usernames(self, usernames: List[Tuple[int, str]]):
         s = int(time.time())
+        bulk_delete = [
+            DeleteMany(
+                {'peer_id': i[0]}
+            ) for i in usernames
+        ]
         bulk = [
             UpdateOne(
                 {'_id': i[1]},
@@ -136,6 +141,9 @@ async def update_usernames(self, usernames: List[Tuple[int, str]]):
         ]
         if not bulk:
             return
+        await self._usernames.bulk_write(
+            bulk_delete
+        )
         await self._usernames.bulk_write(
             bulk
         )