From 660aba50eed479a7e6ebceccf0c73fc8fd78409f Mon Sep 17 00:00:00 2001
From: Oleg A <t0rr@mail.ru>
Date: Wed, 5 Dec 2018 01:01:13 +0300
Subject: [PATCH 1/2] faster skip updates by negative offset

---
 aiogram/dispatcher/dispatcher.py | 15 ++-------------
 1 file changed, 2 insertions(+), 13 deletions(-)

diff --git a/aiogram/dispatcher/dispatcher.py b/aiogram/dispatcher/dispatcher.py
index 6247f211..035ec1f5 100644
--- a/aiogram/dispatcher/dispatcher.py
+++ b/aiogram/dispatcher/dispatcher.py
@@ -50,8 +50,6 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
         self.throttling_rate_limit = throttling_rate_limit
         self.no_throttle_error = no_throttle_error
 
-        self.last_update_id = 0
-
         self.filters_factory: FiltersFactory = filters_factory
         self.updates_handler = Handler(self, middleware_key='update')
         self.message_handlers = Handler(self, middleware_key='message')
@@ -120,17 +118,9 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
         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.
 
-        :return: count of skipped updates
+        :return: None
         """
-        total = 0
-        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
+        await self.bot.get_updates(offset=-1, timeout=1)
 
     async def process_updates(self, updates, fast: typing.Optional[bool] = True):
         """
@@ -158,7 +148,6 @@ class Dispatcher(DataMixin, ContextInstanceMixin):
         :param update:
         :return:
         """
-        self.last_update_id = update.update_id
         types.Update.set_current(update)
 
         try:

From 42d1e875a538895a1bf6fc6dbd16f3279ee142bd Mon Sep 17 00:00:00 2001
From: Oleg A <t0rr@mail.ru>
Date: Wed, 5 Dec 2018 01:28:21 +0300
Subject: [PATCH 2/2] removed skipped updates counter

---
 aiogram/utils/executor.py | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/aiogram/utils/executor.py b/aiogram/utils/executor.py
index f4b2f777..b02bddf2 100644
--- a/aiogram/utils/executor.py
+++ b/aiogram/utils/executor.py
@@ -338,10 +338,8 @@ class Executor:
 
     async def _skip_updates(self):
         await self.dispatcher.reset_webhook(True)
-        count = await self.dispatcher.skip_updates()
-        if count:
-            log.warning(f"Skipped {count} updates.")
-        return count
+        await self.dispatcher.skip_updates()
+        log.warning(f"Updates are skipped successfully.")
 
     async def _welcome(self):
         user = await self.dispatcher.bot.me