o *ήcF`@spdZddlZddlZddlZddlZddlZddlZddlmZm 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/ddZ0e1dkr6e2e0dSdS)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|i|dS)Nr )super__init__)selfr argskwargs __class__9/tmp/pip-target-vg8gfxp4/lib/python/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) name_or_flagsrrrrargumentLs r)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 i|d |j |dq3|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)r3namedescparserverbosity_groupargr cmd_aliasesparentrr decorator\s&   zcommand..decoratorr)rrAr@rBrr?rcommandSs rCcCst||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) pathname_spec separatorrrr path_splitps rGcCs&|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. Nr0)syspathinsert) pathnamesindexpathnamerrradd_to_sys_path|s rNcCsDddl}t|d}||WdS1swYdS)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)yamlopen safe_loadread)tricks_file_pathnamerPfrrr load_configs  $rV;cCs*||}||}|dgkrg}||fS)zc Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). )rD) patterns_specignore_patterns_specrFpatternsignore_patternsrrrparse_patternss   r]cCsZt|D] }||||q|z tdqty&|Ynw|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. Tr2N)setschedulestarttimesleeprstopjoin)observer event_handlerrK recursiverMrrr observe_withs     rhc CsX|D]'}t|D]\}}t|}|di|}t|ddp |} ||| |q qdS)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_directoryNr)r'itemsrgetattrr_) rer rMrgtrickr:value TrickClasshandlertrick_pathnamerrrschedule_trickssrqfiles*zperform tricks from given file)nargshelpz --python-path.zPaths separated by z to add to the Python path.)defaultruz --intervalz --timeouttimeoutg?z?Use this as the polling interval/blocking timeout (in seconds).)r&rwtyperuz --recursive store_trueTz-Recursively monitor paths (defaults to True).)r$rwruz--debug-force-pollingz[debug] Forces polling.)r$ruz--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|jr ddlm}n.|jrddlm}n$|jrddlm}n|j r(ddl m }n|j r2ddl m}nddlm}tt|jg}|jD]^}||jd}tj|s]ttjttj|t|}z|t}Wntyvtd t|fwt |vrt|t tj!|}|stj"t#}t$||||j%|&|'|qDz t()d qt*y|D] }|+|,qYnw|D]}|-qd S) zE Command to execute tricks from a tricks configuration file. rPollingObserverKqueueObserverWindowsApiObserverInotifyObserverFSEventsObserverObserverrxzNo %r key specified in %s.Tr2N).debug_force_pollingwatchdog.observers.pollingr|debug_force_kqueuewatchdog.observers.kqueuer~debug_force_winapi)watchdog.observers.read_directory_changesrdebug_force_inotifywatchdog.observers.inotifyrdebug_force_fseventswatchdog.observers.fseventsrwatchdog.observersrrNrG python_pathrrrxosrIexistsOSErrorerrnoENOENTstrerrorrVCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrqrgr`appendrarbrunschedule_allrcrd) rr observers tricks_filereconfigr dir_pathorrr tricks_froms\$             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$ruzgenerate-tricks-yamlcCsddl}t|j}t|t}|jD] }t|}||q| }| | t |i}|dt 7}|jdurJ|jsB||}tj|dStj|jsU||}t|jd}||WddS1slwYdS)zV Command to generate Yaml configuration for tricks named on the command line. rNz%s: ab)rPrGrrNrrrwrite generate_yamlgetvalueclosedumprrappend_to_filerrHstdoutrrIrrQ)rrP python_pathsoutput trick_pathrncontentheaderrrrtricks_generate_yaml,s(     "r directoriesz%Directories to watch. (default: '.').)rtrwruz-pz --patternz --patternsr[z9Matches event paths with these patterns (separated by ;).)r&rwruz-iz--ignore-patternz--ignore-patternsr\rXz9Ignores event paths with these patterns (separated by ;).z-Dz--ignore-directoriesignore_directorieszIgnores events for directories.z-Rrgz%Monitors the directories recursively.z2Use this as the polling interval/blocking timeout.z--tracez!Dumps complete dispatching trace.csddlm}ddlm}|jr t|j|j|fdddt |j |j \}}||||j d}|j r;ddlm}n.|jrEdd lm}n$|jrOdd lm}n|jrYdd lm}n|jrcdd lm}ndd lm}||jd}t|||j |j!dS)z; Command to log file system events to the console. r)echo) LoggerTrickcs |SN)info)msgclass_module_loggerrrs zlog..)r)r[r\rr{r}rrrrrN)"watchdog.utilsrwatchdog.tricksrtracelogging getLoggerr echo_classr]r[r\rrrr|rrr~rrrrrrrrrrrrxrhrrg)rrrr[r\rorrerrrlog^s0 6     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&rwr$ruz-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}|js d|_|jrddlm}nddlm}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)ShellCommandTrickNr{r) shell_commandr[r\rrrr)rrrCrrr|rrr]r[r\rrrrxrhrrg)rrrr[r\rorerrrrs$ H  rz,Long-running command to run in a subprocess.)ru command_argsr>z Command arguments. Note: Use -- before the command arguments, otherwise watchmedo will try to interpret them. )metavarrtruz-dz --directory DIRECTORYrzLDirectory to watch. Use another -d or --directory option for each directory.)r&rr$ruz--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:|jr ddlm}nddlm}ddlm}ddl|js!dg|_|j dr.t |j}nt |j}j j hfdd }D]}||qBt|j|j\}}|jg}||j|||||j||jd } | ||jd } z#z t| | |j|jWn tyYnwW| dSW| dS| w) zV Command to start a long-running subprocess and restart it on matched events. rr{r)AutoRestartTrickNrvSIGcsD] }|jqtr)rSIG_IGNr)_signum_framesignumrtermination_signalsrrhandler_termination_signalgsz0auto_restart..handler_termination_signal)rCr[r\r stop_signalrr)rrr|rrrrrr startswithrkintSIGTERMrr]r[r\rCextendrrrr`rxrhrgrrc) rrrrrrr[r\rCrorerrr auto_restartsJA         rc@s eZdZdS)LogLevelExceptionN)rrrrrrrrsrcCs>t|jpg}|dkrtd|dkrtdgdd|S)Nr0z&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.)ERRORWARNINGINFODEBUGr2)sumr.r)rr.rrr_get_log_level_from_argss rc Cst}|jdurtdSzt|}Wn&ty;}ztd|jdtj dt |jWYd}~dSd}~wwt d |||dS)zEntry-point function.Nr2zError: r)filewatchdog)cli parse_argsr% print_helprrprintrrHstderrr6rrsetLevelr3)r log_levelexcrrrmains   r__main__)r)rW)3rrrros.pathrHraargparserriortextwraprrrrwatchdog.versionr basicConfigrrrr r!rr8add_subparsers subparsersr6r)rCpathseprGrNrVr]rhrqfloatrrrrr ExceptionrrrrexitrrrrsH          9   2# D  <7