U ")3ga@sdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZddlmZmZmZdd lmZerdd lmZejejd d Zd ZGddde ZdZe eedZ e j!ddede j"ddZ#iZ$ddZ%ge#gfddZ&ej'fddZ(dddZ)dd Z*dd"d#Z+d$d%Z,d&d'Z-e&e%d(d)d*d+e%d,d-d.ej'd/d0e%d1d2d3d4e.d5d6e%d7d8d9d:d;e%de%d?d8d@d>e%dAd8dBd>e%dCd8dDd>e%dEd8dFd>g d gdGdHdIZ/e&e%dJd)dKd+e%d,d-d.ej'd/d0e%dLddMd0e%dNdOdPd8dQdRgdSgdGdTdUZ0e&e%dVd)d-dWdXe%dYdZd[d\d)d]d^e%d_d`dadbdcddd^e%dedfdgd8dhdRe%did7djd8dkdRe%d1d2d3d4e.dld6e%dmd8dnd>e%de%d?d8d@d>e%dAd8dBd>e%dCd8dDd>e%dEd8dFd>g dodpZ1e&e%dVd)d-dqdXe%drdsdddtd^e%dYdZd[d\d)d]d^e%d_d`dadbdcddd^e%dedfdgdud8dhdve%did7djd8dkdRe%d1d2d3d4e.dld6e%dwdxdyd8dzdRe%d{d|d}d8d~dRe%dg ddZ2e&e%ddde%ddd)dde%dddVdddde%dYdZd[d\d)d]d^e%d_d`dadbdcddd^e%dedfdgdud8dhdve%did7djd8dkdRe%d1d2d3d4e.dld6e%ddddd^e%de%ddde.dd6e%ddde.dd6e%ddd9dddvg ddZ3Gddde4Z5ddZ6ddZ7e8dkre9e7dS)u:module: watchdog.watchmedo :author: yesudeep@google.com (Yesudeep Mangalapilly) :author: contact@tiger-222.fr (Mickaël Schoentgen) :synopsis: ``watchmedo`` shell script utility. ) annotationsN)ArgumentParserRawDescriptionHelpFormatter)StringIO)dedent) TYPE_CHECKING)WatchdogShutdown load_classplatform)VERSION_STRING)BaseObserverSubclassCallable)leveltricksz python-pathcs.eZdZdZddfdd ZddZZS) HelpFormattera#A nicer help formatter. Help for arguments can be indented and contain new lines. It will be de-dented and arguments in the help will be separated by a blank line for better readability. Source: https://github.com/httpie/httpie/blob/2423f89/httpie/cli/argparser.py#L31 )max_help_positioncs||d<tj||dS)Nr)super__init__)selfrargskwargs __class__6/tmp/pip-unpacked-wheel-cstuilrs/watchdog/watchmedo.pyr:szHelpFormatter.__init__cCst|d}|S)Nz )rstrip splitlines)rtextwidthrrr _split_lines?szHelpFormatter._split_lines)__name__ __module__ __qualname____doc__rr __classcell__rrrrr0s rzCopyright 2011 Yesudeep Mangalapilly . 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)destcOs t||fS)z\Convenience function to properly format arguments to pass to the command decorator. )list)Z name_or_flagsrrrrargumentQsr,csfdd}|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) cs|jdd}t|j}j||td}|t|<|}|jdddddd |jd d ddd d D]$}|j|d |d |j |dqf|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)r6namedescparserZverbosity_groupargr cmd_aliasesparentrr decoratorbs zcommand..decoratorr)rrCrBrDrrArcommandXs  rEcCst||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)Z pathname_spec separatorrrr path_splitrsrHcCs&|dddD]}tj||qdS)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. Nr3)syspathinsert) pathnamesindexpathnamerrradd_to_sys_path}s rOc Cs8ddl}t|d}||W5QRSQRXdS)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)yamlopenZ safe_loadread)Ztricks_file_pathnamerQfrrr load_configs rU;cCs*||}||}|dgkr"g}||fS)z^Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). )rF)Z patterns_specZignore_patterns_specrGpatternsignore_patternsrrrparse_patternss    rZcCs^t|D]}||||q|ztdq&Wntk rP|YnX|dS)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. r5N)setschedulestarttimesleeprstopjoin)observerZ event_handlerrL recursiverNrrr observe_withs rdc CsT|D]J}t|D]8\}}t|}|f|}t|ddp<|} ||| |qqdS)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_directoryN)r+itemsr getattrr\) rbrrNrcZtrickr=value TrickClasshandlerZtrick_pathnamerrrschedule_trickss  rkfiles*zperform tricks from given file)nargshelpz --python-path.zPaths separated by z to add to the Python path.)defaultroz --intervalz --timeouttimeoutg?z?Use this as the polling interval/blocking timeout (in seconds).)r*rqtyperoz --recursive store_trueTz-Recursively monitor paths (defaults to True).)r(rqroz--debug-force-pollingz[debug] Forces polling.)r(roz--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).)rBc Cs|jrddlm}nl|jr(ddlm}nXts2|js>trLt rLddl m }n4|j r`ddl m}n |jrtddlm}n ddlm}tt|jg}|jD]}||jd}tj|sttjttj|t |}z |t!}Wn<t"k r}zt"d t!d |d |W5d }~XYnXt#|kr2t|t#tj$|pNtj%t&}t'||||j(|)|*|qzt+,d qvWn2t-k r|D]} | .| /qYnX|D]} | 0qd S)z;Command to execute tricks from a tricks configuration file.rPollingObserverKqueueObserverWindowsApiObserverInotifyObserverFSEventsObserverObserverrrzNo z key specified in rpNr5)1debug_force_pollingwatchdog.observers.pollingrvdebug_force_kqueuewatchdog.observers.kqueuerxrdebug_force_winapir is_windows)watchdog.observers.read_directory_changesrzdebug_force_inotifywatchdog.observers.inotifyr|debug_force_fseventswatchdog.observers.fseventsr~watchdog.observersrrOrH python_pathrlrrosrJexistsOSErrorerrnoENOENTstrerrorrUCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrkrcr]appendr^r_rZunschedule_allr`ra) rrZ observersZ tricks_filerbconfigreZdir_pathorrr tricks_fromsH1     *   r 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(rozgenerate-tricks-yamlc Csddl}t|j}t|t}|jD]}t|}||q&| }| | t |i}|t d7}|jdkr|js||}tj|nzlog..)r)rXrYrrurwryr{r}rrN)%watchdog.tricksrwatchdog.utilsrtracelogging getLoggerr!Z echo_classrZrXrYrrrrvrrrxrrr rrrzrrr|rrr~rrrrrdrrc)rrrrXrYrjrrbrrrlogms0H     rzDirectories to watch.z-cz --commandam 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*rqr(roz-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.cCsddlm}|jsd|_|jr,ddlm}n ddlm}t|j |j \}}||j|||j |j |j d}||jd}t|||j|jdS)zDCommand to execute shell commands in response to file system events.r)ShellCommandTrickNrur) shell_commandrXrYrrrr)rrrErrrvrrrZrXrYrrrrrrdrrc)rrrrXrYrjrbrrrrs"W   rz,Long-running command to run in a subprocess.)ro command_argsr@z Command arguments. Note: Use -- before the command arguments, otherwise watchmedo will try to interpret them. )metavarrnroz-dz --directoryZ DIRECTORYrzLDirectory to watch. Use another -d or --directory option for each directory.)r*rr(roz--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 sF|jrddlm}n ddlm}ddlddlm}|jsBdg|_|j drZt |jnt |j}j j htdrjfd d }D]}||qt|j|j\}}|jg}||j|||||j||j|j|jd } | ||jd } z2zt| | |j|jWnt k r2YnXW5| XdS) zLCommand to start a long-running subprocess and restart it on matched events.rrurN)AutoRestartTrickrpZSIGSIGHUPcs D]}|jqtdSr)rSIG_IGNr)Z_signumZ_framesignumrZtermination_signalsrrhandler_termination_signalsz0auto_restart..handler_termination_signal)rErXrYr stop_signalrZdebounce_interval_secondsrr)!rrrvrrrrrr startswithrgintSIGTERMrhasattraddrrZrXrYrEextendrrrrrr]rrr`rdrcr) rrrrrrrXrYrErjrbrrr auto_restartEsD_  "       rc@s eZdZdS)LogLevelExceptionN)r r!r"rrrrrsrcCsBt|jp g}|dkrtd|dkr.tdddddgd |S) Nr3z&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.ERRORWARNINGINFODEBUGr5)sumr1r)rr1rrr_get_log_level_from_argss rc Cst}|jdkrtdSz t|}WnPtk rz}z2td|jdtj dt |jWYdSd}~XYnXt d |z||Wntk rYdSXdS)zEntry-point function.Nr5zError: r)rZwatchdog)cli parse_argsr) print_helprrprintrrIstderrr9rrsetLevelr6KeyboardInterrupt)rZ log_levelexcrrrmains   r__main__)r)rV):r# __future__rrrros.pathrIr^argparserriortextwraprtypingrrrr r Zwatchdog.versionr Zwatchdog.observers.apir basicConfigrrrrr%rr;add_subparsersZ subparsersr9r,rEpathseprHrOrUrZrdrkfloatrrrrr Exceptionrrrr exitrrrrs             +. 4    F # U    \ 9