o 4ja-@sUddlmZddlmZddlmZmZmZddlm Z m Z ddl m Z ddl mZer3ddlmZed d hZd ed <Gd ddZdS)) annotations) Generator) TYPE_CHECKINGAnyFinal)REJECTED UNHANDLED) EventObserver)TelegramEventObserver)TelegramObjectupdateerrorzFinal[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 str | NonereturnNonec Cs|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|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|j|j|j|j |j!d |_&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_media managed_bot guest_message subscriptionstopped_message_generationr) r(r)r*r+r,r-r.r/r0r1r)'hexidr_parent_router sub_routersr rrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1errorsrr startupshutdown observers)selfrr;V/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/aiogram/dispatcher/router.py__init__s     zRouter.__init__strcCst|jd|jS)N )type__name__rr:r;r;r<__str__szRouter.__str__cCs d|dS)N<>r;rBr;r;r<__repr__s zRouter.__repr__ skip_eventsset[str] | None list[str]cCs`t}|dur t}h|t}|jD]}|jD]\}}|jr*||vr*||qqt|S)z Resolve registered event names Is useful for getting updates only for registered event types. :param skip_events: skip specified event names :return: sorted list of registered names N)setr chain_tailr9itemshandlersaddsorted)r:rGhandlers_in_user update_nameobserverr;r;r<resolve_used_update_typess    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)rRrTrUr;)_propagate_event)rXrYrRr:rTr;r<_wrappeds z(Router.propagate_event.._wrapped)rUrY)rXr rYrrr)r r9getwrap_outer_middleware)r:rTrUrVr\r;r[r<propagate_events  zRouter.propagate_eventrRTelegramEventObserver | Nonec st}|r4|j|fi|IdH\}}|stS|||j|fi|IdH}|tur.tS|tur4|S|jD]}|jd||d|IdH}|turN|Sq7|S)N)rTrUr;)r check_root_filtersr triggerrr5r_) r:rRrTrUrVresponseresultrYrr;r;r<rZs&  zRouter._propagate_eventGenerator[Router, None, None]ccs"|}|r|V|j}|sdSdSN) parent_routerr:rr;r;r< chain_heads  zRouter.chain_headccs$|V|jD]}|jEdHqdSrf)r5rKrhr;r;r<rKs  zRouter.chain_tail Router | NonecCs|jSrf)r4rBr;r;r<rgszRouter.parent_routerrcCst|tsdt|j}t||jrd|j}t|||kr(d}t||}|dur?||kr8d}t||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) isinstancerr@rA ValueErrorr4 RuntimeErrorrgr5append)r:rmsgparentr;r;r<rgs$  routerscGs(|sd}t||D]}||q dS)zT Attach multiple routers. :param routers: :return: z$At least one router must be providedN)rminclude_router)r:rrrprr;r;r<include_routerss  zRouter.include_routerscCs,t|tsdt|j}t|||_|S)zQ Attach another router. :param router: :return: rk)rlrr@rArmrg)r:rrpr;r;r<rs s zRouter.include_routerargscL|j|d|jj|i|IdH|jD] }|j|i|IdHqdS)zr Recursively call startup callbacks :param args: :param kwargs: :return: rN)r r7rbr5 emit_startupr:rurVrr;r;r<rx   zRouter.emit_startupcrv)z Recursively call shutdown callbacks to graceful shutdown :param args: :param kwargs: :return: rwN)r r8rbr5 emit_shutdownryr;r;r<r{&rzzRouter.emit_shutdown)rrrr)rr>rf)rGrHrrI)rTr>rUr rVrrr) rRr`rTr>rUr rVrrr)rre)rrj)rrrr)rrrrr)rrrr)rurrVrrr)rA __module__ __qualname____doc__r=rCrFrSr_rZpropertyrirKrgsetterrtrsrxr{r;r;r;r<rs( i           rN) __future__rcollections.abcrtypingrrr event.basesrr event.eventr event.telegramr aiogram.typesr frozensetr__annotations__rr;r;r;r<s