From 4cc67ea03a46efe3f07828614a61a9ab45548475 Mon Sep 17 00:00:00 2001 From: Alex RootJunior Date: Sat, 30 Mar 2019 22:42:36 +0200 Subject: [PATCH] Pass update from webhook to updates handler instead of `Dispatcher.process_update` --- aiogram/dispatcher/webhook.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/aiogram/dispatcher/webhook.py b/aiogram/dispatcher/webhook.py index 10a4b3c1..c8abdef2 100644 --- a/aiogram/dispatcher/webhook.py +++ b/aiogram/dispatcher/webhook.py @@ -1,4 +1,6 @@ import asyncio +import itertools + import asyncio.tasks import datetime import functools @@ -165,7 +167,7 @@ class WebhookRequestHandler(web.View): timeout_handle = loop.call_later(RESPONSE_TIMEOUT, asyncio.tasks._release_waiter, waiter) cb = functools.partial(asyncio.tasks._release_waiter, waiter) - fut = asyncio.ensure_future(dispatcher.process_update(update), loop=loop) + fut = asyncio.ensure_future(dispatcher.updates_handler.notify(update), loop=loop) fut.add_done_callback(cb) try: @@ -219,7 +221,7 @@ class WebhookRequestHandler(web.View): """ if results is None: return None - for result in results: + for result in itertools.chain.from_iterable(results): if isinstance(result, BaseResponse): return result