ja*dZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZddlmZmZmZdd lmZerdd lmZej4ej6 d Zd ZGdde ZdZe eeZ e jCddee jEdZ#iZ$dZ%ge#gfdZ&ejNfdZ(ddZ)dZ*ddZ+dZ,dZ-e&e%dd d!"e%d#d$d%ejNd&'e%d(d)d*d+e.d,-e%d.d/d0d12e%d3d/d45e%d6d/d75e%d8d/d95e%d:d/d;5e%dd?Z/e&e%d@d dA"e%d#d$d%ejNd&'e%dBddC'e%dDdEdFd/dGHgdIg>dJZ0e&e%dKd d$dLMe%dNdOdPdQd dRSe%dTdUdVdWdXdYSe%dZd[d\d/d]He%d^d.d_d/d`He%d(d)d*d+e.da-e%dbd/dc5e%d3d/d45e%d6d/d75e%d8d/d95e%d:d/d;5e%d. Copyright 2012 Google, Inc & contributors. Licensed under the terms of the Apache license, version 2.0. Please see LICENSE in the source code for more information.)epilogformatter_classz --versionversion)actionr* top_command)destct||fS)z\Convenience function to properly format arguments to pass to the command decorator. )list) name_or_flagsrs rargumentr1Qs   &&rcfd}|S)a Decorator to define a new command in a sanity-preserving way. The function will be stored in the ``func`` variable when the parser parses arguments so that it can be called directly like so:: >>> args = cli.parse_args() >>> args.func(args) c|jjdd}t|j}j ||t }|t |<|j}|jddddd |jd d ddd D],}|j|d i|d |j|.|S)N_-) descriptionaliasesr)z-qz--quiet verbosity append_const)r-r+constz-vz --verboser)func) r#replacerr& add_parserrcommand_parsersadd_mutually_exclusive_group add_argument set_defaults) r=namedescparserverbosity_groupargr cmd_aliasesparents r decoratorzcommand..decoratorbs}}$$S#.dll#""4T;`m"n & ==?$$T9;~eg$h$$T;[Q_gh$i +C F  Q 23q6 2   T  * + r)rrJrIrKs``` rcommandrMXs  rc6t|j|S)zSplits a pathname specification separated by an OS-dependent separator. :param pathname_spec: The pathname specification. :param separator: (OS Dependent) `:` on Unix and `;` on Windows or user-specified. )r/split) pathname_spec separators r path_splitrRrs  ##I. //rc^|dddD]"}tjj||$y)zAdds specified paths at specified index into the sys.path list. :param paths: A list of paths to add to the sys.path :param index: (Default 0) The index in the sys.path list where the paths will be added. Nr:)syspathinsert) pathnamesindexpathnames radd_to_sys_pathrZ}s-ddO) x()rcddl}t|d5}|j|jcdddS#1swYyxYw)zLoads the YAML configuration from the specified file. :param tricks_file_path: The path to the tricks configuration file. :returns: A dictionary of configuration information. rNrb)yamlopen safe_loadread)tricks_file_pathnamer]fs r load_configrcs; "D )(Q~~affh'(((s :Ac^|j|}|j|}|dgk(rg}||fS)z^Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). )rO) patterns_specignore_patterns_specrQpatternsignore_patternss rparse_patternsrjs>""9-H*00;O2$ o &&rct|D]}|j||||j tjd#t $r|j YnwxYw|jy)agSingle observer thread with a scheduled path and event handler. :param observer: The observer thread. :param event_handler: Event handler which will be called in response to file system events. :param pathnames: A list of pathnames to monitor. :param recursive: ``True`` if recursive; ``False`` otherwise. r<N)setschedulestarttimesleepr stopjoin)observer event_handlerrW recursiverYs r observe_withrvsl N>-9=> NN JJqM   MMOsA A('A(c|D]Z}t|jD]<\}}t|}|di|}t|ddxs|} |j || |>\y)ajSchedules tricks with the specified observer and for the given watch path. :param observer: The observer thread into which to schedule the trick and watch. :param tricks: A list of tricks. :param pathname: A path name which should be watched. :param recursive: ``True`` if recursive; ``False`` otherwise. source_directoryNrL)r/itemsr getattrrm) rsrrYrutrickrDvalue TrickClasshandlertrick_pathnames rschedule_tricksrsrB . BKD%#D)J )5)G$W.@$GS8N   g~y A  BBrfiles*zperform tricks from given file)nargshelpz --python-path.zPaths separated by z to add to the Python path.)defaultrz --intervalz --timeouttimeoutg?z?Use this as the polling interval/blocking timeout (in seconds).)r-rtyperz --recursive store_trueTz-Recursively monitor paths (defaults to True).)r+rrz--debug-force-pollingz[debug] Forces polling.)r+rz--debug-force-kqueuez[debug] Forces BSD kqueue(2).z--debug-force-winapizebug] Forces Windows API.z--debug-force-fseventsz[debug] Forces macOS FSEvents.z--debug-force-inotifyz [debug] Forces Linux inotify(7).)rIc |jrddlm}nr|jrddlm}n_t s |jst rtjrddl m }n,|jrddl m}n|jrddlm}nddlm}t)t+|j,g}|j.D]+}||j0}t2j4j7|st:j<|tA|} |tB}tF|vrt)|tFt2j4jI|xs1t2j4jKt3jL}tO||||jP|jS|jU|. tWjXd #tD$r}tEd tBd |d |d }~wwxYw#tZ$r*|D]"} | j]| j_$YnwxYw|D]} | jay )z;Command to execute tricks from a tricks configuration file.rPollingObserverKqueueObserverWindowsApiObserverInotifyObserverFSEventsObserverObserverrzNo z key specified in rNr<)1debug_force_pollingwatchdog.observers.pollingrdebug_force_kqueuewatchdog.observers.kqueuerrdebug_force_winapir is_windows)watchdog.observers.read_directory_changesrdebug_force_inotifywatchdog.observers.inotifyrdebug_force_fseventswatchdog.observers.fseventsrwatchdog.observersrrZrR python_pathrrosrUexistsOSErrorerrnoENOENTstrerrorrcCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrrurnappendrorpr unschedule_allrqrr) rr observers tricks_filersconfigredir_pathos r tricks_fromrsb J H 7 7]xObObOd\ ! !J " "L 0Jt//01Izz# DLL1ww~~k*%,, ELL(A;O O[) a-.F "V + F#9: ;77??;/O277??299;3O&(DNNC"'#* JJqM aS!2 55G VWXY_` ` a  A    FFH  s*0 G9"H!9 HHH!0II trick_pathsz5Dotted paths for all the tricks you want to generate.z--append-to-filez Appends the generated tricks YAML to a file. If not specified, prints to standard output.z-az --append-only append_onlyz If --append-to-file is not specified, produces output for appending instead of a complete tricks YAML file.)r-r+rzgenerate-tricks-yamlcddl}t|j}t|t }|j D],}t |}|j|j.|j}|j|jt|i}|tdz }|j1|js||z}t j"j|yt$j&j)|js||z}t+|jdd5}|j|dddy#1swYyxYw)zLCommand to generate Yaml configuration for tricks named on the command line.rNz: azutf-8)encoding)r]rRrrZrrr write generate_yamlgetvalueclosedumprrappend_to_filerrTstdoutrrUrr^) rr] python_pathsoutput trick_pathr}contentheaderfiles rtricks_generate_yamlr1sBd../LL! ZF&&1  +  Z--/01ooG LLN YY. = >F "#3''F "w&G !ww~~d112w&G $%%sW =  JJw    s 0E  E directoriesz%Directories to watch. (default: '.').)rrrz-pz --patternz --patternsrhz9Matches event paths with these patterns (separated by ;).)r-rrz-iz--ignore-patternz--ignore-patternsrirez9Ignores event paths with these patterns (separated by ;).z-Dz--ignore-directoriesignore_directorieszIgnores events for directories.z-Rruz%Monitors the directories recursively.z2Use this as the polling interval/blocking timeout.z--tracez!Dumps complete dispatching trace.cddlm}ddlm}|jr5t j |j|j|fdt|j|j\}}||||j}|jrddlm}nr|j rddlm}n_t&s |j(st&rt+j,rdd lm}n,|j2rdd lm}n|j8rdd lm}ndd lm }||jB }tE|||jF|jHy)z1Command to log file system events to the console.r) LoggerTrick)echoc&j|SN)info)msgclass_module_loggers rzlog..s7J7O7OPS7Tr)r)rhrirrrrrrrrN)%watchdog.tricksrwatchdog.utilsrtracelogging getLoggerr$ echo_classrjrhrirrrrrrrrrr rrrrrrrrrrrrrvrru) rrrrhrir~rrsrs @rlogrmsP,# zz%// 0F0FG  +TU .t}}d>R>R SHo'22G J H 7 7]xObObOd\ ! !J " "L 0 -H7D$4$4dnnErzDirectories to watch.z-cz --commandrMam Shell command executed in response to matching events. These interpolation variables are available to your command string: ${watch_src_path} - event source path ${watch_dest_path} - event destination path (for moved events) ${watch_event_type} - event type ${watch_object} - 'file' or 'directory' Note: Please ensure you do not use double quotes (") to quote your command string. That will force your shell to interpolate before the command is processed by this command. Example: --command='echo "${watch_src_path}"' F)r-rr+rz-wz--waitwait_for_processzDWait for process to finish to avoid multiple simultaneous instances.z-Wz--dropdrop_during_processzhIgnore events that occur while command is still being executed to avoid multiple simultaneous instances.cddlm}|jsd|_|jrddlm}nddlm}t|j|j\}}||j|||j|j|j}||j}t|||j |j"y)zDCommand to execute shell commands in response to file system events.r)ShellCommandTrickNrr) shell_commandrhrirrrr)rrrMrrrrrrjrhrirrrrrvrru)rrrrhrir~rss rrrsn2 <<  J/ .t}}d>R>R SHoll'22.. 44 G -H7D$4$4dnnErz,Long-running command to run in a subprocess.)r command_argsrHz Command arguments. Note: Use -- before the command arguments, otherwise watchmedo will try to interpret them. )metavarrrz-dz --directory DIRECTORYrzLDirectory to watch. Use another -d or --directory option for each directory.)r-rr+rz--signalsignalSIGINTz6Stop the subprocess with this signal (default SIGINT).z --kill-after kill_afterg$@zYWhen stopping, kill the subprocess after the specified timeout in seconds (default 10.0).z--debounce-intervaldebounce_intervalgzwAfter a file change, Wait until the specified interval (in seconds) passes with no file changes, and only then restart.z--no-restart-on-command-exitrestart_on_command_exit store_falsez.Don't auto-restart the command after it exits.c  |jrddlm}nddlm}ddl ddlm}|jsdg|_|j jdrt |j nt|j } j jh t dr j j  fd } D]} j ||t#|j$|j&\}}|j(g}|j+|j,|||||j.||j0|j2|j4 } | j7||j8 } t;| | |j|j<| jAy#t>$rYwxYw#| jAwxYw) zLCommand to start a long-running subprocess and restart it on matched events.rrrN)AutoRestartTrickrSIGSIGHUPcVD]}j|j tr)rSIG_IGNr )_signum_framesignumrtermination_signalss rhandler_termination_signalz0auto_restart..handler_termination_signals*) 2F MM&&.. 1 2r)rMrhrir stop_signalrdebounce_interval_secondsrr)!rrrrrrrrr startswithrzintSIGTERMrhasattraddrrjrhrirMextendrrrrrrnrrvrur rq) rrrrrrrhrirMr~rsrrs @@r auto_restartrEs~ J/0   537++2H2H2O'&$++.UXY]YdYdUeK">>6==9vx  . &: f89:!/t}}d>R>R SHo||nG NN4$$%'22??"&"8"8 $ < < G MMO -HXw(8(8$..I        s$"F88 GGGGGc eZdZy)LogLevelExceptionN)r#r$r%rLrrrrsrrct|jxsg}|dkr td|dkDr tdgdd|zS)Nr:z&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.)ERRORWARNINGINFODEBUGr<)sumr8r)rr8s r_get_log_level_from_argsr sJDNN(b)I2~ HII1} NOO 0Y ??rctj}|jtjy t |}tjdj| |j|y#t $rV}t d|jdtjt|jjYd}~yd}~wwxYw#t$rYywxYw)zEntry-point function.Nr<zError: r)rwatchdog)cli parse_argsr, print_helpr rprintrrTstderrr@rrsetLevelr=KeyboardInterrupt)r log_levelexcs rmainrs >> D  ,T2  j!**95 $    }%CJJ7(()446 s* A9'C9 CA CC C'&C'__main__)r);):r& __future__rrrros.pathrTroargparserriortextwraprtypingrrr r r watchdog.versionr watchdog.observers.apir basicConfigrrrrr(rrBadd_subparsers subparsersr@r1rMpathseprRrZrcrjrvrfloatrrrrr Exceptionrr rr#exitrLrrr)s." #   @ AA+C',,'&!/!( 4FMBYG   ]  3 'JB4)+ 0 ) ('.B* *JK &rzzn4OP   R    @  (D]^ "0  ".  $1  #3 K*V Y-\1]-\1h  H  &rzzn4OP  C    H  %8((;> ?> :  8     L      "L     "%2     8     E   <6YZ(D]^ "0  ".  $1  #3 }CEL FMEL FF c3=TU    2    L      "L     "%2     8     E     #W     &B   (D]^cRTjFkTjF4 !OP     _      L      "L     "%2     8     E    I  (D]^ l    !$K    ** A  eY[x6y[x6r  @ . z CHHTVr