python/aiogram
1
0
Fork 0
mirror of https://github.com/aiogram/aiogram.git synced 2026-04-08 16:37:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

replacement by motor

Browse source
This commit is contained in:
morz 2019-10-09 23:51:01 +05:00
parent bb16a9b1a7
commit 886f34d397
1 changed files with 16 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

27
aiogram/contrib/fsm_storage/mongo.py
View file

@ -1,12 +1,12 @@
"""
This module has mongo storage for finite-state machine
based on `aiomongo <https://github.com/ZeoAlliance/aiomongo`_ driver
based on `motor <https://github.com/mongodb/motor>`_ driver
"""
from typing import Union, Dict, Optional, List, Tuple, AnyStr
import aiomongo
from aiomongo import AioMongoClient, Database
import motor
from motor.motor_asyncio import AsyncIOMotorClient, AsyncIOMotorDatabase
from ...dispatcher.storage import BaseStorage
@ -35,22 +35,27 @@ class MongoStorage(BaseStorage):
"""
def __init__(self, host='localhost', port=27017, db_name='aiogram_fsm',
def __init__(self, host='localhost', port=27017, db_name='aiogram_fsm', uri=None,
username=None, password=None, index=True, **kwargs):
self._host = host
self._port = port
self._db_name: str = db_name
self._uri = uri
self._username = username
self._password = password
self._kwargs = kwargs
self._mongo: Union[AioMongoClient, None] = None
self._db: Union[Database, None] = None
self._mongo: Union[AsyncIOMotorClient, None] = None
self._db: Union[AsyncIOMotorDatabase, None] = None
self._index = index
async def get_client(self) -> AioMongoClient:
if isinstance(self._mongo, AioMongoClient):
async def get_client(self) -> AsyncIOMotorClient:
if isinstance(self._mongo, AsyncIOMotorClient):
return self._mongo
if self._uri:
self._mongo = AsyncIOMotorClient(self._uri)
return self._mongo
uri = 'mongodb://'
@ -63,16 +68,16 @@ class MongoStorage(BaseStorage):
uri += f'{self._host}:{self._port}' if self._host else f'localhost:{self._port}'
# define and return client
self._mongo = await aiomongo.create_client(uri)
self._mongo = AsyncIOMotorClient(uri)
return self._mongo
async def get_db(self) -> Database:
async def get_db(self) -> AsyncIOMotorDatabase:
"""
Get Mongo db
This property is awaitable.
"""
if isinstance(self._db, Database):
if isinstance(self._db, AsyncIOMotorDatabase):
return self._db
mongo = await self.get_client()