o NK&h9@sddlmZddlZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZddlmZmZmZdd lmZdd lmZdd lmZdd lmZmZdd lmZGdddeZej j!ej"j!ej#j!ej$j!ej%j!fej&j!ej'j!ej(j!ej)j!ej*j!ej+j!ej,j!ej-j!ej.j!ej/j!ej0j!ej1j!ej2j!ej3j!ej4j!fej5j!ej6j!ej7j!hdZ8dZ9ddZ:GdddeZ;eGdddZdS)) annotationsN)deque) dataclass)Enum) isawaitable)AnyOptionalUnioncast) BaseRouterRoute RouteGroup)NotFound) path_to_parts) InvalidSignal) error_loggerlogger) SignalHandlerc@sleZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdS)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_EXCEPTIONr0r0@/var/www/html/venv/lib/python3.10/site-packages/sanic/signals.pyrs2r)serverhttp websocketz__generic__.__signal__.%scCsdSNr0r0r0r0r1_blankSsr6c@eZdZdZdS)Signalz6A `Route` that is used to dispatch signals to handlersNrrrrr0r0r0r1r8Vr8c@sbeZdZUdZded<ded<dZded<dZd ed <d Zd ed <dZded<ddZ ddZ dS) SignalWaiterz3A record representing a future waiting for a signalr8signalstrevent_definitiontriggerNOptional[dict[str, str]] requirementsTbool exclusivezOptional[asyncio.Future]futurec sVt}||_|jjj|z|jIdHW|jjj|S|jjj|w)zoBlock until the signal is next dispatched. Return the context of the signal dispatch, if any. N) asyncioget_running_loop create_futurerEr<ctxwaitersappendremove)selfloopr0r0r1waitfs  $zSignalWaiter.waitcCs:|dur|j p|duo|j p||jko|jp||jkSr5)rDrBr@r>)rMevent conditionr0r0r1matchessszSignalWaiter.matches) rrrr__annotations__r@rBrDrErOrRr0r0r0r1r;Zs      r;c@r7) SignalGroupz;A `RouteGroup` that is used to dispatch signals to handlersNr9r0r0r0r1rT{r:rTcseZdZdZd8fdd Zed9d d Z d:d;ddZ  dddZ d?d@d!d"Z dAd$d%Z d?d&d'dBfd-d.Z dCdDfd1d2 Z dAd3d4ZdEd6d7ZZS)F SignalRouterz;A `BaseRouter` that is used to dispatch signals to handlersreturnNonecs&tjdttddd|_d|j_dS)N.T) delimiter route_class group_classstacking)super__init__r8rTallow_fail_builtinrIrN)rM __class__r0r1r^s zSignalRouter.__init__rPUnion[str, Enum]r=cCs(t|tr t|j}d|vrt|}|S)zEnsure event strings in proper format Args: event (str): event string Returns: str: formatted event string rX) isinstancerr=valueGENERIC_SIGNAL_FORMAT)rPr0r0r1 format_events zSignalRouter.format_eventNrQrAcs||}|pi}z|jd||j|iid|d\}Wnty=d}|g}|r5|d7}||t|t|wd}|sPfdd|jD}|d d |D|fS) 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 rX) __params__ __matches__extrazCould not find signal %sz with %srgcs i|] \}}|jd|qS)rh)name).0idxparam param_basketr0r1 sz$SignalRouter.get..cSsg|]}|jqSr0)handler)rlrouter0r0r1 sz$SignalRouter.get..)rf find_routeDEFAULT_METHODrrKtupleparamsitems)rMrPrQrjgroupmessagetermsrxr0ror1gets0     zSignalRouter.getTFcontextOptional[dict[str, Any]]fail_not_foundrCreverserc s ||}z |j||d\}}}Wn:tyL} z.|dddtv} |r-| r+|jr-| |jjjrA|jjj j dkrAt t | WYd} ~ dSd} ~ ww|rT|||dd|j} |sf| ddd} zd| D]} | jjD]} | ||r| jt|qoqi| D]D} | jj}|dur| jjdus|dur|r||kr| jjs|| jjkr| jd i|}t|r|IdH}|r|WSq|r|WSqWdSty} z.|jjjr|jjj j dkrt | |tj j!kr|j"tj j!d| id IdHt#| d d | d} ~ ww) N)rQrXr __trigger__F exception)r~__dispatched__Tr0)$rfr}rsplitRESERVED_NAMESPACESr_rIappdebugstate verbosityrwarningr=updatepoproutesrJrRrE set_resultdictrjrBrDr@ definitionrrr Exceptionrrrrddispatchsetattr)rMrPr~rQrrrzhandlersrxe is_reservedsignalsr<waiterrBmaybe_coroutineretvalr0r0r1 _dispatchsp             zSignalRouter._dispatch)r~rQrinlinerrUnion[asyncio.Task, Any]c sl||}|j||||o||d}tjd|ddid|r%|IdHSt|}tdIdH|S)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 )r~rQrrzDispatching signal: rrriNr)rfrrrrFrG create_tasksleep) rMrPr~rQrrrrtaskr0r0r1r s  zSignalRouter.dispatchrDOptional[SignalWaiter]c Cs\||}||\}}}tt|j|}|sdS|dr#|s#d}t||||t|dS)Nz.**)r<r>r@rBrD) rf_get_event_partsr r8 name_indexr}endswithr;rC) rMrPrQrDr>rkr@_r<r0r0r1 get_waiter5s zSignalRouter.get_waitertuple[str, str, str]cCsr||}|ddr!dg|ddd}||d}n|}d}|s4dg|ddd}|||fS)N)_build_event_parts startswithjoin_clean_trigger)rMrPpartsrkr@r0r0r1rKs  zSignalRouter._get_event_partsr)priorityrrrrintr8c sZ||}||\}}} tj| ||d|d} || j_|| j_|| j_|| j_ t t | S)NT)rkrKr) rfrr]addrIrDr@rrjrBr r8) rMrrrPrQrDrr>rkr@ event_stringr<r`r0r1rYs  zSignalRouter.add do_compile do_optimizecsZ|tdzt|j_Wn tytdw|jD]}t|j_ qt j ||dS)aFinalize the router and compile the routes Args: do_compile (bool, optional): Whether to compile the routes. Defaults to `True`. do_optimize (bool, optional): Whether to optimize the routes. Defaults to `False`. Returns: SignalRouter: The router Raises: RuntimeError: If the router is finalized outside of an event loop zsanic.__signal__.__init__z-Cannot finalize signals outside of event loop)rr) rr6rFrGrIrN RuntimeErrorrrrJr]finalize)rMrrr<r`r0r1rts    zSignalRouter.finalizecCst||j}t|dks|dds|ddr td||dtvrB|t|dvrB|ddr<|ddsBtd||S) NrrrzInvalid signal event: %sr>z(Cannot declare reserved signal event: %s)rrYlenrrrr)rMrPrr0r0r1rs"        zSignalRouter._build_event_partsr@cCs&|dd}d|vr|d\}}|S)Nrr:)r)rMr@rr0r0r1rs zSignalRouter._clean_trigger)rVrW)rPrbrVr=r5)rPrbrQrA)NNTF) rPr=r~rrQrArrCrrCrVr)rPrbr~rrQrArrCrrCrrCrVr)NT)rPrbrQrrDrCrVr)rPr=rVr) rrrrPrbrQrrDrCrrrVr8)TF)rrCrrC)r@r=rVr=)rrrrr^ staticmethodrfr}rrrrrrrr __classcell__r0r0r`r1rUs<  4 @/  rU)? __future__rrF collectionsr dataclassesrenumrinspectrtypingrrr r sanic_routingr r r sanic_routing.exceptionsrsanic_routing.utilsrsanic.exceptionsr sanic.logrrsanic.models.handler_typesrrrrdrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/rrer6r8r;rTrUr0r0r0r1s`