mirror of
https://github.com/eternnoir/pyTelegramBotAPI.git
synced 2023-08-10 21:12:57 +03:00
Compare commits
No commits in common. "bf415e4bd75d8557f3228c0d9a7db2045f545c15" and "726b203724e1b126475b64bad76ae080b91da69b" have entirely different histories.
bf415e4bd7
...
726b203724
|
@ -161,9 +161,9 @@ class TeleBot:
|
|||
}
|
||||
self.default_middleware_handlers = []
|
||||
if apihelper.ENABLE_MIDDLEWARE and use_class_middlewares:
|
||||
self.typed_middleware_handlers = None
|
||||
logger.error(
|
||||
'You are using class based middlewares while having ENABLE_MIDDLEWARE set to True. This is not recommended.'
|
||||
logger.warning(
|
||||
'You are using class based middlewares, but you have '
|
||||
'ENABLE_MIDDLEWARE set to True. This is not recommended.'
|
||||
)
|
||||
self.middlewares = [] if use_class_middlewares else None
|
||||
self.threaded = threaded
|
||||
|
@ -464,7 +464,7 @@ class TeleBot:
|
|||
new_chat_join_request = None
|
||||
|
||||
for update in updates:
|
||||
if apihelper.ENABLE_MIDDLEWARE and not self.use_class_middlewares:
|
||||
if apihelper.ENABLE_MIDDLEWARE:
|
||||
try:
|
||||
self.process_middlewares(update)
|
||||
except Exception as e:
|
||||
|
@ -595,7 +595,6 @@ class TeleBot:
|
|||
self._notify_command_handlers(self.chat_join_request_handlers, chat_join_request, 'chat_join_request')
|
||||
|
||||
def process_middlewares(self, update):
|
||||
if self.typed_middleware_handlers:
|
||||
for update_type, middlewares in self.typed_middleware_handlers.items():
|
||||
if getattr(update, update_type) is not None:
|
||||
for typed_middleware_handler in middlewares:
|
||||
|
@ -605,7 +604,7 @@ class TeleBot:
|
|||
e.args = e.args + (f'Typed middleware handler "{typed_middleware_handler.__qualname__}"',)
|
||||
raise
|
||||
|
||||
if self.default_middleware_handlers:
|
||||
if len(self.default_middleware_handlers) > 0:
|
||||
for default_middleware_handler in self.default_middleware_handlers:
|
||||
try:
|
||||
default_middleware_handler(self, update)
|
||||
|
@ -3171,17 +3170,10 @@ class TeleBot:
|
|||
if not apihelper.ENABLE_MIDDLEWARE:
|
||||
raise RuntimeError("Middleware is not enabled. Use apihelper.ENABLE_MIDDLEWARE before initialising TeleBot.")
|
||||
|
||||
if self.use_class_middlewares:
|
||||
logger.error("middleware_handler/register_middleware_handler/add_middleware_handler cannot be used with use_class_middlewares=True. Skipped.")
|
||||
return
|
||||
|
||||
added = False
|
||||
if update_types and self.typed_middleware_handlers:
|
||||
if update_types:
|
||||
for update_type in update_types:
|
||||
if update_type in self.typed_middleware_handlers:
|
||||
added = True
|
||||
self.typed_middleware_handlers[update_type].append(handler)
|
||||
if not added:
|
||||
else:
|
||||
self.default_middleware_handlers.append(handler)
|
||||
|
||||
# function register_middleware_handler
|
||||
|
|
|
@ -141,7 +141,7 @@ class AsyncTeleBot:
|
|||
return [types.Update.de_json(ju) for ju in json_updates]
|
||||
|
||||
async def polling(self, non_stop: bool=False, skip_pending=False, interval: int=0, timeout: int=20,
|
||||
request_timeout: int=None, allowed_updates: Optional[List[str]]=None,
|
||||
request_timeout: int=20, allowed_updates: Optional[List[str]]=None,
|
||||
none_stop: Optional[bool]=None):
|
||||
"""
|
||||
This allows the bot to retrieve Updates automatically and notify listeners and message handlers accordingly.
|
||||
|
@ -174,7 +174,7 @@ class AsyncTeleBot:
|
|||
await self.skip_updates()
|
||||
await self._process_polling(non_stop, interval, timeout, request_timeout, allowed_updates)
|
||||
|
||||
async def infinity_polling(self, timeout: int=20, skip_pending: bool=False, request_timeout: int=None, logger_level=logging.ERROR,
|
||||
async def infinity_polling(self, timeout: int=20, skip_pending: bool=False, request_timeout: int=20, logger_level=logging.ERROR,
|
||||
allowed_updates: Optional[List[str]]=None, *args, **kwargs):
|
||||
"""
|
||||
Wrap polling with infinite loop and exception handling to avoid bot stops polling.
|
||||
|
@ -213,7 +213,7 @@ class AsyncTeleBot:
|
|||
logger.error("Break infinity polling")
|
||||
|
||||
async def _process_polling(self, non_stop: bool=False, interval: int=0, timeout: int=20,
|
||||
request_timeout: int=None, allowed_updates: Optional[List[str]]=None):
|
||||
request_timeout: int=20, allowed_updates: Optional[List[str]]=None):
|
||||
"""
|
||||
Function to process polling.
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user