python/aiogram
1
0
Fork 0
mirror of https://github.com/aiogram/aiogram.git synced 2025-12-11 09:55:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

faster skip updates by negative offset

Browse source
This commit is contained in:
Oleg A 2018-12-05 01:01:13 +03:00
parent d8fdbb853c
commit 660aba50ee
1 changed files with 2 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

15
aiogram/dispatcher/dispatcher.py
View file

@ -50,8 +50,6 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
self.throttling_rate_limit = throttling_rate_limit self.throttling_rate_limit = throttling_rate_limit
self.no_throttle_error = no_throttle_error self.no_throttle_error = no_throttle_error
self.last_update_id = 0
self.filters_factory: FiltersFactory = filters_factory self.filters_factory: FiltersFactory = filters_factory
self.updates_handler = Handler(self, middleware_key='update') self.updates_handler = Handler(self, middleware_key='update')
self.message_handlers = Handler(self, middleware_key='message') self.message_handlers = Handler(self, middleware_key='message')
@ -120,17 +118,9 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
You can skip old incoming updates from queue. You can skip old incoming updates from queue.
This method is not recommended to use if you use payments or you bot has high-load. This method is not recommended to use if you use payments or you bot has high-load.
:return: count of skipped updates :return: None
""" """
total = 0 await self.bot.get_updates(offset=-1, timeout=1)
updates = await self.bot.get_updates(offset=self.last_update_id, timeout=1)
while updates:
total += len(updates)
for update in updates:
if update.update_id > self.last_update_id:
self.last_update_id = update.update_id
updates = await self.bot.get_updates(offset=self.last_update_id + 1, timeout=1)
return total
async def process_updates(self, updates, fast: typing.Optional[bool] = True): async def process_updates(self, updates, fast: typing.Optional[bool] = True):
""" """
@ -158,7 +148,6 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
:param update: :param update:
:return: :return:
""" """
self.last_update_id = update.update_id
types.Update.set_current(update) types.Update.set_current(update)
try: try: