dh)UddlmZddlmZmZmZmZmZmZm Z ddl m Z ddl m Z mZddlmZddlmZed d hZd ed <Gd dZy)) annotations)AnyDictFinal GeneratorListOptionalSet)TelegramObject)REJECTED UNHANDLED) EventObserver)TelegramEventObserverupdateerrorzFinal[frozenset[str]]INTERNAL_UPDATE_TYPESceZdZdZddddZddZddZdddZddZ dd Z e dd Z e dd Z e dd Z e jdd Z ddZddZddZddZy)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)namec l|xstt||_d|_g|_t |d|_t |d|_t |d|_t |d|_ t |d|_ t |d|_ t |d |_ t |d |_ t |d |_t |d |_t |d |_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |d|_t |dx|_|_t?|_ t?|_!id|j d|jd|jd|jd|jd|jd |jd |jd |jd |jd |j d|j"d|j$d|j&d|j(d|j*d|j,|j.|j0|j2|j4|j6|j8|j:d|_"y)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)selfrs S/var/www/netwell/bot/venv/lib/python3.12/site-packages/aiogram/dispatcher/router.py__init__zRouter.__init__sZ )C4M 04)+-DYO 34L\]1.Y#8$9$  2.Y$9$:% !44L\]34L\]"7$8# *&I 0W34L\]0W!6dOb!c 5TN` a&;$<' #0t U"7$8# *?$?* &$9$9$  (=$=( $!6TN` a$9$:% !$9QX#YY dj$ % < t||< d11<  D--<  "4#;#; < D-- < #D$=$= <  d11<  d11<  !$"9"9<  DII<  4++<  d11<  4++<  !7!7<   5 5< %d&A&A!< " $//#< $#'"9"9)-)G)G#'#;#;'+'C'C $ 5 5$($=$=[[1< cJt|jd|jS)N )type__name__rr:s r;__str__zRouter.__str__ms"t*%%&a }55r=cd|dS)N<>rBs r;__repr__zRouter.__repr__ps4&{r=ct}| t}h|t}|jD]G}|jj D](\}}|j s||vs|j |*Itt|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 ) setr chain_tailr9itemshandlersaddlistsorted)r: skip_eventshandlers_in_user update_nameobservers r;resolve_used_update_typesz Router.resolve_used_update_typesss%(E  %K< <&;< oo 5F)/)9)9)?)?)A 5% X$$K)G#'' 4 5 5 F?+,,r=cK|jjjdfd }rj|||d{S||fi|d{S77w)N) event_routercLKjd|d|d{S7w)N)rT update_typeeventrG)_propagate_event)telegram_eventdatarTr:rYs r;_wrappedz(Router.propagate_event.._wrappeds:...!{.TX s $"$)rZr])r\r r]rreturnr)rr9getwrap_outer_middleware)r:rYrZkwargsr^rTs`` @r;propagate_eventzRouter.propagate_eventsl 4 (>>%%k2  !77TZ7[[ [e.v...\.s$AA.A*A.%A,&A.,A.cpKt}|rj|j|fi|d{\}}|stS|j||j|fi|d{}|turtS|tur|S|j D]*}|j d||d|d{}|tus)|S|S77Y7w)N)rYrZrG)rcheck_root_filtersrtriggerrr5rc) r:rTrYrZrbresponseresultr]rs r;r[zRouter._propagate_events "=!v>>H8#  y(&& F3V33c SXc\bccHy(   #N ?ds:B6B06B6B2AB6B4 B6*B62B64B6c#<K|}|r||j}|ryywN) parent_routerr:rs r; chain_headzRouter.chain_heads##'L))Fsc#bK||jD]}|jEd{y7wrj)r5rKrls r;rKzRouter.chain_tails2 && )F(( ( ( ) (s #/-/c|jSrj)r4rBs r;rkzRouter.parent_routers"""r=cXt|ts!tdt|j|j rt d|j ||k(r t d|}|||k(r t d|j}|||_|jj|y)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 RuntimeErrorrkr5append)r:rparents r;rkzRouter.parent_routers&&)GV H]H]G`ab b   !?@S@S?VWX X 6>HI I#) ~"#RSS))F  %!!$'r=cN|s td|D]}|j|y)zT Attach multiple routers. :param routers: :return: z$At least one router must be providedN)rsinclude_router)r:routersrs r;include_routerszRouter.include_routerss0CD D (F    ' (r=ct|ts+tdt|jj ||_|S)zQ Attach another router. :param router: :return: rq)rrrrsr@ __class__rArkrls r;rxzRouter.include_routersE&&):4<;Q;Q;Z;Z:[\  $ r=cK|j||jj|i|d{|jD]}|j|i|d{y707 w)zr Recursively call startup callbacks :param args: :param kwargs: :return: rN)rr7rfr5 emit_startupr:argsrbrs r;rzRouter.emit_startupsn  T ""dll""D3F333&& 7F%&%%t6v6 6 6 7 4 6!2A)A%(A)A'A)'A)cK|j||jj|i|d{|jD]}|j|i|d{y707 w)z Recursively call shutdown callbacks to graceful shutdown :param args: :param kwargs: :return: r~N)rr8rfr5 emit_shutdownrs r;rzRouter.emit_shutdownsn  T "#dmm##T4V444&& 8F&&&&77 7 7 8 5 7r)rz Optional[str]r_None)r_strrj)rQzOptional[Set[str]]r_z List[str])rYrrZr rbrr_r) rTzOptional[TelegramEventObserver]rYrrZr rbrr_r)r_zGenerator[Router, None, None])r_zOptional[Router])rrr_r)ryrr_r)rrr_r)rrrbrr_r)rA __module__ __qualname____doc__r<rCrHrUrcr[propertyrmrKrksetterrzrxrrrGr=r;rr s15S j6-* /1    >** )) ##((6 (  7 8r=rN) __future__rtypingrrrrrr r typesr event.basesrr event.eventrevent.telegramr frozensetr__annotations__rrGr=r;rs?"CCC",&1/8(G9L/M,MF8F8r=