|
33 | 33 | from io import StringIO, BytesIO |
34 | 34 | from mimetypes import MimeTypes |
35 | 35 | from pathlib import Path |
36 | | -from typing import Union, List, Optional, Callable, AsyncGenerator, Type, Tuple |
| 36 | +from typing import Union, List, Optional, Callable, AsyncGenerator, Tuple |
37 | 37 |
|
38 | 38 | import pyrogram |
39 | 39 | from pyrogram import __version__, __license__ |
|
51 | 51 | from pyrogram.methods import Methods |
52 | 52 | from pyrogram.session import Auth, Session |
53 | 53 | from pyrogram.storage import FileStorage, MemoryStorage, Storage |
54 | | -try: |
55 | | - import pymongo |
56 | | -except Exception: |
57 | | - pass |
58 | | -else: |
59 | | - from pyrogram.storage import MongoStorage |
60 | 54 | from pyrogram.types import User, TermsOfService |
61 | 55 | from pyrogram.utils import ainput |
62 | 56 | from .connection import Connection |
63 | | -from .connection.transport import TCP, TCPAbridged |
| 57 | +from .connection.transport import TCPAbridged |
64 | 58 | from .dispatcher import Dispatcher |
65 | 59 | from .file_id import FileId, FileType, ThumbnailSource |
66 | | -from .filters import Filter |
67 | 60 | from .mime_types import mime_types |
68 | 61 | from .parser import Parser |
69 | 62 | from .session.internals import MsgId |
70 | 63 |
|
71 | 64 | log = logging.getLogger(__name__) |
| 65 | +MONGO_AVAIL = False |
| 66 | + |
| 67 | +try: |
| 68 | + import pymongo |
| 69 | +except Exception: |
| 70 | + pass |
| 71 | +else: |
| 72 | + from pyrogram.storage import MongoStorage |
| 73 | + MONGO_AVAIL = True |
72 | 74 |
|
73 | 75 |
|
74 | 76 | class Client(Methods): |
@@ -316,9 +318,7 @@ def __init__( |
316 | 318 | elif self.in_memory: |
317 | 319 | self.storage = MemoryStorage(self.name) |
318 | 320 | elif self.mongodb: |
319 | | - try: |
320 | | - import pymongo |
321 | | - except Exception: |
| 321 | + if not MONGO_AVAIL: |
322 | 322 | log.warning( |
323 | 323 | "pymongo is missing! " |
324 | 324 | "Using MemoryStorage as session storage" |
@@ -953,7 +953,7 @@ def load_plugins(self): |
953 | 953 | ) |
954 | 954 |
|
955 | 955 | count += 1 |
956 | | - except Exception as e: |
| 956 | + except Exception: |
957 | 957 | pass |
958 | 958 | else: |
959 | 959 | for path, handlers in include: |
|
0 commit comments