k"g_LddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z mZddlmZddlmZddlmZddlZddlmZddlmZdd lmZdd lmZdd lmZeZ eZ!d Z"ejFd Z$gZ%da& ddl'Z' ddl)Z)dZ*dZ+dZ,dZ-dZ.dZ/e ddZ0e ddZ1dZ2dZ3dZ4dZ5GddZ6Gdde6Z7Gd d!e8Z9Gd"d#e6Z:d$Z;d%Z.wrapper<s     J#JBBr:t,4$//3B7:;;|+##H-  s  A;B)r)r/r0s` r check_errorsr1;s  2Y( Nrc"t tdy)N)r$rrraise_last_exceptionr5Tsmrc6trtjjsytjtj}|dtj zs|dxxtj zcc<t tdr3tjtjtj}nd}tjtjtj||%tjtj|yyy)z} Ensure that echo mode is enabled. Some tools such as PDB disable it which causes usability issues after reload. NSIGTTOU) termiosr"stdinisatty tcgetattrECHOhasattrsignalr8SIG_IGN tcsetattrTCSANOW) attr_list old_handlers rensure_echo_onrEZs #))**,!!#)),I Q<',, &!  $ 69 % --GKK#))W__i@  " MM&..+ 6 # 'rcttj}tdt tjj |D}t |ttS)Nc3TK|] }t|tjs|"ywN) isinstanceweakref ProxyTypes).0ms r z/iter_all_python_module_files..ss( !W//0 s&() sortedr"modulestuplemap __getitem__iter_modules_and_files frozensetr()keysrPs riter_all_python_module_filesrWmsN #++ DS[[,,d3G "'9\+B CCrr3)maxsizecg}|D]}t|ts|jdvr(t|dr|j |j Jt |ddX|j}|jsqt|jtr|jjn |j}|j |t}tj||D]R}|st!|} |j#s# |j+j-} |j/| Tt1|S#t$$r!} t&j)d| |Yd} ~ d} ~ wwxYw)z1Iterate through all modules needed to be watched.)__main__ __mp_main__r__spec__Nz%"%s" raised when resolving path: "%s")rIrrr>r)rr%r\ has_locationloaderrarchiveoriginset itertoolschainrexists ValueErrorloggerdebugresolveabsoluteaddrU) rP extra_filessys_file_pathsrspecr`resultsrre resolved_paths rrTrT{sUN*&*-  ??9 9 vz*%%foo6  6:t , 4    dkk;7 ##[[   ! !& )3*6eGOONK@# H~ ;;=! //1  M"# W    LL@!T J  s7E E/E**E/ct|Dcgc]}|jc}td}i}|D]-}|}|D]}|j|i}|j /fdt |dScc}w)a Return a tuple of common roots that are shared between the given paths. File system watchers operate on directories and aren't cheap to create. Try to find the minimum set of directories to watch that encompass all of the files that need to be watched. T)keyreversec3K|jD]\}}|||fzEd{|s t|yy7wrH)itemsr)noderprefixchild_walks rryzcommon_roots.._walksN!ZZ\ 6MFEUDF9$45 5 5 6+  6s'A?Ar4)rOpartslen setdefaultclearrQ)pathsx path_partstreechunksrvchunkrys @r common_rootsrs%0Q0c4HJ D .E??5"-D .  tR !!#1sA7c#KtjD]_}t|}|js|j j }|j r|j\|ayw)zZ Yield absolute directories from sys.path, ignoring entries that don't exist. N)r"rrrdrhriis_filer)rrps rsys_path_directoriesrsb   Dz{{}  //1  "&& &   sA4A6cddl}ttjd}|j d}tj gtj Dcgc]}d|z c}z}tjjdvr4|jdtjjDt|dd|jsz|j}|jdk(s|jjd r|j r |j }n |j}|d |gz }|tjd dz }|S|js{|jr|gtjd dS|j#d |jz}|jrg||tjd dSt%d |z|tjz }|Scc}w)z Return the executable. This contains a workaround for Windows if the executable is reported to not have the .exe extension which can cause bugs on reloading. rNz.exez-W%s)cpythonpypyc3DK|]\}}|durd|nd|d|yw)Tz-X=Nr4)rLrrvalues rrNz&get_child_arguments..s: U 4-bJr#aw-? ? s r\rZz .__main__z-mr3z %s-script.pyzScript %s does not exist.)rZrr"argv with_suffix executable warnoptionsimplementationnameextend _xoptionsrur%rdr\endswithr with_name RuntimeError)rZ py_scriptexe_entrypointor*rmrscript_entrypoints rget_child_argumentsrs SXXa[!I**62N NN 3??CavzC CD "55  !mm113  xT*6~?T?T?V   II #tyy'9'9+'FDKK;;D99D t    K     ""2SXXab\2 2%//0OP  # # %Apps ready_event triggered. Sending autoreload_started signal.)sender) rfrgrr django.urlsrurlconf_moduler!autoreload_startedsendrun_loop)rrrs rrzBaseReloader.runIsr 45   '9:,  N ) )  UVt,     sB B  B c|j}|js t||js|j y#t$rYwxYwrH)tick should_stopnext StopIterationstop)rtickers rrzBaseReloader.run_loopZsL"" V "" !  s A AActd)aX This generator is called in a loop from run_loop. It's important that the method takes care of pausing or otherwise waiting for a period of time. This split between run_loop() and tick() is to improve the testability of the reloader implementations by decoupling the work they do from the loop. z!subclasses must implement tick().NotImplementedErrorrs rrzBaseReloader.tickcs""EFFrctd)Nz/subclasses must implement check_availability().rclss rcheck_availabilityzBaseReloader.check_availabilityms!"STTrctj||}tjd||t d|Ds t |yy)N)r file_pathz+%s notified as changed. Signal results: %s.c3&K|] }|d yw)r3Nr4)rLress rrNz3BaseReloader.notify_file_changed..ts-c3q6-s) file_changedrrfrganyr)rrrns rnotify_file_changedz BaseReloader.notify_file_changedqsC##44#@ BD'R-W-- 4 .rc6|jjSrH)ris_setrs rrzBaseReloader.should_stopxs##**,,rc8|jjyrH)rrars rrzBaseReloader.stop|s   "rN)T)r __module__ __qualname__rrrrrrr classmethodrrpropertyrrr4rrrrsZ1 - 7$"GUU!--#rrc,eZdZdZdZdZedZy) StatReloaderr3c#FKi} |jD]d\}}|j|}|||<|tjd||6||kDsUnable to watch root dir %s as neither it or its parent exist.z watch-projectwarningzWatchman warning: %sz!Watchman watch-project result: %swatch relative_path) rdrrfrrquerystrrirgr)rrootresults r _watch_rootzWatchmanReloader._watch_roots{{};;%%'T;;D""?C 4HI   NN16)3D E 8&Ag ? ;;;rc@|jjd|dS)Nclock)rr)rrs r _get_clockzWatchmanReloader._get_clocks{{  $/88rc|j|\}}ddddgddgg|g}|dg|j|dd}|r||d <tjd ||||jj d |||y) NallofanyoftypeflrT) expressionfieldssince dedup_results relative_rootz8Issuing watchman subscription %s, for root %s. Query: %s subscribe)rr rfrgrr)rrrr'rrel_pathonly_files_expressionrs r _subscribezWatchmanReloader._subscribes)))4h  vsmfc] 3 !  0h__T*!   %-E/ " F     +tT59rcJ|jsp|jjstjd|yd|jz}|Dcgc]}|jd|}}|j}d|dg}nd}d|g}|j ||d||ycc}w)N?Unable to watch directory %s as neither it or its parent exist.zfiles-parent-%s/r wholenamefiles:)rdrrfrrr/)rr filenamesrwrr's r_subscribe_dirzWatchmanReloader._subscribe_dirs!##**,U&7FNWX(INNH=XIX!((I )[9JF ),J  fi#@*M YsB crd}|jsj|jjstjd|yd|jz}|Dcgc]}|jd|}}|j}dg}|D]}|j d|dg|j ||d ||ycc}w) a Watch a directory with a specific glob. If the directory doesn't yet exist, attempt to watch the parent directory and amend the patterns to include this. It's important this method isn't called more than one per directory when updating all subscriptions. Subsequent calls will overwrite the named subscription, so it must include all possible glob expressions. rr1Nzglob-parent-%sr2r#matchr3r5)rdrrfrrr)r/)rrrrwrr's r _watch_globzWatchmanReloader._watch_globs!##**,U% 6FKST9>>7;THT!((IY  ?G   w= > ?  fi#@*M UsB4c|jj}|Dcgc]}|j}}tt }t g|||Scc}wrH)rrVrlistrrU)rrextra_directoriesr%watched_file_dirs sys_pathss r watched_rootszWatchmanReloader.watched_rootss_ 00557/<=!QXX==-/0 M,M/@M9MNN>sAc Xt|jd}t|j|}tj dt |tj d|t|D]}|j||jjD]\}}|j||t|d}tj|dD]=\}}|j||Dcgc]}t|j!|c}?ycc}w)NF)rzWatching %s fileszFound common roots: %sc|jSrHrrs rz2WatchmanReloader._update_watches..+s 188r)rrc|jSrHrCrDs rrEz2WatchmanReloader._update_watches..,s ahhr)r<rrr@rfrgr{rOrrrur:rbgroupbyr7r relative_to) rr found_rootsrrr sorted_filesgrouprs r_update_watchesz WatchmanReloader._update_watches s T//e/DE "4#5#5m#DE  (#m*<= -{;;' #D   T " ##'#7#7#=#=#? 2 Ix   Y 1 2m1CD ) 1 1,DV W  Iu   5IaC i 89I  Js|jj|}|sytjd||D]d}t |dj ddd}tjd||j dgD]}|j||z fy)Nz%Watchman subscription %s has results. subscriptionr5r3zFound root directory %sr4)rgetSubscriptionrfrgrsplitrr)rsubrRrroot_directoryrs r_check_subscriptionz$WatchmanReloader._check_subscription:s{{2237   ">sA"Fq"IJN LL2N C 7B/ @(($)>? @ @rc btjd|jjy)Nz0Request processed. Setting update_watches event.)rfrgr ra)rr+s rrequest_processedz"WatchmanReloader.request_processedIs! GH ""$rc#Ktj|j|j |jj r*|j|jj  |jjt|jjjD]}|j| dt'j(d#tj$rY/tj$r1}t j#d||j%|Yd}~md}~wwxYww)Nz+Watchman error: %s, checking server status.r)r connectrYrPr rr}rreceiver<subsrVrWr SocketTimeout WatchmanErrorrfrgrNrr)rrUrOs rrzWatchmanReloader.tickMs  !7!78 %%,,.##%&&,,. 2 ##%  0 0 5 5 782C,,S12  JJsO! ++ ++ - JBO((,, -s=A5E 8C0AE 0EE E'E>E EE cV|jjt| yrH)rcloserrrs rrzWatchmanReloader.stopbs   rc |jjdy#t$rtt ||wxYw)z'Return True if the server is available.versionT)rrr!rr)rinner_exs rrNz$WatchmanReloader.check_server_statusfsC C KK  i ( C%c(m4( B Cs=c ts tdtjd} |j}t |d}t jd||dkr tdy#t$r tdwxYw) Nzpywatchman not installed.rrz'Cannot connect to the watchman service.rczWatchman version %s) z"Watchman 4.9 or later is required.)rrrcapabilityCheckr!r rfrg)rrrrcs rrz#WatchmanReloader.check_availabilityns%&AB B""3/ Q++-F$F9$56  *G4 V %&JK K  Q%&OP P Qs A..BrH)rrrrr rrrr r/r7r:r@rLrPrWrYrrrNrr __classcell__)rs@rrrs >><099:2N"N4O $ @%*LLrrcr tjtS#t$r tcYSwxYw)z7Return the most suitable reloader for this environment.)rrrrr4rr get_reloaderrks7++-   ~s  66ctt|}tj|||d}d|_|j |j s|j||j syy)Nzdjango-main-thread)targetr*r+rT)rEr1rThreaddaemonstartrr)reloader main_funcr*r+rs r start_djangorsseY'I"))tF9M!%"" '(""rctjtjd tjj t dk(rEt }tjd|jjt||g|i|yt}tj|y#t$rYywxYw)Nc,tjdS)Nr)r"r)r*s rrEz#run_with_reloader..s rrz!Watching for file changes with %s)r?SIGTERMrrrrrkrfrrrrsrr"rKeyboardInterrupt)rrr*r+rq exit_codes rrun_with_reloaderrys MM&..";<  ::>>/ 0F :#~H KK3X5G5G5P5P  9 >t >v >-/I HHY     sA*B2B22 B>=B>)>rbloggingrr?rr"rrr&rJ collectionsr functoolsrrpathlibrtypesr zipimportrr django.appsr django.core.signalsr django.dispatchr django.utils.functionalr django.utils.versionr rrr getLoggerrfr(r$r9 ImportErrorrrrr1r5rErWrTrrrrrrrrrrrkrsryr4rrrsa   #&! 0"32Xx "   4 5     1 > 2 7& D 1..b 1""< ")X  f#f#R(<(V , NL|NLb )  aG Js$D D DDD#"D#