o hlc@s dZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZmZddlmZmZmZdd lmZerndd l mZmZdd lmZdd lmZdd lmZddl m!Z!ej"ej#ddZ$dZ%Gddde Z&dZ'e e'e&dZ(e(j)ddede(j*ddZ+iZ,e-e.e/efZ0dd!d"Z1e+dd#dd+d,Z2ej3d-dd1d2Z4dd3dd8d9Z5ddd-ddBdCZ7ddJdKZ8ddNdOZ9e2e1dPdQdRdSe1dTdUdVej3dWdXe1dYdZd[d\e:d]d^e1d_d`dadbdce1ddd`dedfe1dgd`dhdfe1did`djdfe1dkd`dldfe1dmd`dndfg dgdoddqdrZ;e2e1dsdQdtdSe1dTdUdVej3dWdXe1duddvdXe1dwdxdyd`dzd{gd|gdodd}d~Ze2e1d,dde1dddQdde1ddddddde1dddddQdde1ddddddde1ddddd`dde1dd_dHd`dd{e1dYdZd[d\e:dd^e1ddddde1ddd`dedfe1ddde:dd^e1ddde:dd^e1dddadddg dddĄZ?GddƄde@ZAdddȄZBdddʄZCeDdkreEeCdSdS)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_CHECKINGAny)WatchdogShutdownError load_classplatform)VERSION_STRING) Namespace_SubParsersAction)Callable)FileSystemEventHandler) ObserverType) BaseObserver)leveltricksz python-pathcs<eZdZdZdddfd d ZdddZdddZZS) 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_positionargsrrintkwargsreturnNonecs||d<tj|i|dS)Nr)super__init__)selfrrr __class__F/var/www/vscode/kcb/lib/python3.10/site-packages/watchdog/watchmedo.pyr0szHelpFormatter.__init__strcCsdt|jdS)N<>)type__name__)rr"r"r#__repr__5szHelpFormatter.__repr__textwidth list[str]cCst|d}|S)Nz )rstrip splitlines)rr*r+r"r"r# _split_lines8szHelpFormatter._split_lines)rrrrrrrr)rr$)r*r$r+rrr,)r( __module__ __qualname____doc__rr)r/ __classcell__r"r"r r#r&s  ru,Copyright 2018-2024 Mickaël Schoentgen & contributors Copyright 2014-2018 Thomas Amland & contributors Copyright 2012-2014 Google, Inc. Copyright 2011-2012 Yesudeep Mangalapilly Licensed under the terms of the Apache license, version 2.0. Please see LICENSE in the source code for more information.)epilogformatter_classz --versionversion)actionr6 top_command)dest name_or_flagsr$rrrArgumentcOs t||fS)z\Convenience function to properly format arguments to pass to the command decorator. )list)r:rr"r"r#argumentNs r=)parent cmd_aliasesrlist[Argument]r>!_SubParsersAction[ArgumentParser]r?list[str] | Nonercsdfdd }|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) funcrrcs|jdd}t|jp d}j|pg|td}|t|<|}|jddddd d |jd d ddd d D]\}}|j|i||j |dq7|S)N_-)aliases descriptionr5z-qz--quiet verbosity append_const)r9r7constz-vz --verbose)rC) r(replacerr2 add_parserrcommand_parsersadd_mutually_exclusive_group add_argument set_defaults)rCnamedescparserverbosity_groupr:rrr?r>r"r# decoratords zcommand..decoratorN)rCrrrr")rr>r?rYr"rXr#commandUs rZ) separator pathname_specr[r,cCs ||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. split)r\r[r"r"r# path_splitts r_)index pathnamesr`rrcCs&|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. NrK)syspathinsert)rar`pathnamer"r"r#add_to_sys_paths rftricks_file_pathnamedictcCsDddl}t|d}||WdS1swYdS)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)rgrjfr"r"r# load_configs  $ro; patterns_specignore_patterns_spectuple[list[str], list[str]]cCs*||}||}|dgkrg}||fS)z^Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). rFr])rqrrr[patternsignore_patternsr"r"r#parse_patternss   rvobserverr event_handlerr recursiveboolcCs\t|D] }|j|||dq|z tdqty'|Ynw|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. ryTrMN)setschedulestarttimesleepr stopjoin)rwrxraryrer"r"r# observe_withs     r list[dict]rec CsV|D]&}|D]\}}t|}|di|}t|ddp|} |j|| |dqqdS)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_directoryNr{r")itemsr getattrr}) rwrrerytrickrTvalue trick_clshandlertrick_pathnamer"r"r#schedule_trickss rfiles*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).)r9rr'rz --recursive store_trueTz-Recursively monitor paths (defaults to True).)r7rrz--debug-force-pollingz[debug] Forces polling.)r7rz--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?r c Cs|jr ddlm}|}n@|jrddlm}|}n4ts|js#tr,t r,ddl m }|}n |j r8ddl m}|}n|jrDddlm}|}nddlm}|}tt|jg}|jD]h} ||jd} tj| sqttjttj| t | } z| t!} Wnt"y} zd t!d | d }t"|| d } ~ wwt#| vrt| t#tj$| ptj%t&}t'| | ||j(d | )|*| qXz t+,dqt-y|D] }|.|/qYnw|D]}|0qd S)z;Command to execute tricks from a tricks configuration file.rPollingObserverKqueueObserverWindowsApiObserverInotifyObserverFSEventsObserverObserverrzNo z key specified in rNr{TrM)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.observersrrfr_ python_pathrrosrcexistsOSErrorerrnoENOENTstrerrorroCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrryr~appendrrr unschedule_allrr)rr observer_clsrrrrr observers tricks_filerwconfigreerrordir_pathor"r"r# tricks_fromsd1                 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.)r9r7rzgenerate-tricks-yamlc Csddl}t|j}t|t}|jD] }t|}||q| }| | t |i}|t d7}|jdurK|jsC||}tj|dStj|jsV||}t|jddd}||WddS1sowYdS)zLCommand to generate Yaml configuration for tricks named on the command line.rNz: azutf-8)encoding)rjr_rrfrrr write generate_yamlgetvalueclosedumprrappend_to_filerrbstdoutrrcrrk) rrj python_pathsoutput trick_pathrcontentheaderfiler"r"r#tricks_generate_yamlHs(!    "r directoriesz%Directories to watch. (default: '.').)rrrz-pz --patternz --patternsrtz9Matches event paths with these patterns (separated by ;).)r9rrz-iz--ignore-patternz--ignore-patternsrurFz9Ignores event paths with these patterns (separated by ;).z-Dz--ignore-directoriesignore_directorieszIgnores events for directories.z-Rz%Monitors the directories recursively.z2Use this as the polling interval/blocking timeout.c Csddlm}t|j|j\}}||||jd}|jr#ddlm}|}n@|j r/ddl m }|}n4t s4|j s:t rCtrCddlm}|}n |jrOddlm} | }n|jr[ddlm} | }ndd lm} | }||jd } t| ||j|jd d S) z1Command to log file system events to the console.r) LoggerTrick)rtrurrrrrrrrr{N)watchdog.tricksrrvrtrurrrrrrrrrr rrrrrrrrrrrrrrry) rrrtrurrrrrrrrrwr"r"r#logs4 G       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)r9rr7rz-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.c Csddlm}|js d|_|jrddlm}|}nddlm}|}t|j |j \}}||j|||j |j |j d}||jd}t|||j|jddS) zDCommand to execute shell commands in response to file system events.r)ShellCommandTrickNrr)rtrurrrrr{)rrrZrrrrrrvrtrurrrrrrry) rrrrrrtrurrwr"r"r# shell_commands& W   rz,Long-running command to run in a subprocess.)r command_argsargz 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.)r9rr7rz--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 sb|jr ddlm}|}nddlm}|}ddlddlm}|js%dg|_|j dr1t |jnt |j}j j htdrGjdfdd }D]}||qQt|j|j\}} |jg} | |j|| || |j||j|j|jd} | ||jd} z$z t| | |j|jdWn tyYnwW| dSW| dS| w)zLCommand to start a long-running subprocess and restart it on matched events.rrrN)AutoRestartTrickrSIGSIGHUP_signumsignal._SIGNUM_frameobjectrrcsD] }|jqt)N)rSIG_IGNr )rrsignumrtermination_signalsr"r#handler_termination_signalsz0auto_restart..handler_termination_signal)rtrur stop_signalrdebounce_interval_secondsrrr{)rrrrrr)!rrrrrrrrr startswithrrSIGTERMrhasattraddrrvrtrurZextendrrrrrr~rrryr r) rrrrrrrrrtrurZrrwr"rr# auto_restartgsP_   "       rc@s eZdZdS) LogLevelErrorN)r(r0r1r"r"r"r#rsrcCsFt|jpg}|dkrd}t||dkrd}t|gdd|S)NrKz&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.)ERRORWARNINGINFODEBUGrM)sumrIr)rrIrr"r"r#_get_log_level_from_argssrc Cst}|jdurtdSzt|}Wn'ty<}ztd|jdtj dt |jWYd}~dSd}~wwt d |z||WdStyWYdSw)zEntry-point function.NrMzError: r)rwatchdog)cli parse_argsr8 print_helprrprintrrbstderrrPlogging getLoggersetLevelrCKeyboardInterrupt)r log_levelexcr"r"r#mains&    r__main__)r:r$rrrr;)rr@r>rAr?rBrr)r\r$r[r$rr,)rar,r`rrr)rgr$rrh)rqr$rrr$r[r$rrs) rwrrxrrar,ryrzrr) rwrrrrer$ryrzrr)rr rr)rr rr$)rr)Fr2 __future__rrrros.pathrbrargparserriortextwraprtypingrrwatchdog.utilsr r r watchdog.versionr r rrwatchdog.eventsrrrwatchdog.observers.apir basicConfigrrrrr4r rRadd_subparsers subparsersrPtupler<r$r;r=rZpathsepr_rfrorvrrfloatrrrrr Exceptionrrrr(exitr"r"r"r#s                 + .A    E+  U    \=