o 'hE<@sUddlmZddlZddlZddlZddlZddlZddlZddlZ ddl m Z ddl m Z ddlmZeejejhZheejejZeedrReejeeZ[hdZd6d d Zd7ddZd8ddZd8ddZd9ddZd:ddZ GdddZ!Gd d!d!e!Z"Gd"d#d#e!Z#e"e#d$Z$d%e%d&<ze&d'Wne'ye$d(e$d)<Ynwe$d*e$d)<d;d+d,Z(    )d) annotationsN)chain)PurePath)_log real_prefix>.hg.git.nox.tox .mypy_cache .pytest_cache __pycache__returnt.Iterator[str]ccsrttjD].}t|dd}|dus|trqtj |s3|}tj |}||kr-n tj |r |VqdS)z;Find the filesystem paths associated with imported modules.__file__N) listsysmodulesvaluesgetattr startswith_ignore_alwaysospathisfiledirname)modulenameoldr N/var/www/html/olx_land/venv/lib/python3.10/site-packages/werkzeug/_reloader.py_iter_module_paths(s    r"pathsset[str]exclude_patternsNonecCs |D] }|t||qdSN)difference_updatefnmatchfilter)r#r%patternr r r!_remove_by_pattern<sr, extra_filest.Iterable[str]c Cst}tttj|D]d}tj|}tj|r||q tj |di}t |D]B\}}}| t s>tj |tvrC|q,d}|D]} | drZd}|tj|| qG|sj|tj |sj|q,|||<q,q |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)setrrrrrabspathraddrwalkr_stat_ignore_scanbasename_ignore_common_dirsclearendswithjoinupdater"r,) r-r%r#r parent_has_pyrootdirsfileshas_pyrr r r!_find_stat_pathsAs6        r?cCszt}tttj|D]}tj|}tj|rtj|}| |q t D] }| tj|q(t ||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/rrrrrr0rrr1r"r,_find_common_roots)r-r%r<rr r r!_find_watchdog_pathsws      rAcshi}tdd|DtddD]}|}|D]}||i}q|qtdfd d |d S)Ncss|]}t|jVqdSr')rparts.0xr r r! sz%_find_common_roots..T)keyreversenode t.Mapping[str, dict[str, t.Any]]rtuple[str, ...]rr&csH|D] \}}|||fq|s |r"tjj|dSdSdSr')itemsr1rrr8)rIrprefixchild_walkrvr r!rPs z!_find_common_roots.._walkr )rIrJrrKrr&)sortedlen setdefaultr6r/)r#r;chunksrIchunkr rOr!r@s  r@ list[str]cCsxtjdkrtjgtjddStjg}tjd}tjdd}tjd}t|dddusFtjdkr|j dkrtj |stj |d rtj |}tjdkr~tj |sdtj |d rd|d 7}tj tjdd kr~tj |dd kr~|d||n1tj |rtt|j }tj tj |d}|dkr|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 executable orig_argvargvrrrrr[rexistsr0splitextpopappendrtcaststrr4extendlstrip)rQ py_scriptargsrZ py_modulerr r r!_get_args_for_reloadings>            roc@sfeZdZdZ   dd d d Zd!d dZddZd"ddZd"ddZd#ddZ d$ddZ d%ddZ dS)& ReloaderLoopr]Nrr-t.Iterable[str] | Noner%interval int | floatrr&cCs,dd|pdD|_t|pd|_||_dS)NcSsh|]}tj|qSr )rrr0rCr r r! z(ReloaderLoop.__init__..r )r-r/r%rr)selfr-r%rrr r r!__init__s zReloaderLoop.__init__cCs ||S)zgDo any setup, then run one step of the watch to populate the initial filesystem state. )run_steprvr r r! __enter__szReloaderLoop.__enter__cCdS)z4Clean up any resources associated with the reloader.Nr rvexc_typeexc_valexc_tbr r r!__exit__szReloaderLoop.__exit__cCs |t|jq)zfContinually run the watch step, sleeping for the configured interval after each step. )rxtimesleeprrryr r r!runs zReloaderLoop.runcCr{)z}Run one step for watching the filesystem. Called once to set up initial state, then repeatedly to update it. Nr ryr r r!rxszReloaderLoop.run_stepintcCsJ tdd|jt}tj}d|d<tj||dd}|dkr$|Sq) z|Spawn a new Python interpreter with the same arguments as the current one, but running the reloader thread. Tinfoz * Restarting with trueWERKZEUG_RUN_MAINF)env close_fdsrX)rrrorenvironcopy subprocesscall)rvrm new_environ exit_coder r r!restart_with_reloader s z"ReloaderLoop.restart_with_reloaderfilenamericCs||tddSNrX) log_reloadrexitrvrr r r!trigger_reload zReloaderLoop.trigger_reload str | bytescCs"tj|}tdd|ddS)Nrz * Detected change in z , reloading)rrr0rrr r r!rs zReloaderLoop.log_reload)NNr)r-rqr%rqrrrsrr&rrprr&)rr)rrirr&rrrr&) __name__ __module__ __qualname__rrwrzrrrxrrrr r r r!rps     rpcs,eZdZdZd fdd Zd ddZZS) StatReloaderLoopstatrrpcsi|_tSr')mtimessuperrzry __class__r r!rz$s zStatReloaderLoop.__enter__r&c Csnt|j|jD]-}zt|j}Wn tyYqw|j|}|dur+||j|<q||kr4| |qdSr') r?r-r%rrst_mtimeOSErrorrgetr)rvrmtimeold_timer r r!rx(s    zStatReloaderLoop.run_steprr)rrrrrzrx __classcell__r r rr!r!srcsReZdZdfdd Zdd d Zdfd d ZddZdddZdddZZ S)WatchdogReloaderLooprmt.Anykwargsrr&c sddlmddlmddlmddlmddlmddlm}ddlm}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$eZdZdfdd ZdS)z3WatchdogReloaderLoop.__init__..EventHandlereventrcs&|jhvr dS|jdSr') event_typesrc_path)rvrrrrrrrr r! on_any_eventHsz@WatchdogReloaderLoop.__init__..EventHandler.on_any_eventN)rr)rrrrr rr r! EventHandlerGsrobserveriz watchdog ()cSsg|] }tj|s|qSr )rrisdir)rDpr r r! asz1WatchdogReloaderLoop.__init__..z*.pyz*.pycz*.zipcSsg|]}d|dqS)z*/z/*r )rDdr r r!reru)patternsignore_patternsF)watchdog.eventsrrrrrrrwatchdog.observersrrrwrrlowerr7rrr-r5r% event_handler should_reload) rvrmrrrrr reloader_nameextra_patternsrrr!rw:s4              zWatchdogReloaderLoop.__init__rrcCsd|_||dS)NT)rrrr r r!rksz#WatchdogReloaderLoop.trigger_reloadrpcsi|_|jtSr')watchesrstartrrzryrr r!rzrs  zWatchdogReloaderLoop.__enter__cCs|j|jdSr')rstopr8r|r r r!rwrzWatchdogReloaderLoop.__exit__cCs.|js|t|j|jrtddSr)rrxrrrrrrryr r r!r{s  zWatchdogReloaderLoop.runc Cst|j}t|j|jD]*}||jvr1z|jj|j|dd|j|<Wnty0d|j|<Ynw| |q |D]}|j |d}|durL|j |q9dS)NT) recursive) r/rrAr-r%rschedulerrdiscardre unschedule)rv to_deleterwatchr r r!rxs"     zWatchdogReloaderLoop.run_step)rmrrrrr&rrr) rrrrwrrzrrrxrr r rr!r9s 1 r)rwatchdogzdict[str, type[ReloaderLoop]]reloader_loopszwatchdog.observersrautorcCstjdus tjs dSzddl}Wn tyYdSw|tj}|d|j@s>|d|jO<|tj|j|dSdS)zuEnsure that echo mode is enabled. Some tools such as PDB disable it which causes usability issues after a reload.NrrX) rstdinisattytermios ImportError tcgetattrECHO tcsetattrTCSANOW)r attributesr r r!ensure_echo_ons   r main_funct.Callable[[], None]rqrrrs reloader_typericCsddl}||jddt||||d}z>tjddkrKttj|dd }d |_ || | WdWdS1sCwYWdSt |WdSty^YdSw) zs z#run_with_reloader..)r-r%rrrrr )targetrmT)signalSIGTERMrrrrr threadingThreaddaemonrrrrrKeyboardInterrupt)rr-r%rrrrreloaderrgr r r!run_with_reloaders$ & r)rr)r#r$r%r$rr&)r-r$r%r$rr.)r#r.rr.)rrWr)NNrr) rrr-rqr%rqrrrsrrirr&)* __future__rr)rrrrrtypingrg itertoolsrpathlibr _internalrtuple base_prefixbase_exec_prefixrrM exec_prefixhasattrr1rr3r5r"r,r?rAr@rorprrr__annotations__ __import__rrrr r r r!sT        6  ;=b