Mongo storage cleanup (#609)

* Update message.py

Fixed syntax bug, added comma

* Cleanup mongodb storage

Cleaning up blank documents in DATA collection
This commit is contained in:
Biorobot1337 2021-06-22 01:15:01 +05:00 committed by GitHub
parent c42b7e4b0d
commit e70a76ff63
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -142,9 +142,11 @@ class MongoStorage(BaseStorage):
data: Dict = None):
chat, user = self.check_address(chat=chat, user=user)
db = await self.get_db()
await db[DATA].update_one(filter={'chat': chat, 'user': user},
update={'$set': {'data': data}}, upsert=True)
if not data:
await db[DATA].delete_one(filter={'chat': chat, 'user': user})
else:
await db[DATA].update_one(filter={'chat': chat, 'user': user},
update={'$set': {'data': data}}, upsert=True)
async def get_data(self, *, chat: Union[str, int, None] = None, user: Union[str, int, None] = None,
default: Optional[dict] = None) -> Dict: