a 9g@sddlmZddlmZmZmZmZmZmZddl m Z ddl m Z ddl mZddlmZdd lmZmZmZdd lmZmZmZerdd lmZGd d d ZdS)) annotations) TYPE_CHECKINGAnyCallableDictListOptional)MiddlewareManager)UnsupportedKeywordArgument)Filter)TelegramObject) UNHANDLEDMiddlewareType SkipHandler) CallbackType FilterObject HandlerObject)Routerc@seZdZdZddddddZddd d d Zd d ddZddddddddddZdddddddZddddddZ dddddd Z dddddd!d"d#d$Z dS)%TelegramEventObserverz Event observer for Telegram events Here you can register handler with filter. This observer will stop event propagation when first handler is pass. rstrNone)router event_namereturncCs8||_||_g|_t|_t|_tddgd|_dS)NcSsdS)NTrrr~/var/www/vosh/data/www/fastworkle.ru/webshop-tgbot-v.1.0/venv/lib/python3.9/site-packages/aiogram/dispatcher/event/telegram.py$z0TelegramEventObserver.__init__..)callbackfilters)rrhandlersr middlewareouter_middlewarer_handler)selfrrrrr__init__s zTelegramEventObserver.__init__r)r!rcGs0|jjdurg|j_|jjdd|DdS)zu Register filter for all handlers of this event observer :param filters: positional filters NcSsg|] }t|qSrr.0Zfilter_rrr .rz0TelegramEventObserver.filter..)r%r!extend)r&r!rrrfilter&s zTelegramEventObserver.filterz$List[MiddlewareType[TelegramObject]])rcCs<g}tt|jjD]"}|j|j}|r||jq|SN) reversedtuplerZ chain_headZ observersgetrr,r#)r&Z middlewaresrZobserverrrr_resolve_middlewares0s z*TelegramEventObserver._resolve_middlewaresNflagszOptional[Dict[str, Any]]r)r r!r4kwargsrcOsl|rtdt|d|dur(i}|D]}t|tr,|j|dq,|jt|dd|D|d|S)z( Register event handler a Passing any additional keyword arguments to the registrar method is not supported. This error may be caused when you are trying to register filters like in 2.x version of this framework, if it's true just look at correspoding documentation pages. Please remove the z arguments from this call. Nr3cSsg|] }t|qSrr(r)rrrr+Wrz2TelegramEventObserver.register..)r r!r4) r setkeys isinstancer Zupdate_handler_flagsr"appendr)r&r r4r!r5itemrrrregister9s&     zTelegramEventObserver.registerr zDict[str, Any])r eventdatarcCs|j|j|}|||Sr.)r#wrap_middlewaresr$)r&r r<r=Z wrapped_outerrrrwrap_outer_middleware^s z+TelegramEventObserver.wrap_outer_middleware)r<r5rcKs|jj|fi|Sr.)r%check)r&r<r5rrrcheck_root_filtersgsz(TelegramEventObserver.check_root_filtersc s|jD]x}||d<|j|fi|IdH\}}|r||z*|j||j}|||IdHWSty|YqYq0qtS)z Propagate event to handlers and stops propagation on first match. Handler will be called when all its filters are pass. handlerN) r"r@updater$r>r2callrr)r&r<r5rBresultr=Z wrapped_innerrrrtriggerjs    zTelegramEventObserver.triggerz&Callable[[CallbackType], CallbackType])r!r4r5rcsdddfdd }|S)z: Decorator for registering event handlers r)r rcs j|gRdi|S)Nr4)r;)r r!r4r5r&rrwrappersz/TelegramEventObserver.__call__..wrapperr)r&r4r!r5rHrrGr__call__s zTelegramEventObserver.__call__) __name__ __module__ __qualname____doc__r'r-r2r;r?rArFrIrrrrrs   % rN) __future__rtypingrrrrrrZ&aiogram.dispatcher.middlewares.managerr exceptionsr Z filters.baser typesr basesrrrrBrrrZaiogram.dispatcher.routerrrrrrrs