o LDi*@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 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+r,r-r)#hexidr_parent_router sub_routersr rrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-errorsrr startupshutdown observers)selfrr7e/var/www/www-root/data/www/77.83.87.30/venv/lib/python3.10/site-packages/aiogram/dispatcher/router.py__init__s     zRouter.__init__strcCst|jd|jS)N )type__name__rr6r7r7r8__str__yszRouter.__str__cCs d|dS)N<>r7r>r7r7r8__repr__|s zRouter.__repr__ skip_eventsset[str] | None 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_tailr5itemshandlersaddlistsorted)r6rChandlers_in_user update_nameobserverr7r7r8resolve_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)rOrQrRr7)_propagate_event)rUrVrOr6rQr7r8_wrappeds z(Router.propagate_event.._wrapped)rRrV)rUr rVrrr)r r5getwrap_outer_middleware)r6rQrRrSrYr7rXr8propagate_events  zRouter.propagate_eventrOTelegramEventObserver | Nonec st}|r4|j|fi|IdH\}}|stS|||j|fi|IdH}|tur.tS|tur4|S|jD]}|jd||d|IdH}|turN|Sq7|S)N)rQrRr7)r check_root_filtersr triggerrr1r\) r6rOrQrRrSresponseresultrVrr7r7r8rWs&  zRouter._propagate_eventGenerator[Router, None, None]ccs"|}|r|V|j}|sdSdSN) parent_routerr6rr7r7r8 chain_heads  zRouter.chain_headccs$|V|jD]}|jEdHqdSrc)r1rGrer7r7r8rGs  zRouter.chain_tail Router | NonecCs|jSrc)r0r>r7r7r8rdszRouter.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<r= ValueErrorr0 RuntimeErrorrdr1append)r6rmsgparentr7r7r8rds$  routerscGs(|sd}t||D]}||q dS)zT Attach multiple routers. :param routers: :return: z$At least one router must be providedN)rjinclude_router)r6rormrr7r7r8include_routerss  zRouter.include_routerscCs.t|tsdt|jj}t|||_|S)zQ Attach another router. :param router: :return: rh)rirr< __class__r=rjrd)r6rrmr7r7r8rps zRouter.include_routerargscL|j|d|jj|i|IdH|jD] }|j|i|IdHqdS)zr Recursively call startup callbacks :param args: :param kwargs: :return: rN)r r3r_r1 emit_startupr6rsrSrr7r7r8rv   zRouter.emit_startupcrt)z Recursively call shutdown callbacks to graceful shutdown :param args: :param kwargs: :return: ruN)r r4r_r1 emit_shutdownrwr7r7r8ryrxzRouter.emit_shutdown)rrrr)rr:rc)rCrDrrE)rQr:rRr rSrrr) rOr]rQr:rRr rSrrr)rrb)rrg)rrrr)rorrr)rrrr)rsrrSrrr)r= __module__ __qualname____doc__r9r?rBrPr\rWpropertyrfrGrdsetterrqrprvryr7r7r7r8rs( ^           rN) __future__rcollections.abcrtypingrrr event.basesrr event.eventr event.telegramr aiogram.typesr frozensetr__annotations__rr7r7r7r8s