telebot/__init__.py

@@ -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,17 +595,16 @@ 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:
-                        try:
-                            typed_middleware_handler(self, getattr(update, update_type))
-                        except Exception as e:
-                            e.args = e.args + (f'Typed middleware handler "{typed_middleware_handler.__qualname__}"',)
-                            raise
+        for update_type, middlewares in self.typed_middleware_handlers.items():
+            if getattr(update, update_type) is not None:
+                for typed_middleware_handler in middlewares:
+                    try:
+                        typed_middleware_handler(self, getattr(update, update_type))
+                    except Exception as e:
+                        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:
+                self.typed_middleware_handlers[update_type].append(handler)
+        else:
             self.default_middleware_handlers.append(handler)
 
     # function register_middleware_handler

telebot/async_telebot.py

@@ -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.