a 0hE<@sUddlmZddlZddlZddlZddlZddlZddlZddlZ ddl m Z ddl m Z ddlmZeejejhZheejejZeedreejeeZ[hdZd d d d Zd d ddddZd d ddddZd d ddddZdddddZdd ddZ GdddZ!Gd d!d!e!Z"Gd"d#d#e!Z#e"e#d$Z$d%e%d&<z e&d'Wn e'ye$d(e$d)<Yn0e$d*e$d)<dd d+d,Z(d4d-d.d.d/d0dd1d2d3Z)dS)5) annotationsN)chain)PurePath)_log real_prefix>z .pytest_cache __pycache__z .mypy_cachez.gitz.hgz.toxz.noxzt.Iterator[str]returnccsfttjD]R}t|dd}|dus|tr2qtj |sZ|}tj |}||kr2qq2|VqdS)z;Find the filesystem paths associated with imported modules.__file__N) listsysmodulesvaluesgetattr startswith_ignore_alwaysospathisfiledirname)modulenameoldr@/var/www/auris/lib/python3.9/site-packages/werkzeug/_reloader.py_iter_module_paths(s   rzset[str]None)pathsexclude_patternsr cCs |D]}|t||qdSN)difference_updatefnmatchfilter)rrpatternrrr_remove_by_pattern<sr%zt.Iterable[str]) extra_filesrr c Cst}tttj|D]}tj|}tj|r>||qtj |di}t |D]\}}}| t s|tj |tvr|qXd}|D]&} | drd}|tj|| q|s|tj |s|qX|||<qXq|tt|||S)axFind paths for the stat reloader to watch. Returns imported module files, Python files under non-system paths. Extra files and Python files under extra directories can also be scanned. System paths have to be excluded for efficiency. Non-system paths, such as a project root or ``sys.path.insert``, should be the paths of interest to the user anyway. TF)z.pyz.pyc)setrr r rrabspathraddrwalkr_stat_ignore_scanbasename_ignore_common_dirsclearendswithjoinupdaterr%) r&rrrZ parent_has_pyrootdirsfilesZhas_pyrrrr_find_stat_pathsAs4        r5cCszt}tttj|D]2}tj|}tj|r>tj|}| |qt D]}| tj|qPt ||t |S)zFind paths for the stat reloader to watch. Looks at the same sources as the stat reloader, but watches everything under directories instead of individual files. ) r'rr r rrr(rrr)rr%_find_common_roots)r&rr3rrrr_find_watchdog_pathsws      r7)rr cspi}tdd|DtddD]&}|}|D]}||i}q(|qtddddfd d |d S) Ncss|]}t|jVqdSr )rparts.0xrrr z%_find_common_roots..T)keyreversez t.Mapping[str, dict[str, t.Any]]ztuple[str, ...]r)noderr cs@|D]\}}|||fq|s<|r<tjj|dSr )itemsr)rrr0)r@rprefixchild_walkrvrrrEsz!_find_common_roots.._walkr)sortedlen setdefaultr.r')rr2chunksr@chunkrrDrr6s  r6z list[str]cCstjdkr tjgtjddStjg}tjd}tjdd}tjd}t|dddustjdkr|j dkrtj |stj |d rtj |}tjdkr tj |stj |d r|d 7}tj tjdd kr tj |dd kr |d||nftj |rdtt|j }tj tj |d}|dkrh|d |7}n|}|d |d f|||S) zpDetermine how the script was executed, and return the args needed to execute it again in a new process. ) rNr__main__ __package__ntz.exe.z-m)r version_info executableZ orig_argvargvrrrrrOrexistsr(splitextpopappendrtcaststrr,extendlstrip)rFZ py_scriptargsrNZ py_modulerrrr_get_args_for_reloadingsD          r`c@seZdZdZdddddddd Zdd d d Zd dZdd ddZdd ddZdd ddZ dddddZ dddddZ dS) ReloaderLooprQNrt.Iterable[str] | None int | floatr)r&rintervalr cCs,dd|p dD|_t|pd|_||_dS)NcSsh|]}tj|qSr)rrr(r9rrr r=z(ReloaderLoop.__init__..r)r&r'rrd)selfr&rrdrrr__init__szReloaderLoop.__init__r cCs ||S)zgDo any setup, then run one step of the watch to populate the initial filesystem state. )run_steprfrrr __enter__szReloaderLoop.__enter__cCsdS)z4Clean up any resources associated with the reloader.Nrrfexc_typeexc_valexc_tbrrr__exit__szReloaderLoop.__exit__cCs|t|jqdS)zfContinually run the watch step, sleeping for the configured interval after each step. N)rhtimesleeprdrirrrrunszReloaderLoop.runcCsdS)z}Run one step for watching the filesystem. Called once to set up initial state, then repeatedly to update it. NrrirrrrhszReloaderLoop.run_stepintcCsLtdd|jt}tj}d|d<tj||dd}|dkr|SqdS) z|Spawn a new Python interpreter with the same arguments as the current one, but running the reloader thread. infoz * Restarting with trueWERKZEUG_RUN_MAINF)env close_fdsrLN)rrr`renvironcopy subprocesscall)rfr_Z new_environZ exit_coderrrrestart_with_reloader s z"ReloaderLoop.restart_with_reloaderr\filenamer cCs||tddSNrL) log_reloadr exitrfrrrrtrigger_reloads zReloaderLoop.trigger_reload str | bytescCs"tj|}tdd|ddS)Nrtz * Detected change in z , reloading)rrr(rrrrrrs zReloaderLoop.log_reload)NNr) __name__ __module__ __qualname__rrgrjrorrrhr}rrrrrrras racs4eZdZdZddfdd ZddddZZS) StatReloaderLoopstatrar csi|_tSr )mtimessuperrjri __class__rrrj$szStatReloaderLoop.__enter__rc Csrt|j|jD]^}zt|j}Wnty8YqYn0|j|}|durZ||j|<q||kr| |qdSr ) r5r&rrrst_mtimeOSErrorrgetr)rfrmtimeZold_timerrrrh(s    zStatReloaderLoop.run_step)rrrrrjrh __classcell__rrrrr!srcsleZdZddddfdd Zddddd Zd d fd d ZddZdd ddZdd ddZZ S)WatchdogReloaderLoopzt.Anyr)r_kwargsr csddlmddlmddlmddlmddlmddlmddlm}dd lm }t j |i||j Gfd d d |}|j }|d r|dd }d|d|_||_dd|jD}|dddg|gddtD|jd|_d|_dS)Nr)EVENT_TYPE_CLOSED)EVENT_TYPE_CREATED)EVENT_TYPE_DELETED)EVENT_TYPE_MODIFIED)EVENT_TYPE_MOVED)FileModifiedEvent)PatternMatchingEventHandler)Observercs(eZdZddfdd ZdS)z3WatchdogReloaderLoop.__init__..EventHandlerr)eventcs&|jhvrdS|jdSr )Z event_typeZsrc_path)rfr)rrrrrrrr on_any_eventHsz@WatchdogReloaderLoop.__init__..EventHandler.on_any_eventN)rrrrrrrrrrrrrr EventHandlerGsrobserveriz watchdog ()cSsg|]}tj|s|qSr)rrisdir)r:prrr ar=z1WatchdogReloaderLoop.__init__..z*.pyz*.pycz*.zipcSsg|]}d|dqS)z*/z/*r)r:drrrrer=)patternsignore_patternsF)Zwatchdog.eventsrrrrrrrZwatchdog.observersrrrgrrlowerr/rrr&r-r event_handler should_reload)rfr_rrrrZ reloader_nameZextra_patternsrrrrg:s4              zWatchdogReloaderLoop.__init__rr~cCsd|_||dS)NT)rrrrrrrksz#WatchdogReloaderLoop.trigger_reloadrar csi|_|jtSr )watchesrstartrrjrirrrrjrs zWatchdogReloaderLoop.__enter__cCs|j|jdSr )rstopr0rkrrrrows zWatchdogReloaderLoop.__exit__cCs*|js|t|jqtddSr)rrhrprqrdr rrirrrrr{szWatchdogReloaderLoop.runc Cst|j}t|j|jD]T}||jvrbz|jj|j|dd|j|<Wnty`d|j|<Yn0| |q|D]&}|j |d}|durr|j |qrdS)NT) recursive) r'rr7r&rrZschedulerrdiscardrXZ unschedule)rfZ to_deleterZwatchrrrrhs    zWatchdogReloaderLoop.run_step) rrrrgrrjrorrrhrrrrrr9s 1r)rwatchdogzdict[str, type[ReloaderLoop]]reloader_loopszwatchdog.observersrautorcCs|tjdustjsdSz ddl}Wnty8YdS0|tj}|d|j@sx|d|jO<|tj|j|dS)zuEnsure that echo mode is enabled. Some tools such as PDB disable it which causes usability issues after a reload.NrrL) r stdinisattytermios ImportError tcgetattrECHO tcsetattrTCSANOW)r attributesrrrensure_echo_ons   rzt.Callable[[], None]rbrcr\) main_funcr&rrd reloader_typer cCsddl}||jddt||||d}zrtjddkrttj|dd }d |_ | | | Wdq1s0Ynt |WntyYn0dS) zr=z#run_with_reloader..)r&rrdrvrur)targetr_T)signalSIGTERMrrryrr threadingThreaddaemonrrrr rr}KeyboardInterrupt)rr&rrdrrZreloaderrZrrrrun_with_reloaders ( r)NNrr)* __future__rr"rr{r rrptypingrZ itertoolsrpathlibr _internalrtuple base_prefixbase_exec_prefixrrB exec_prefixhasattrr)rr+r-rr%r5r7r6r`rarrr__annotations__ __import__rrrrrrrsP      6;=b