8Cf:ddlmZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZmZmZmZddlmZmZmZdd lmZdd lmZdd lmZdd lmZmZdd l m!Z!GddeZ"e"jFjHe"jJjHe"jLjHe"jNjHe"jPjHfe"jRjHe"jTjHe"jVjHe"jXjHe"jZjHe"j\jHe"j^jHe"j`jHe"jbjHe"jdjHe"jfjHe"jhjHe"jjjHe"jljHe"jnjHfe"jpjHe"jrjHe"jtjHhdZ;dZeGddZ?GddeZ@GddeZAy)) annotationsN)deque) dataclass)Enum) isawaitable)AnyDictListOptionalTupleUnioncast) BaseRouterRoute RouteGroup)NotFound) path_to_parts) InvalidSignal) error_loggerlogger) SignalHandlercleZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZy)Eventz Event names for the SignalRouterzserver.exception.reportzserver.init.afterzserver.init.beforezserver.shutdown.afterzserver.shutdown.beforezhttp.lifecycle.beginzhttp.lifecycle.completezhttp.lifecycle.exceptionzhttp.lifecycle.handlezhttp.lifecycle.read_bodyzhttp.lifecycle.read_headzhttp.lifecycle.requestzhttp.lifecycle.responsezhttp.routing.afterzhttp.routing.beforezhttp.handler.afterzhttp.handler.beforezhttp.lifecycle.sendzhttp.middleware.afterzhttp.middleware.beforezwebsocket.handler.afterzwebsocket.handler.beforezwebsocket.handler.exceptionN)__name__ __module__ __qualname____doc__SERVER_EXCEPTION_REPORTSERVER_INIT_AFTERSERVER_INIT_BEFORESERVER_SHUTDOWN_AFTERSERVER_SHUTDOWN_BEFOREHTTP_LIFECYCLE_BEGINHTTP_LIFECYCLE_COMPLETEHTTP_LIFECYCLE_EXCEPTIONHTTP_LIFECYCLE_HANDLEHTTP_LIFECYCLE_READ_BODYHTTP_LIFECYCLE_READ_HEADHTTP_LIFECYCLE_REQUESTHTTP_LIFECYCLE_RESPONSEHTTP_ROUTING_AFTERHTTP_ROUTING_BEFOREHTTP_HANDLER_AFTERHTTP_HANDLER_BEFOREHTTP_LIFECYCLE_SENDHTTP_MIDDLEWARE_AFTERHTTP_MIDDLEWARE_BEFOREWEBSOCKET_HANDLER_AFTERWEBSOCKET_HANDLER_BEFOREWEBSOCKET_HANDLER_EXCEPTIONM/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/sanic/signals.pyrrs*7+-3517939957-/-//3579"?r6r)serverhttp websocketz__generic__.__signal__.%scyNr5r5r6r7_blankr=Ssr6ceZdZdZy)Signalz6A `Route` that is used to dispatch signals to handlersNrrrrr5r6r7r?r?Ws@r6r?cjeZdZUdZded<ded<dZded<dZd ed <d Zd ed <dZded<dZ dZ y) SignalWaiterz3A record representing a future waiting for a signalr?signalstrevent_definitiontriggerNOptional[Dict[str, str]] requirementsTbool exclusivezOptional[asyncio.Future]futurecKtj}|j|_|jj j j| |jd{|jj j j|S73#|jj j j|wxYww)zoBlock until the signal is next dispatched. Return the context of the signal dispatch, if any. N) asyncioget_running_loop create_futurerLrCctxwaitersappendremove)selfloops r7waitzSignalWaiter.waitgs '')((*  &&t, 1$ KKOO # # * *4 0% KKOO # # * *4 0s0ACB!+B,B!/0CB!!1CCc|duxr |j xs$|duxr |j xs||jk(xr|jxs||jk(Sr<)rKrIrGrE)rUevent conditions r7matcheszSignalWaiter.matchestsg $  5t~~#5 .T!;$*;*;&; .D---?||=u(=(==  ?r6) rrrr__annotations__rGrIrKrLrWr[r5r6r7rBrB[sD= NGS-1L*1It'+F $+ 1?r6rBceZdZdZy) SignalGroupz;A `RouteGroup` that is used to dispatch signals to handlersNr@r5r6r7r^r^|sEr6r^ceZdZdZdfd ZeddZ d ddZ d ddZdddddd  dd Z d dd Z dd Z dd d dfdZ ddfd Z ddZd dZxZS)! SignalRouterz;A `BaseRouter` that is used to dispatch signals to handlersclt|dttdd|_d|j _y)N.T) delimiter route_class group_classstacking)super__init__r?r^allow_fail_builtinrQrV)rU __class__s r7rhzSignalRouter.__init__s6 #  #' r6cjt|trt|j}d|vr t|z}|S)zEnsure event strings in proper format Args: event (str): event string Returns: str: formatted event string rb) isinstancerrDvalueGENERIC_SIGNAL_FORMAT)rYs r7 format_eventzSignalRouter.format_events3 eT " $E e )E1E r6Nc|j|}|xsi} |jd||j|iid|\}}|d}|s=|j jD cic]\} } | j|d| }} } ||D cgc]} | jc} |fS#t$r5d}|g}|r|dz }|j |t|t |zwxYwcc} } wcc} w)a Get the handlers for a signal Args: event (str): The event to get the handlers for condition (Optional[Dict[str, str]], optional): A dictionary of conditions to match against the handlers. Defaults to `None`. Returns: Tuple[SignalGroup, List[SignalHandler], Dict[str, Any]]: A tuple of the `SignalGroup` that matched, a list of the handlers that matched, and a dictionary of the params that matched Raises: NotFound: If no handlers are found rb) __params__ __matches__extrazCould not find signal %sz with %srqrr) ro find_routeDEFAULT_METHODrrStupleparamsitemsnamehandler) rUrYrZrtgroup param_basketmessagetermsrxidxparamroutes r7getzSignalRouter.gets"!!%(R 3"&//E7 ##!"5 #2# E<"l+ #(,,"4"4"6C L7<<F %8u}}8&@@) 30GAFE:% U#7U5\12 2  3 9s)B#&C$ C*#>C!TFcK|j|} |j||\}}}|r|j||jdd|j } |s| ddd} | D]T} | j j"D]9} | j%||s| j&j)t+|;V| D]} | j,j.}|| j j0dus ||r||k(s=| j j2s|| j j4k(sm| j6d i|}t9|r|d{}|s|cS|s|cSy#t$r} |jdddtv} |r| r |j r| |j jjrK|j jjjdk\rtjt| Yd} ~ yd} ~ wwxYw7#t:$r} |j jjrB|j jjjdk\rtj<| |t>j@jBk7rC|jEt>j@jBd| i d{7tG| d d | d} ~ wwxYww) N)rZrbr __trigger__F exception)context__dispatched__Tr5)$rorrsplitRESERVED_NAMESPACESrirQappdebugstate verbosityrwarningrDupdatepoproutesrRr[rL set_resultdictrtrIrKrG definitionr{r Exceptionrrrrmdispatchsetattr)rUrYrrZfail_not_foundreverser|handlersrxe is_reservedsignalsrCwaiterrImaybe_coroutineretvals r7 _dispatchzSignalRouter._dispatchs!!%( &*hhu h&J #E8V  MM' " =$',,ddmG ! ?$jj00?F~~eY7 00f>? ? " /%||88 &6::+?+?5+H!),!\1zz))Ufjj6K6K-K&4fnn&>v&>O"?3'6!6!#)M(.. /I ++c1-a04GGK{d6M6M88<<%%$((,,*<*<*F*F!*K ((Q0 >"7  xx||!!dhhll&8&8&B&Ba&G&&q)55;;;mm1177(!,$+T2G sK,E';K,(0HA&H/H0"HHHHK,H!H$K,%H&K,' H0BH K, HK,H K) B/K$KK$$K))K,)rrZrinlinerc<K|j|}|j||||xr||}tjd|ddi|r |d{St j j |}t jdd{|S7F7w)aDispatch a signal to all handlers that match the event Args: event (str): The event to dispatch context (Optional[Dict[str, Any]], optional): A dictionary of context to pass to the handlers. Defaults to `None`. condition (Optional[Dict[str, str]], optional): A dictionary of conditions to match against the handlers. Defaults to `None`. fail_not_found (bool, optional): Whether to raise an exception if no handlers are found. Defaults to `True`. inline (bool, optional): Whether to run the handlers inline. An inline run means it will return the value of the signal handler. When `False` (which is the default) the signal handler will run in a background task. Defaults to `False`. reverse (bool, optional): Whether to run the handlers in reverse order. Defaults to `False`. Returns: Union[asyncio.Task, Any]: If `inline` is `True` then the return value of the signal handler will be returned. If `inline` is `False` then an `asyncio.Task` will be returned. Raises: RuntimeError: If the signal is dispatched outside of an event loop )rrZrrzDispatching signal: rrrsNr)rorrrrNrO create_tasksleep) rUrYrrZrrrrtasks r7rzSignalRouter.dispatch s6!!%(>> )4f "   +E73K;KL !> !'')55h?mmA " s$ABB?BBBBc |j|}|j|\}}}tt|jj |}|sy|j dr|sd}t||||t|S)Nz.**)rCrErGrIrK) ro_get_event_partsrr? name_indexrendswithrBrJ) rUrYrZrKrErzrG_rCs r7 get_waiterzSignalRouter.get_waiter6s  ,,U3001ABgqfdoo11$78  $ $T *7G-"9o   r6c|j|}|djdr-djg|ddd}|j|d}n|}d}|sdjg|ddd}|||fS)N)_build_event_parts startswithjoin_clean_trigger)rUrYpartsrzrGs r7rzSignalRouter._get_event_partsLs''. 8  s #88.eCRj.#./D))%(3GDGHH:uRay:/:;EWe##r6r)priorityc |j|}|j|\}}} t | | ||d|} || j_|| j_|| j_|| j_ tt| S)NT)rzrSr) rorrgaddrQrKrGrrtrIrr?) rUr{rYrZrKrrErzrG event_stringrCrjs r7rzSignalRouter.addZs ,,U3&*&;&;z(Cannot declare reserved signal event: %s)rrclenrrrr)rUrYrs r7rzSignalRouter._build_event_partsseT^^4 J!OQx""3'Qx""3' :U BC C !H+ +0q::1X((-%(2C2CC2H:UB  r6c@|dd}d|vr|jd\}}|S)Nrr:)r)rUrGrs r7rzSignalRouter._clean_triggers+!B- '> s+JGQr6)returnNone)rYUnion[str, Enum]rrDr<)rYrrZrH)NNTF) rYrDrOptional[Dict[str, Any]]rZrHrrJrrJrr)rYrrrrZrHrrJrrJrrJrzUnion[asyncio.Task, Any])NT)rYrrZrrKrJrzOptional[SignalWaiter])rYrDrzTuple[str, str, str]) r{rrYrrZrrKrJrintrr?)TF)rrJrrJ)rGrDrrD)rrrrrh staticmethodrorrrrrrrrr __classcell__)rjs@r7r`r`sE  $/3/A/A,/Ah-1.2# ::*:, :  :  : :@-1.2#*** * , *  *** "*^/3   ,    , $$/3 $$$ $, $  $$ $6P2&r6r`)B __future__rrN collectionsr dataclassesrenumrinspectrtypingrr r r r r r sanic_routingrrrsanic_routing.exceptionsrsanic_routing.utilsrsanic.exceptionsr sanic.logrrsanic.models.handler_typesrrrrmrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4rrnr=r?rBr^r`r5r6r7rs "!@@@77--**4@D@< %%++ %%   && ##)) $$**  ""(( %%++ &&,, ##)) &&,, &&,, $$** %%++   && !!''   && !!'' !!'' ##)) $$** $ %%++ &&,, ))//3@4AUA ?? ?@F*Fe:er6