o NK&ht@sddlmZddlZddlZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZddlmZddlmZmZmZmZmZdd lmZdd lmZdd lmZmZdd l m!Z!dd l"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4m5Z5m6Z6ddl7m8Z8ddl9m:Z:m;Z;ddlm?Z?m@Z@mAZAddlBmCZCddlDmEZEmFZFddlGmHZHddlImJZJmKZKmLZLmMZMddlNmOZOddlPmQZQddlRmSZTddlRmUZUddlVmWZWdd lXmYZYdd!lZm[Z[dd"l\m]Z]dd#l^m_Z_dd$l`maZadd%lbmcZcdd&ldmeZemfZfdd'lgmhZhdd(limjZjdd)lkmlZldd*lmmnZndd+lompZpe%rQdd,lqmrZrdd-l3msZsdd.ltmuZud/Zve+eCe)d0e)d1fZwGd2d3d3e8d4ZxdS)5) annotationsN)AbstractEventLoopCancelledErrorProtocol all_tasksget_event_loopget_running_loopnew_event_loop)Mapping)suppresspartial) import_module)ManagerPipe get_contextget_start_methodset_start_method) BaseContext)Path) SHUT_RDWRsocket) SSLContext)sleep) TYPE_CHECKINGAnyCallableClassVarLiteralOptionalUnioncast) setup_ext)get_logo)MOTD)ApplicationServerInfoMode ServerStage) SanicMeta) OS_IS_WINDOWS StartMethod) ServerKilled)Default_defaultis_atty)HTTP)get_ssl_contextprocess_to_context)SanicSSLContext)Colors deprecation error_loggerlogger) setup_logging) ListenerType)Signal)try_use_uvloop) AsyncioServer)trigger_events) get_goodbye)try_windows_loop) HttpProtocol)WebSocketProtocol)serve)configure_socketremove_unix_socket) AppLoader) WorkerManager)WorkerMultiplexer)Reloader) worker_serve)Sanic)ApplicationState)Config)z sanic-routingz sanic-testingz sanic-extc@s\eZdZUded<ded<ded<ded<d ed <d ed <ded <ded<ded<eZded<dZded<dddZedddZ ddZ  dddde j ddddd d!dddddd!dd"dddd#ddFdGZ  dddde j ddddd d!dddddd!dd"dddddHddJdKZ  dddddd ddd!dddL ddQdRZdddUdVZddde j ddddded d!ddfddZd[Z ddd]d^Z ddd`daZeddbdcZe dddddeZee j dfddgdhZeddidjZeddkdlZeddmdnZeddpdqZe ddddrddydzZedd|d}Zeddd~dZ dddZ!dddZ"eddZ#eddZ$dS) StartupMixinzClassVar[dict[str, Sanic]] _app_registrystrnameboolasgirKconfigz"dict[str, list[ListenerType[Any]]] listenersrJstatewebsocket_enabledrF multiplexerzClassVar[bool] test_modezClassVar[StartMethod] start_methodFSTART_METHOD_SETreturnNonecCsD|js|jjdust|jjtrtstdStr tdSdSdS)zSet up the event loop. An internal method that sets up the event loop to uvloop if possible, or a Windows selector loop if on Windows. Returns: None TN)rSrT USE_UVLOOP isinstancer,r)r:r>selfrbG/var/www/html/venv/lib/python3.10/site-packages/sanic/mixins/startup.py setup_loopbs    zStartupMixin.setup_loopcCs|jS)aInterface for interacting with the worker processes This is a shortcut for `app.multiplexer`. It is available only in a worker process using the Sanic server. It allows you to interact with the worker processes, such as sending messages and commands. See [Access to the multiplexer](/en/guide/deployment/manager#access-to-the-multiplexer) for more information. Returns: WorkerMultiplexer: The worker multiplexer instance Examples: ```python app.m.restart() # restarts the worker app.m.terminate() # terminates the worker app.m.scale(4) # scales the number of workers to 4 ``` )rXr`rbrbrcmtszStartupMixin.mcOsd|j_|j|i|dS)u/ Try for yourself! `sanic server:app --coffee` ``` ▄████████▄ ██ ██▀▀▄ ███████████ █ ███████████▄▄▀ ▀███████▀ ``` TN)rVcoffeerun)raargskwargsrbrbrc make_coffees zStartupMixin.make_coffeeNrLdTr)devdebug auto_reloadversionsslsockworkersprotocolbacklogregister_sys_signals access_logunixloop reload_dirnoisy_exceptionsmotdfast verbosity motd_displayauto_tlssingle_processhost Optional[str]port Optional[int]rlrmrnOptional[bool]ro HTTPVersionrp/Union[None, SSLContext, dict, str, list, tuple]rqOptional[socket]rrintrsOptional[type[Protocol]]rtrurvrwrxOptional[AbstractEventLoop]ryOptional[Union[list[str], str]]rzr{r|r}r~Optional[dict[str, str]]rrcCs|jdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|d|d|d|d|d|d||rR|jj}n|jj}||ddS)al Run the HTTP Server and listen until keyboard interrupt or term signal. On termination, drain connections before closing. .. note:: When you need control over running the Sanic instance, this is the method to use. However, in most cases the preferred method is to use the CLI command: ```sh sanic server:app` ``` If you are using this method to run Sanic, make sure you do the following: 1. Use `if __name__ == "__main__"` to guard the code. 2. Do **NOT** define the app instance inside the `if` block. See [Dynamic Applications](/en/guide/deployment/app-loader) for more information about the second point. Args: host (Optional[str]): Address to host on. port (Optional[int]): Port to host on. dev (bool): Run the server in development mode. debug (bool): Enables debug output (slows server). auto_reload (Optional[bool]): Reload app whenever its source code is changed. Enabled by default in debug mode. version (HTTPVersion): HTTP Version. ssl (Union[None, SSLContext, dict, str, list, tuple]): SSLContext, or location of certificate and key for SSL encryption of worker(s). sock (Optional[socket]): Socket for the server to accept connections from. workers (int): Number of processes received before it is respected. protocol (Optional[Type[Protocol]]): Subclass of asyncio Protocol class. backlog (int): A number of unaccepted connections that the system will allow before refusing new connections. register_sys_signals (bool): Register SIG* events. access_log (Optional[bool]): Enables writing access logs (slows server). unix (Optional[str]): Unix socket to listen on instead of TCP port. loop (Optional[AbstractEventLoop]): AsyncIO event loop. reload_dir (Optional[Union[List[str], str]]): Directory to watch for code changes, if auto_reload is True. noisy_exceptions (Optional[bool]): Log exceptions that are normally considered to be quiet/silent. motd (bool): Display Message of the Day. fast (bool): Enable fast mode. verbosity (int): Verbosity level. motd_display (Optional[Dict[str, str]]): Customize Message of the Day display. auto_tls (bool): Enable automatic TLS certificate handling. single_process (bool): Enable single process mode. Returns: None Raises: RuntimeError: Raised when attempting to serve HTTP/3 as a secondary server. RuntimeError: Raised when attempting to use both `fast` and `workers`. RuntimeError: Raised when attempting to use `single_process` with `fast`, `workers`, or `auto_reload`. TypeError: Raised when attempting to use `loop` with `create_server`. ValueError: Raised when `PROXIES_COUNT` is negative. Examples: ```python from sanic import Sanic, Request, json app = Sanic("TestApp") @app.get("/") async def handler(request: Request): return json({"foo": "bar"}) if __name__ == "__main__": app.run(port=9999, dev=True) ``` rrrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rr)primaryNrb)prepare __class__ serve_singlerA)rarrrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrArbrbrcrgsf b      zStartupMixin.run)rlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rfrrrfcCs|dkr |jjr td|rd}d}|r| durd} ||j_|jjs(t||j_|r2| dkr2td|r@|s<| dks<|r@td| durJ|sJtd |rS|jj||r|t |t r]|g}|D]}t |}| srt d |d |jjt |q_|durtd |dur|||||\}}| dur|jrtnt} | |||d D]\}}|durt|j||q|rd|j_z ttd} Wntytpd} Ynw|rd|j_|j|||||||| | | | |d }|jj t!|ddS)a{ Prepares one or more Sanic applications to be served simultaneously. This low-level API is typically used when you need to run multiple Sanic applications at the same time. Once prepared, `Sanic.serve()` should be called in the `if __name__ == "__main__"` block. .. note:: "Preparing" and "serving" with this function is equivalent to using `app.run` for a single instance. This should only be used when running multiple applications at the same time. Args: host (Optional[str], optional): Hostname to listen on. Defaults to `None`. port (Optional[int], optional): Port to listen on. Defaults to `None`. dev (bool, optional): Development mode. Defaults to `False`. debug (bool, optional): Debug mode. Defaults to `False`. auto_reload (Optional[bool], optional): Auto reload feature. Defaults to `None`. version (HTTPVersion, optional): HTTP version to use. Defaults to `HTTP.VERSION_1`. ssl (Union[None, SSLContext, dict, str, list, tuple], optional): SSL configuration. Defaults to `None`. sock (Optional[socket], optional): Socket to bind to. Defaults to `None`. workers (int, optional): Number of worker processes. Defaults to `1`. protocol (Optional[Type[Protocol]], optional): Custom protocol class. Defaults to `None`. backlog (int, optional): Maximum number of pending connections. Defaults to `100`. register_sys_signals (bool, optional): Register system signals. Defaults to `True`. access_log (Optional[bool], optional): Access log. Defaults to `None`. unix (Optional[str], optional): Unix socket. Defaults to `None`. loop (Optional[AbstractEventLoop], optional): Event loop. Defaults to `None`. reload_dir (Optional[Union[List[str], str]], optional): Reload directory. Defaults to `None`. noisy_exceptions (Optional[bool], optional): Display exceptions. Defaults to `None`. motd (bool, optional): Display message of the day. Defaults to `True`. fast (bool, optional): Fast mode. Defaults to `False`. verbosity (int, optional): Verbosity level. Defaults to `0`. motd_display (Optional[Dict[str, str]], optional): Custom MOTD display. Defaults to `None`. coffee (bool, optional): Coffee mode. Defaults to `False`. auto_tls (bool, optional): Auto TLS. Defaults to `False`. single_process (bool, optional): Single process mode. Defaults to `False`. Raises: RuntimeError: Raised when attempting to serve HTTP/3 as a secondary server. RuntimeError: Raised when attempting to use both `fast` and `workers`. RuntimeError: Raised when attempting to use `single_process` with `fast`, `workers`, or `auto_reload`. TypeError: Raised when attempting to use `loop` with `create_server`. ValueError: Raised when `PROXIES_COUNT` is negative. Examples: ```python if __name__ == "__main__": app.prepare() app.serve() ``` rMzServing HTTP/3 instances as a secondary server is not supported. There can only be a single HTTP/3 worker and it must be the first instance prepared.TNrLz+You cannot use both fast=True and workers=XzASingle process cannot be run with multiple workers or auto-reloadFzOCannot run Sanic.serve with register_sys_signals=False. Use Sanic.serve_single.z Directory z could not be locatedzloop is not a valid argument. To use an existing loop, change to create_server(). See more: https://sanic.readthedocs.io/en/latest/sanic/deploying.html#asynchronous-support) ACCESS_LOG AUTO_RELOADr$NOISY_EXCEPTIONSr) rrrmrorprqrwrrrsrtrur)settings)"rV server_info RuntimeErrorr}rnrRrT MOTD_DISPLAYupdater_rPris_dirr6warning reload_dirsadd TypeError get_addressrWr@r?itemssetattrr|lenossched_getaffinityAttributeError cpu_countrf_helperappendr%)rarrrlrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rfrr directorydirec attributevalueserver_settingsrbrbrcrsK         zStartupMixin.prepare) rmrprqrsrtrvrwreturn_asyncio_serverasyncio_server_kwargsrzrrOptional[dict[str, Any]]Optional[AsyncioServer]c  s|dur|||\}}\}}|dur|jrtnt}|| dD]\} }|dur2t|j| |q#| ssz(StartupMixin._helper..Tr)(rT PROXIES_COUNT ValueErrorrVis_debugr&DEBUG PRODUCTIONmoder7NO_COLORr_rr/r1 VERSION_3rr!rIr0rrrrrprwrq ServerSignalr{r.renvirongetr5rr3YELLOWENDrUcopyreverse)rarrrmrorprqrwrrrxrsrtrurrr event_name settings_namerrUrbr`rcrxsl        zStartupMixin._helperrcCsztjdstjdstjdstjdrdS||}|jjr;t|jjd}| |\}}t ||||dSdS)abOutputs the message of the day (MOTD). It generally can only be called once per process, and is usually called by the `run` method in the main process. Args: server_settings (Optional[Dict[str, Any]], optional): Settings for the server. Defaults to `None`. Returns: None SANIC_WORKER_NAMESANIC_MOTD_OUTPUTSANIC_WORKER_PROCESSSANIC_SERVER_RUNNINGN)rf) rrrget_server_locationrTr$r#rVrf get_motd_dataoutput)rarserve_locationlogodisplayextrarbrbrcr{s     zStartupMixin.motd%tuple[dict[str, Any], dict[str, Any]]c Csr|jjdg}|jjr|d|jjr|dn|jjdkr'|dn |d|jjd|rBd|jj|d f}n|jrGdnd }|j d ||t t d }i}|j j rzd }|jjrv|ddgdd|jjD7}||d<g}tD]"}|dd} zt| } ||d| jWq~tyYq~w|rd||d<|j jr||j j||fS)aZRetrieves the message of the day (MOTD) data. Args: server_settings (Optional[Dict[str, Any]], optional): Settings for the server. Defaults to `None`. Returns: Tuple[Dict[str, Any], Dict[str, Any]]: A tuple containing two dictionaries with the relevant MOTD data. ,z goin' fastASGIrLz single workerzw/ z workersz, rounknown )rrserverpythonplatformenabledrcss|] }t|VqdSN)rPabsolute)rpathrbrbrc "s  z-StartupMixin.get_motd_data..z auto-reload-_z==packages)rVrr|rrSrrjoinrrrQrpython_versionrTrrSANIC_PACKAGESreplacer __version__ ImportErrorrr) rarrrrrreload_displayr package_name module_namemodulerbrbrcrs`        zStartupMixin.get_motd_datacCsHz |jjdj}||WSty#|jrdnd}d|dYSw)z^Retrieve the server location. Returns: str: The server location. rrrzhttp://<>)rVrrr IndexErrorrS)rarlocationrbrbrcr;s  zStartupMixin.serve_locationcCsd}d}|s|S|d}|d}|ddurd}|dr)|dd |d }n|d r7|d ^}}}|sS|rS|rSd |vrGd |dn|}|d|d |}|S)aUsing the server settings, retrieve the server location. Args: server_settings (Optional[Dict[str, Any]], optional): Settings for the server. Defaults to `None`. Returns: str: The server location. rhttprrrpNhttpsrwrz://...rq:[]z://)r getsockname)rrprotorrr display_hostrbrbrcrIs     z StartupMixin.get_server_locationtuple[str, int]cCs(|pd}|p|dks |rdnd}||fS)aKRetrieve the host address and port, with default values based on the given parameters. Args: host (Optional[str]): Host IP or FQDN for the service to use. Defaults to `"127.0.0.1"`. port (Optional[int]): Port number. Defaults to `8443` if version is 3 or `auto_tls=True`, else `8000` version (HTTPVersion, optional): HTTP Version. Defaults to `HTTP.VERSION_1` (HTTP/1.1). auto_tls (bool, optional): Automatic TLS flag. Defaults to `False`. Returns: Tuple[str, int]: Tuple containing the host and port z 127.0.0.1rMi i@rb)rrrorrbrbrcrlszStartupMixin.get_addresscCstdd|jDS)zCheck if any applications have auto-reload enabled. Returns: bool: `True` if any applications have auto-reload enabled, else `False`. cs|]}|jjVqdSr)rVrnrrrbrbrcrz2StartupMixin.should_auto_reload..)anyrOvaluesclsrbrbrcshould_auto_reloadszStartupMixin.should_auto_reloadcCst|jts |jSdS)Nspawn)r_rZr,rrbrbrc_get_startup_methods z StartupMixin._get_startup_methodc Cst|jr|jsdS|}z t||jdWnty4t}|}||kr3td|d|ddwd|_dS)N)forceStart method '' was requested, but '' was already set. For more information, see: https://sanic.dev/en/guide/running/manager.html#overcoming-a-coderuntimeerrorcodeT)r[rYrrrrr)rmethodctxactualrbrbrc_set_startup_methods"   z StartupMixin._set_startup_methodrcCs@|}td|t}||krtd|d|ddtS)Nz+Creating multiprocessing context using '%s'rrr)rr6rmrrr)rr r"rbrbrc _get_contexts zStartupMixin._get_context) app_loaderfactoryrOptional[Sanic]r%Optional[AppLoader]r&Optional[Callable[[], Sanic]]c!Cs|dtjd<t|j}|r|}n.|s3|r|}|s3z|d}Wn ty2tddw|j j sD|D]}|j j q9dSz|j j d}Wnty]td|j ddwg}t }dd i} t|d} zz\|jd d|jd d|jd } |jd } |jd}|t} t| | |dddd|DD}d|jd<td\}}|} i|j|| d}|s|rt|d}n tt|j|j d}|j |d<||d<i|d<|j|j j|j jd|jj|jj d|j!j"d|d<|D]'}g|d|j <|j j D]}dd|j#D|_|d|j $|q q|d}t%|t&r8|j'|d<t(|j j)t*||+||f| }|,rh|j j-j.d d!|D}t/|d||}|j0d"|id#d$d}|jj1r|2\}}d%d|d&3d'D}t4d(}d)|j5}i||g||d*}|6||| |jj7|jj8|jj9|jj:|jj;}|j0d+|id#d$||_<||_=|jd,}t|| ||>Wnt?yd-} Ynt@y|j}tABd.wWtCDd/|D]}|j j |jEF|jGFq|D]}z|HtIWn tJyYnw|Kqg}t| | || K|L|Md0}|N| rVtOd1|d-8}|dkrPtAPd2n|N| s=|H|d3} | rftQ| tCRtSntCDd/|D]}|j j |jEF|jGFqt|D]}z|HtIWn tJyYnw|Kqg}t| | || K|L|Md0}|N| rtOd1|d-8}|dkrtAPd2n|N| s|H|d3} | rtQ| tCRtSw| rtT| dSdS)4a&Serve one or more Sanic applications. This is the main entry point for running Sanic applications. It should be called in the `if __name__ == "__main__"` block. Args: primary (Optional[Sanic], optional): The primary Sanic application to serve. Defaults to `None`. app_loader (Optional[AppLoader], optional): An AppLoader instance to use for loading applications. Defaults to `None`. factory (Optional[Callable[[], Sanic]], optional): A factory function to use for loading applications. Defaults to `None`. Raises: RuntimeError: Raised when no applications are found. RuntimeError: Raised when no server information is found for the primary application. RuntimeError: Raised when attempting to use `loop` with `create_server`. RuntimeError: Raised when attempting to use `single_process` with `fast`, `workers`, or `auto_reload`. RuntimeError: Raised when attempting to serve HTTP/3 as a secondary server. RuntimeError: Raised when attempting to use both `fast` and `workers`. TypeError: Raised when attempting to use `loop` with `create_server`. ValueError: Raised when `PROXIES_COUNT` is negative. Examples: ```python if __name__ == "__main__": app.prepare() Sanic.serve() ``` truerrDid not find any applications.Nz No server information found for z+. Perhaps you need to run app.prepare(...)?rVNONErrrrrcSsg|]}|r|qSrbrb)rrqrbrbrcrs z&StartupMixin.serve..cSs$g|]}|jjD]}t|jqqSrb)rVrrBr)rrrrbrbrcrsT run_multiple)monitor_publisher worker_state)r&app_namer%r)r}rr)rnrVrT shared_ctxpassthrucSi|] \}}|dvr||qS))rrrrprbrkvrbrbrc ; z&StartupMixin.serve..rpcsrr)rVrrrbrbrcrQrz%StartupMixin.serve..rGF) transientcSsg|]}|qSrb)strip)rpkgrbrbrcrYsrrsaniczsanic==)rr Inspectormain_process_readyrL+Experienced exception while trying to serveServer Stoppedrkg?z?Worker shutdown timed out. Some processes may still be running.rw)Ur#rrlistrOrloadrrrVrclearrQrr"rrrUrrdr r<rdictrDr get_apprnr}rrTrrr1__dict__rrr_r2r<rErrrHr$rrunionrGmanage INSPECTORrsplitrrinspector_classINSPECTOR_HOSTINSPECTOR_PORTINSPECTOR_API_KEYINSPECTOR_TLS_KEYINSPECTOR_TLS_CERT _inspector_managerrgr+ BaseExceptionr5 exceptionr6inforouterreset signal_routershutdownrOSErrorclose_cleanup_env_vars _cleanup_apps_get_process_statesrrrCrmr=_exit)!rrr%r&appsrprimary_server_infosocks sync_managerr/ exit_coderrrx monitor_sub monitor_pubrirrpmanagerrreloader inspectorrrrr sanic_versionapp_inforeadyrqlimitrwrbrbrcrAs,                                               zStartupMixin.serve list[str]csfdd|DS)Ncs&g|]}|drdvrqS)rV) TERMINATEDFAILED COMPLETEDr,)r)rsrVrbrcrs z4StartupMixin._get_process_states..)r)r/rbrsrcr^s z StartupMixin._get_process_statesc Csdtjd<t|j}|s z|d}Wn tytdw|jjs1|D]}|jj q&dS|jjd}| t |j |ddd|j D}|j|d <d|d <t|}i|d <g|d |j<|jjD]}d d|j D|_ |d |j|qgzDz tdd di|Wn tytdwWtd|D]}|jj |j|jq|r|||dStd|D]}|jj |j|jq|r|||w)aServe a single process of a Sanic application. Similar to `serve`, but only serves a single process. When used, certain features are disabled, such as `fast`, `workers`, `multiplexer`, `auto_reload`, and the Inspector. It is almost never needed to use this method directly. Instead, you should use the CLI: ```sh sanic app.sanic:app --single-process ``` Or, if you need to do it programmatically, you should use the `single_process` argument of `run`: ```python app.run(single_process=True) ``` Args: primary (Optional[Sanic], optional): The primary Sanic application to serve. Defaults to `None`. Raises: RuntimeError: Raised when no applications are found. RuntimeError: Raised when no server information is found for the primary application. RuntimeError: Raised when attempting to serve HTTP/3 as a secondary server. RuntimeError: Raised when attempting to use both `fast` and `workers`. ValueError: Raised when `PROXIES_COUNT` is negative. r*rrr+N)r`cSr3)rrrrbr4rbrbrcr7sz-StartupMixin.serve_single..r0r%rcSr3rtrbr4rbrbrcr7r8r.r?r@rb)rrrArOrrrrVrrCbefore_server_startr _start_serversrrrQrBrrHrSr5rTr6rUrVrWrXr[r\r])rrr`rrarirqrrbrbrcrsl #                zStartupMixin.serve_singlerIr` list[Sanic]c s|D]}|j|jurB|jj|jjkrB|jjrBdt|d|jjdt|d|jjd }tr;dtj|tj g}t j |dd|jjD]}|j t jurd |j_g|jd g|jd g}|rst d t|d t||jds~t|jd<i|jdt|jjdd}d|vr||d<z tdi|IdH|_Wn6ty} z*d} t| } trtj| tj| tj g} n| | g} d| }t j |ddWYd} ~ qFd} ~ ww|j|||ddqFqdS)NzThe primary application z is running with zS worker(s). All application instances will run with the same number. You requested z to run with zF worker(s), which will be ignored in favor of the primary application.rT)exc_infoFrrz Sanic found z listener(s) on secondary applications attached to the main process. These will be ignored since main process listeners can only be attached to your primary application: rxrL)r reuse_portrz?An OSError was detected on startup. The encountered error was: r)rQrb)rQrVrrrreprr.rr3rrr5rrr'SERVINGrrrrrrRrArrZrPREDadd_task _run_server) rarrr`rmessagerhandlers serve_argse first_messagesecond_message message_partsrbrbrcrvs           zStartupMixin._start_serversrrr%cszqz4|js td|jjtjur-tj|_|jIdH|jIdH|j IdH|j IdHWn(t y^|jsDtd|j IdH|j IdH|jIdHYn wWtj|_d|_dSWtj|_d|_dStj|_d|_w)NzCould not locate AsyncioServer)rrrVrr'rr{startup before_start after_start serve_foreverr before_stopr[ after_stop)rarrrbrbrcr~as2   zStartupMixin._run_serverc Cs0d}|D]}ztj|=WqtyYqwdS)N)SANIC_RELOADER_PROCESSrrrrr)rrKeyError) variablesvarrbrbrcr\}s  zStartupMixin._cleanup_env_varscCs4|jD]}|jj|j|jqdSr)rOrrVrrCrVrWrX)rrrbrbrcr]s    zStartupMixin._cleanup_apps)r\r])r\rF)NN)0rrrrrlrRrmrRrnrrorrprrqrrrrrsrrtrrurRrvrrwrrxrryrrzrr{rRr|rRr}rr~rrrRrrRr\r])2rrrrrlrRrmrRrnrrorrprrqrrrrrsrrtrrurRrvrrwrrxrryrrzrr{rRr|rRr}rr~rrfrRrrRrrRr\r])rrrrrmrRrprrqrrsrrtrrvrrwrrrRrrrzrr\r)TF)rrRrrRr\r])rrrrrmrRrorrprrqrrwrrrrrxrrsrrtrrurRrrRrrRr\rr)rrr\r])rrr\r)r\rP)rrr\rP) rrrrrorrrRr\r)r\rR)r\r)rr'r%r(r&r)r\r])r\rn)rr'r\r])rrIr`rwr\r])rrNrr%r\r])%__name__ __module__ __qualname____annotations__r-rZr[rdpropertyrerjr/ VERSION_1rgrrrr?rr{rr staticmethodrr classmethodrrr#r$rAr^rrvr~r\r]rbrbrbrcrNTs     9  ]  J  "     o   _ Q rN) metaclass)y __future__rrrasynciorrrrrrr collections.abcr contextlibr functoolsr importlibrmultiprocessingrrrrrmultiprocessing.contextrpathlibrrrrprtimertypingrrrrrrr r!sanic.application.extr"sanic.application.logor#sanic.application.motdr$sanic.application.stater%r&r'sanic.base.metar( sanic.compatr)r*sanic.exceptionsr+ sanic.helpersr,r-r.sanic.http.constantsr/sanic.http.tlsr0r1sanic.http.tls.contextr2 sanic.logr3r4r5r6sanic.logging.setupr7sanic.models.handler_typesr8 sanic.serverr9rr:sanic.server.async_serverr;sanic.server.eventsr<sanic.server.goodbyer=sanic.server.loopr>$sanic.server.protocols.http_protocolr?)sanic.server.protocols.websocket_protocolr@sanic.server.runnersrAsanic.server.socketrBrCsanic.worker.loaderrDsanic.worker.managerrEsanic.worker.multiplexerrFsanic.worker.reloaderrGsanic.worker.serverHr<rIrJ sanic.configrKrrrNrbrbrbrcsf $       (