U ꥡcU`@sldZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZddlmZejejdd Zd ZGd d d e Zd ZeeedZejddedejddZiZddZgegfddZej fddZ!dddZ"ddZ#ddd Z$d!d"Z%d#d$Z&eed%d&d'd(ed)d*d+ej d,d-ed.d/d0d1e'd2d3ed4d5d6d7d8ed9d5d:d;edd5d?d;ed@d5dAd;edBd5dCd;g d gdDdEdFZ(eedGd&dHd(ed)d*d+ej d,d-edIddJd-edKdLdMd5dNdOgdPgdDdQdRZ)eedSd&d*dTdUedVdWdXdYd&dZd[ed\d]d^d_d`dad[edbdcddd5dedOedfd4dgd5dhdOed.d/d0d1e'did3edjd5dkd;ed9d5d:d;edd5d?d;ed@d5dAd;edBd5dCd;g dldmZ*eedSd&d*dndUedodpdddqd[edVdWdXdYd&dZd[ed\d]d^d_d`dad[edbdcdddrd5dedsedfd4dgd5dhdOed.d/d0d1e'did3edtdudvd5dwdOedxdydzd5d{dOed9d5d:d;g d|d}Z+eedd~deddd&ddedddSddddedVdWdXdYd&dZd[ed\d]d^d_d`dad[edbdcdddrd5dedsedfd4dgd5dhdOed.d/d0d1e'did3eddddd[ed9d5d:d;eddde'dd3g ddZ,Gddde-Z.ddZ/ddZ0e1dkrhe2e0dS)u :module: watchdog.watchmedo :author: yesudeep@google.com (Yesudeep Mangalapilly) :author: contact@tiger-222.fr (Mickaël Schoentgen) :synopsis: ``watchmedo`` shell script utility. N)ArgumentParserRawDescriptionHelpFormatter)StringIO)dedent)WatchdogShutdown load_class)VERSION_STRING)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__)selfr argskwargs __class__6/tmp/pip-unpacked-wheel-thtqfo2i/watchdog/watchmedo.pyr5szHelpFormatter.__init__cCst|d}|S)Nz )rstrip splitlines)rtextwidthrrr _split_lines:szHelpFormatter._split_lines)__name__ __module__ __qualname____doc__rr __classcell__rrrrr +s r zCopyright 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_flagsrrrrargumentLsr(csfdd}|S)aDecorator 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) rreplacerr add_parserr command_parsersadd_mutually_exclusive_group add_argument set_defaults)r2namedescparserZverbosity_groupargr cmd_aliasesparentrr decorator\s*   zcommand..decoratorr)rr?r>r@rr=rcommandSs rAcCst||S)z Splits 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_splitps rDcCs&|dddD]}tj||qdS)z Adds 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) pathnamesindexpathnamerrradd_to_sys_path|s rKc Cs8ddl}t|d}||W5QRSQRXdS)z Loads 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_pathnamerMfrrr load_configs  rQ;cCs*||}||}|dgkr"g}||fS)zc Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). )rB)Z patterns_specZignore_patterns_specrCpatternsignore_patternsrrrparse_patternss    rVcCs^t|D]}||||q|ztdq&Wntk rP|YnX|dS)al Single 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. r1N)setschedulestarttimesleeprstopjoin)observerZ event_handlerrH recursiverJrrr observe_withs r`c CsT|D]J}t|D]8\}}t|}|f|}t|ddp<|} ||| |qqdS)ao Schedules 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'itemsrgetattrrX) r^r rJr_Ztrickr9value TrickClasshandlerZtrick_pathnamerrrschedule_trickss  rgfiles*zperform tricks from given file)nargshelpz --python-path.zPaths separated by z to add to the Python path.)defaultrkz --intervalz --timeouttimeoutg?z?Use this as the polling interval/blocking timeout (in seconds).)r&rmtyperkz --recursive store_trueTz-Recursively monitor paths (defaults to True).)r$rmrkz--debug-force-pollingz[debug] Forces polling.)r$rkz--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).)r>c Cs|jrddlm}n\|jr(ddlm}nH|jrzlog..)r)rTrUrrqrsrurwryr{r}N)"watchdog.utilsrwatchdog.tricksrtracelogging getLoggerrZ echo_classrVrTrUrr~rrrrrrtrrrvrrrxrrrzrr|rnr`rr_)rrrrTrUrfr|r^rrrlog^s06      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&rmr$rkz-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)zN Command to execute shell commands in response to file system events. r)ShellCommandTrickNrqr{) shell_commandrTrUrrrr})rrrAr~rrrrr|rVrTrUrrrrnr`rr_)rrr|rTrUrfr^rrrrs$H   rz,Long-running command to run in a subprocess.)rk command_argsr<z Command arguments. Note: Use -- before the command arguments, otherwise watchmedo will try to interpret them. )metavarrjrkz-dz --directoryZ DIRECTORYrzLDirectory to watch. Use another -d or --directory option for each directory.)r&rr$rkz--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).c s.|jrddlm}n ddlm}ddlm}ddl|jsBdg|_|j dr\t |j}n t |j}j j jhfdd }D]}||qt|j|j\}}|jg}||j|||||j||jd } | ||jd } z2zt| | |j|jWntk rYnXW5| XdS) zV Command to start a long-running subprocess and restart it on matched events. rrqr{)AutoRestartTrickNrlZSIGcs D]}|jqtdSr)rSIG_IGNr)Z_signumZ_framesignumrZtermination_signalsrrhandler_termination_signalgsz0auto_restart..handler_termination_signal)rArTrUr stop_signalrr})r~rrrrr|rrrr startswithrcintSIGTERMrSIGHUPrVrTrUrAextendrrrrYrnr\r`r_r) rr|rrrrrTrUrArfr^rrr auto_restartsBA       rc@s eZdZdS)LogLevelExceptionN)rrrrrrrrsrcCsBt|jp g}|dkrtd|dkr.tdddddgd |S) Nr/z&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.ERRORWARNINGINFODEBUGr1)sumr-r)rr-rrr_get_log_level_from_argss rc Cst}|jdkrtdSz t|}WnNtk rx}z0td|jdtj dt |jWYdSd}~XYnXt d |||dS)zEntry-point function.Nr1zError: r)fileZwatchdog)cli parse_argsr% print_helprrprintrrEstderrr5rrsetLevelr2)rZ log_levelexcrrrmains   r__main__)r)rR)3rrrros.pathrErZargparserriortextwraprrrrZwatchdog.versionr basicConfigrrrr r!rr7add_subparsersZ subparsersr5r(rApathseprDrKrQrVr`rgfloatrrrrr ExceptionrrrrexitrrrrsD         9  2 #D  < 7