o Fh)@sUddlmZddlmZmZmZmZmZmZm Z ddl m Z ddl m Z mZddlmZddlmZed d hZd ed <Gd ddZdS)) annotations)AnyDictFinal GeneratorListOptionalSet)TelegramObject)REJECTED UNHANDLED) EventObserver)TelegramEventObserverupdateerrorzFinal[frozenset[str]]INTERNAL_UPDATE_TYPESc@seZdZdZddd3dd Zd4d d Zd4d dZd5d6ddZd7ddZd8ddZ e d9d d!Z e d9d"d#Z e d:d%d&Z e jd;d(d&Z dd/d0Zd>d1d2ZdS)?RouteraZ Router can route update, and it nested update types like messages, callback query, polls and all other event types. Event handlers can be registered in observer by two ways: - By observer method - :obj:`router..register(handler, )` - By decorator - :obj:`@router.()` N)namer Optional[str]returnNonec Cs8|ptt||_d|_g|_t|dd|_t|dd|_t|dd|_t|dd|_ t|dd|_ t|dd|_ t|d d|_ t|d d|_ t|d d|_t|d d|_t|d d|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_t|dd|_|_t|_ t|_!id|jd|jd|jd|j d|j d|j d |j d |j d |jd |jd |jd|jd|jd|jd|jd|jd|j|j|j|j|j|j|j|jd|_"dS)zP :param name: Optional router name, can be useful for debugging Nmessage)router event_nameedited_message channel_postedited_channel_post inline_querychosen_inline_resultcallback_queryshipping_querypre_checkout_querypoll poll_answermy_chat_member chat_memberchat_join_requestmessage_reactionmessage_reaction_count chat_boostremoved_chat_boostdeleted_business_messagesbusiness_connectionedited_business_messagebusiness_messagepurchased_paid_mediar)r,r-r.r/r0r1r)#hexidr_parent_router sub_routersrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1errorsrrstartupshutdown observers)selfrr;L/var/www/html/venv/lib/python3.10/site-packages/aiogram/dispatcher/router.py__init__s     zRouter.__init__strcCst|jd|jS)N )type__name__rr:r;r;r<__str__mszRouter.__str__cCs d|dS)N<>r;rBr;r;r<__repr__ps zRouter.__repr__ skip_eventsOptional[Set[str]] List[str]cCsdt}|dur t}h|t}|jD]}|jD]\}}|jr*||vr*||qqtt|S)z Resolve registered event names Is useful for getting updates only for registered event types. :param skip_events: skip specified event names :return: set of registered names N) setr chain_tailr9itemshandlersaddlistsorted)r:rGhandlers_in_user update_nameobserverr;r;r<resolve_used_update_typesss     z Router.resolve_used_update_types update_typeeventr kwargsrcs\|jdjd fdd }r#j|||d IdHS||fi|IdHS) N) event_routertelegram_eventr datarrcs jd|d|IdHS)N)rSrUrVr;)_propagate_event)rYrZrSr:rUr;r<_wrappeds  z(Router.propagate_event.._wrapped)rVrZ)rYr rZrrr)rr9getwrap_outer_middleware)r:rUrVrWr]r;r\r<propagate_events  zRouter.propagate_eventrSOptional[TelegramEventObserver]c st}|r4|j|fi|IdH\}}|stS|||j|fi|IdH}|tur.tS|tur4|S|jD]}|jd||d|IdH}|turN|Sq7|S)N)rUrVr;)rcheck_root_filtersrtriggerr r5r`) r:rSrUrVrWresponseresultrZrr;r;r<r[s&  zRouter._propagate_eventGenerator[Router, None, None]ccs"|}|r|V|j}|sdSdSN) parent_routerr:rr;r;r< chain_heads  zRouter.chain_headccs$|V|jD]}|jEdHqdSrg)r5rKrir;r;r<rKs  zRouter.chain_tailOptional[Router]cCs|jSrg)r4rBr;r;r<rhszRouter.parent_routerrcCst|tstdt|j|jrtd|j||kr"td|}|dur7||kr0td|j}|dus(||_|j |dS)a Internal property setter of parent router fot this router. Do not use this method in own code. All routers should be included via `include_router` method. Self- and circular- referencing are not allowed here :param router: (router should be instance of Router not zRouter is already attached to z'Self-referencing routers is not allowedNz-Circular referencing of Router is not allowed) isinstancer ValueErrorr@rAr4 RuntimeErrorrhr5append)r:rparentr;r;r<rhs routerscGs$|std|D]}||qdS)zT Attach multiple routers. :param routers: :return: z$At least one router must be providedN)rninclude_router)r:rrrr;r;r<include_routerss  zRouter.include_routerscCs*t|tstdt|jj||_|S)zQ Attach another router. :param router: :return: rl)rmrrnr@ __class__rArhrir;r;r<rss zRouter.include_routerargscL|j|d|jj|i|IdH|jD] }|j|i|IdHqdS)zr Recursively call startup callbacks :param args: :param kwargs: :return: rN)rr7rcr5 emit_startupr:rvrWrr;r;r<ry   zRouter.emit_startupcrw)z Recursively call shutdown callbacks to graceful shutdown :param args: :param kwargs: :return: rxN)rr8rcr5 emit_shutdownrzr;r;r<r|r{zRouter.emit_shutdown)rrrr)rr>rg)rGrHrrI)rUr>rVr rWrrr) rSrarUr>rVr rWrrr)rrf)rrk)rrrr)rrrrr)rrrr)rvrrWrrr)rA __module__ __qualname____doc__r=rCrFrTr`r[propertyrjrKrhsetterrtrsryr|r;r;r;r<r s( U           rN) __future__rtypingrrrrrrr typesr event.basesr r event.eventrevent.telegramr frozensetr__annotations__rr;r;r;r<s$