U
|
Þ=®d9 ã @ sÆ U d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZ d dl
|
m Z d dl m Z ddlmZ eejejhZeejejhZeedr e ej¡ eeZ[dd d
|
d d d dhZddddZddddddZ ddddddZ ddddd d Z ddd d d Z d!dd"d#Z G d$d% d%Z!G d&d' d'e!Z"G d(d) d)e!Z#e"e#d*Z$d+e%d,< z e&d- W n" e'k
|
r e$d. e$d/< Y nX e$d0 e$d/< ddd1d2Z(d:d3d4d4d5d6dd7d8d9Z)dS );é )Ú annotationsN)Úchain)ÚPurePathé )Ú_logÚ real_prefixÚ __pycache__z.gitz.hgz.toxz.noxz .pytest_cachez .mypy_cachezt.Iterator[str]©Úreturnc c sf t tj ¡ D ]R} t| dd}|dks| t¡r2qtj |¡sZ|}tj
|
|¡}||kr2qq2|V qdS )z;Find the filesystem paths associated with imported modules.Ú__file__N) ÚlistÚsysÚmodulesÚvaluesÚgetattrÚ
|
startswithÚ_ignore_alwaysÚosÚpathÚisfileÚdirname)ÚmoduleÚnameÚold© r úId:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\werkzeug/_reloader.pyÚ_iter_module_paths( s r zset[str]ÚNone)ÚpathsÚexclude_patternsr
|
c C s |D ]}| t | |¡¡ qd S ©N)Údifference_updateÚfnmatchÚfilter)r r Úpatternr r r Ú_remove_by_pattern< s r% zt.Iterable[str])Ú extra_filesr r
|
c
|
C sú t }tttj| D ]È}tj |¡}tj |¡r>| |¡ qtj |¡di}t
|
|¡D ]\}}}| t ¡s|tj |¡tkr| ¡ qXd}|D ]&} | d¡rd}| tj || ¡¡ q|sÔ|tj |¡ sÔ| ¡ qX|||< qXq| t ¡ t|| |S )ax Find 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)Úsetr r r r r Úabspathr Úaddr Úwalkr Ú_stat_ignore_scanÚbasenameÚ_ignore_common_dirsÚclearÚendswithÚjoinÚupdater r% )
|
r& r r r Z parent_has_pyÚrootÚdirsÚfilesZhas_pyr r r r Ú_find_stat_pathsA s4
|
ÿþ
|
|
r5 c C sz t }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' r r r r r r( r r r) r r% Ú_find_common_roots)r& r r3 r r r r Ú_find_watchdog_pathsw s
|
|
r7 )r r
|
c sp i }t dd | D tddD ]&}|}|D ]}| |i ¡}q(| ¡ q t dddd fd d
|
|d S ) Nc s s | ]}t |jV qd S r )r Úparts©Ú.0Úxr r r Ú <genexpr> s z%_find_common_roots.<locals>.<genexpr>T)ÚkeyÚreversezt.Mapping[str, dict]ztuple[str, ...]r )Únoder r
|
c s< | ¡ D ]\}} |||f q| s8 tjj| ¡ d S r )Úitemsr) r r r0 )r? r ÚprefixÚchild©Ú_walkÚrvr r rD s z!_find_common_roots.<locals>._walkr )ÚsortedÚlenÚ
|
setdefaultr. r' )r r2 Úchunksr? Úchunkr rC r r6 s
|
|
r6 z list[str]c C s t jdkr t jft jdd
S t jg} t jd }t jdd
}t jd }t|dddkstjdkr|j dkrtj
|
|¡stj
|
| d ¡rtj
|
|¡}tjdkr
|
tj
|
|¡sÒtj
|
| d ¡rÒ|d 7 }tj
|
t j¡d d kr
|
tj
|
|¡d d kr
|
| d¡ | |¡ nftj
|
|¡rdt t|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.
|
)é é
|
r Nr Ú__main__Ú __package__ÚntÚ z.exeÚ.z-m)r Ú version_infoÚ
|
executableZ orig_argvÚargvr r r r rN r Úexistsr( ÚsplitextÚpopÚappendr ÚtÚcastÚstrr, ÚextendÚlstrip)rE Z py_scriptÚargsrM Z py_moduler r r r Ú_get_args_for_reloading§ sD
|
|
|
ÿþ
|
ýü ÿþ
|
|
|
r_ c @ s e Zd ZdZd ddddddd Zd d
|
d d Zd d Zdd
|
ddZdd
|
ddZdd
|
ddZ dddddZ
|
dddddZ dS ) Ú ReloaderLooprP Nr út.Iterable[str] | Noneú int | floatr )r& r Úintervalr
|
c C s, dd |p dD | _ t|p d| _|| _d S )Nc S s h | ]}t j |¡qS r )r r r( r9 r r r Ú <setcomp>ë s z(ReloaderLoop.__init__.<locals>.<setcomp>r )r& r' r rc )Úselfr& r rc r r r Ú__init__å s zReloaderLoop.__init__r c C s | ¡ | S )zgDo any setup, then run one step of the watch to populate the
|
initial filesystem state.
|
)Úrun_step©re r r r Ú __enter__ï s zReloaderLoop.__enter__c C s dS )z4Clean up any resources associated with the reloader.Nr ©re Úexc_typeÚexc_valÚexc_tbr r r Ú__exit__ö s zReloaderLoop.__exit__c C s | ¡ t | j¡ q dS )zfContinually run the watch step, sleeping for the configured
|
interval after each step.
|
N)rg ÚtimeÚsleeprc rh r r r Úrunú s zReloaderLoop.runc C s dS )z}Run one step for watching the filesystem. Called once to set
|
up initial state, then repeatedly to update it.
|
Nr rh r r r rg s zReloaderLoop.run_stepÚintc C sL t dd| j t }tj ¡ }d|d< tj||dd}|dkr |S q dS ) z|Spawn a new Python interpreter with the same arguments as the
|
current one, but running the reloader thread.
|
Úinfoz * Restarting with ÚtrueÚWERKZEUG_RUN_MAINF)ÚenvÚ close_fdsrK N)r r r_ r ÚenvironÚcopyÚ
|
subprocessÚcall)re r^ Z new_environZ exit_coder r r Úrestart_with_reloader s
|
z"ReloaderLoop.restart_with_reloaderr[ ©Úfilenamer
|
c C s | |¡ t d¡ d S ©NrK )Ú
|
log_reloadr Úexit©re r~ r r r Útrigger_reload s
|
zReloaderLoop.trigger_reloadc C s" t j |¡}tdd|d d S )Nrs z * Detected change in z , reloading)r r r( r r r r r r s zReloaderLoop.log_reload)NNr ) Ú__name__Ú
|
__module__Ú __qualname__r rf ri rn rq rg r| r r r r r r r` â s ü
|
r` c s4 e Zd ZdZdd fdd ZddddZ ZS ) ÚStatReloaderLoopÚstatr` r c s i | _ t ¡ S r )ÚmtimesÚsuperri rh ©Ú __class__r r ri " s zStatReloaderLoop.__enter__r c C st t | j| jD ]`}zt |¡j}W n tk
|
r: Y qY nX | j |¡}|d kr\|| j|< q||kr| |¡ qd S r )
|
r5 r& r r r Úst_mtimeÚOSErrorr Úgetr )re r ÚmtimeZold_timer r r rg & s
|
|
zStatReloaderLoop.run_step)r r
r r ri rg Ú __classcell__r r r r r s r c sl e Zd Zdddd fdd Zddddd Zd
|
d fd d Zdd Zdd ddZdd ddZ Z S )ÚWatchdogReloaderLoopzt.Anyr )r^ Úkwargsr
|
c sÎ ddl m} ddlm} ddlm ddlm t j|| | jG fddd|}|j
|
¡ }| d¡r||d d
}d
|
| d | _ | | _ d d | jD }|d|dd tD | jd| _d| _d S )Nr )ÚObserver)ÚPatternMatchingEventHandler)ÚEVENT_TYPE_OPENED)ÚFileModifiedEventc s e Zd Zdd fdd ZdS )z3WatchdogReloaderLoop.__init__.<locals>.EventHandlerr )Úeventc s |j krd S |j d S r )Z
|
event_typeZsrc_path)re r )r r r r Ú on_any_eventB s
|
z@WatchdogReloaderLoop.__init__.<locals>.EventHandler.on_any_eventN)r r
r r r ©r r r r r Ú EventHandlerA s r Úobserveriøÿÿÿz
|
watchdog (ú)c S s g | ]}t j |¡s|qS r )r r Úisdir)r: Úpr r r Ú
|
<listcomp>T s z1WatchdogReloaderLoop.__init__.<locals>.<listcomp>ú*.pyú*.pycú*.zipc S s g | ]}d | dqS )z*/z/*r )r: Údr r r r X s )ÚpatternsÚignore_patternsF)r¡ r¢ r£ )Zwatchdog.observersr Zwatchdog.eventsr r r r rf r r Úlowerr/ r r r& r- r Ú event_handlerÚ should_reload)re r^ r r r r Z reloader_nameZextra_patternsr r r rf 8 s(
|
|
þþz WatchdogReloaderLoop.__init__r[ r} c C s d| _ | |¡ d S )NT)r© r r r r r r ^ s z#WatchdogReloaderLoop.trigger_reloadr` r c s i | _ | j ¡ t ¡ S r )Úwatchesr Ústartr ri rh r r r ri e s
|
z WatchdogReloaderLoop.__enter__c C s | j ¡ | j ¡ d S r )r Ústopr0 rj r r r rn j s
|
z WatchdogReloaderLoop.__exit__c C s* | j s | ¡ t | j¡ q t d¡ d S r )r© rg ro rp rc r r rh r r r rq n s zWatchdogReloaderLoop.runc C s t | j}t| j| jD ]V}|| jkrdz | jj| j|dd| j|< W n tk
|
rb d | j|< Y nX | |¡ q|D ]&}| j
|
|d ¡}|d k rt| j |¡ qtd S )NT)Ú recursive) r' rª r7 r& r r Úscheduler¨ r ÚdiscardrW Z
|
unschedule)re Z to_deleter Zwatchr r r rg u s
|
|
ÿ z WatchdogReloaderLoop.run_step)
|
r r
r rf r ri rn rq rg r r r r r r 7 s &r )r Úwatchdogz dict[str, type[ReloaderLoop]]Úreloader_loopszwatchdog.observersr Úautor° c C s~ t jdkst j ¡ sdS z ddl} W n tk
|
r: Y dS X | t j¡}|d | j@ sz|d | jO < | t j| j|¡ dS )zuEnsure that echo mode is enabled. Some tools such as PDB disable
|
it which causes usability issues after a reload.Nr rK ) r ÚstdinÚisattyÚtermiosÚ ImportErrorÚ tcgetattrÚECHOÚ tcsetattrZTCSANOW)rµ Ú
|
attributesr r r Úensure_echo_on s r» zt.Callable[[], None]ra rb r[ )Ú main_funcr& r rc Ú reloader_typer
|
c C s¤ ddl }| |jdd ¡ t| |||d}z^tj d¡dkrzt tj| dd }d
|
|_ | |
|
¡ | ¡ W 5 Q R X nt | ¡ ¡ W n tk
|
r Y nX dS ) z<Run the given function in an independent Python interpreter.r Nc W s
|
t d¡S )Nr )r r )r^ r r r Ú<lambda>· ó z#run_with_reloader.<locals>.<lambda>)r& r rc ru rt r )Útargetr^ T)ÚsignalÚSIGTERMr± r rx r r» Ú threadingÚThreadÚdaemonr« rq r r r| ÚKeyboardInterrupt)r¼ r& r rc r½ rÁ ZreloaderrY r r r Úrun_with_reloader s$ ÿrÇ )NNr r² )*Ú
|
__future__r r" r rz r rà ro ÚtypingrY Ú itertoolsr Úpathlibr Ú _internalr ÚtupleÚ base_prefixÚbase_exec_prefixr rA Ú exec_prefixÚhasattrr) r r+ r- r r% r5 r7 r6 r_ r` r r r± Ú__annotations__Ú
|
__import__r¶ r» rÇ r r r r Ú<module> s`
|
ù 6;=Wþ û
|
