xjlcdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZmZddlmZmZmZdd lmZer dd l mZmZdd lmZdd lmZdd lmZddl m!Z!ej"ej#dZ$dZ%Gdde Z&dZ'e e'e&Z(e()ddee(*dZ+iZ,e-e.e/efZ0dd!Z1e+dd"dd*Z2ej3d+dd/Z4dd0dd5Z5dd8Z6d9d+dd=Z7ddDZ8ddGZ9e2e1dHdIdJKe1dLdMdNej3dOPe1dQdRdSdTe:dUVe1dWdXdYdZ[e1d\dXd]^e1d_dXd`^e1dadXdb^e1dcdXdd^e1dedXdf^g dggddiZ;e2e1djdIdkKe1dLdMdNej3dOPe1dlddmPe1dndodpdXdqrgdsggddtZ<e2e1dudIdMdvwe1dxdydzd{dId|}e1d~ddddd}e1ddddXdre1ddWdBdXdre1dQdRdSdTe:dVe1d\dXd]^e1d_dXd`^e1dadXdb^e1dcdXdd^e1dedXdf^g ddZ=e2e1dudIdMdwe1ddddd}e1dxdydzd{dId|}e1d~ddddd}e1dddddXde1ddWdBdXdre1dQdRdSdTe:dVe1ddddXdre1ddddXdre1d\dXd]^g ddZ>e2e1dde1dddIde1ddduddde1dxdydzd{dId|}e1d~ddddd}e1dddddXde1ddWdBdXdre1dQdRdSdTe:dVe1dddd}e1d\dXd]^e1ddde:dVe1ddde:dVe1dddYddg ddZ?Gdde@ZAddZBddZCeDdkrejEeCdSdS)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-pathc:eZdZdZdddfd Zdd ZddZxZS) 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_positionargsr rintkwargsreturnNonecD||d<tj|i|dS)Nr)super__init__)selfrrr __class__s CC:\Projects\Historical\venv\Lib\site-packages\watchdog/watchmedo.pyr!zHelpFormatter.__init__0s0&7"#$)&)))))strc2dt|jdS)N<>)type__name__)r"s r$__repr__zHelpFormatter.__repr__5s)4::&))))r%textwidth list[str]crt|dz}|S)Nz )rstrip splitlines)r"r-r.s r$ _split_lineszHelpFormatter._split_lines8s.d||!!##f,   r%)rr rrrr rr)rr&)r-r&r.rrr/)r+ __module__ __qualname____doc__r!r,r3 __classcell__)r#s@r$rr&s~=>******** ****!!!!!!!!r%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)actionr: top_command)dest name_or_flagsr&rr rArgumentc$t||fS)z\Convenience function to properly format arguments to pass to the command decorator. )list)r>rs r$argumentrBNs    &&r%)parent cmd_aliasesrlist[Argument]rC!_SubParsersAction[ArgumentParser]rDlist[str] | Nonercdfd }|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) funcrrc|jdd}t|jpd} |pg|t }|t |<|}|ddddd |d d ddd D](\}}|j|i|| |)|S)N_-)aliases descriptionr9z-qz--quiet verbosity append_const)r=r;constz-vz --verbose)rI) r+replacerr6 add_parserrcommand_parsersadd_mutually_exclusive_group add_argument set_defaults) rInamedescparserverbosity_groupr>rrrDrCs r$ decoratorzcommand..decoratords}$$S#..dl(b))""41BPTfs"tt & ==??$$T9;~eg$hhh$$T;[Q_gh$iii%) + + !M6 F  9& 9 9 9   T  * * * * r%)rIrrr)rrCrDr_s``` r$commandraUs5         r%) separator pathname_specrbr/c,||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)rcrbs r$ path_splitrgts   y ) ))r%)index pathnamesrhrrcb|dddD]"}tj||#dS)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. NrR)syspathinsert)rirhpathnames r$add_to_sys_pathros@dddO)) x(((())r%tricks_file_pathnamedictcddl}t|d5}||cdddS#1swxYwYdS)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)rprtfs r$ load_configrysKKK "D ) )(Q~~affhh''((((((((((((((((((s'A  A A ; patterns_specignore_patterns_spectuple[list[str], list[str]]cp||}||}|dgkrg}||fS)z^Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). rMre)r{r|rbpatternsignore_patternss r$parse_patternsrsG ""9--H*00;;O2$ _ $$r%observerr event_handlerr recursiveboolc t|D]}||||| tjd#t $r|YnwxYw|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. rTrTN)setschedulestarttimesleepr stopjoin)rrrirrns r$ observe_withrs$ NNHH-YGGGG NN  JqMMM    MMOOOOOsAA76A7 list[dict]rnc|D]^}|D]G\}}t|}|di|}t|ddp|} ||| |H_dS)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_directoryNrr`)itemsr getattrr) rrrnrtrickr[value trick_clshandlertrick_pathnames r$schedule_tricksrsLL ;;== L LKD%"4((Ii((%((G$W.@$GGS8N   g~  K K K K  LLLr%files*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=rr*rz --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).)rDrc|jr ddlm}|}ni|jr ddlm}|}nYt s|jst rtj r ddl m }|}n(|j r ddl m}|}n|jr ddlm}|}nddlm}|}t)t+|jg}|jD]k} ||j} t2j| s7t9t:jt3jt:j| tA| } | tB} n0#tD$r#} d tBd | d }tE|| d } ~ wwxYwtF| vrt)| tFt2j$| p/t2j%t3j&}tO| | ||j( | )|*| m tWj,d#tZ$r0|D]*}|.|/+YnwxYw|D]}|0d S)z;Command to execute tricks from a tricks configuration file.rPollingObserverKqueueObserverWindowsApiObserverInotifyObserverFSEventsObserverObserverrzNo z key specified in rNrTrT)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.observersrrorg python_pathrrosrlexistsOSErrorerrnoENOENTstrerrorryCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrrrappendrrr unschedule_allrr)rr observer_clsrrrrr observers tricks_filerconfigreerrordir_pathos r$ tricks_fromrsb  >>>>>>&  <<<<<<%   7 ] xObOdOd PPPPPP) !  >>>>>>& "  @@@@@@'  0///// Jt/00111Iz## < 555w~~k** P%, EL(A(A;OO O[)) )-.FF ) ) )Q+QQQQQE5//q ( ) "V + + F#9: ; ; ;7??;//O27??29;;3O3O&(dnMMMM""""  JqMMM    A      FFHHHH   s* D,, E6EEH((7I"!I" 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 }|jD]8}t |}||9| }| | t|i}|tdz }|j-|js||z}t j|dSt$j|js||z}t+|jdd5}||ddddS#1swxYwYdS)zLCommand to generate Yaml configuration for tricks named on the command line.rNz: azutf-8)encoding)rtrgrrorrr write generate_yamlgetvalueclosedumprrappend_to_filerrkstdoutrrlrru) rrt python_pathsoutput trick_pathrcontentheaderfiles r$tricks_generate_yamlrHsBKKKd.//LL!!! ZZF&00 z**  Y,,..////ooG LLNNN YY. = > >F "''''F " 'w&G !!!!!w~~d122 'w&G $%sW = = =  JJw                     s;EE"%E" directoriesz%Directories to watch. (default: '.').)rrrz-pz --patternz --patternsrz9Matches event paths with these patterns (separated by ;).)r=rrz-iz--ignore-patternz--ignore-patternsrrMz9Ignores 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.cddlm}t|j|j\}}||||j}|jr ddlm}|}ni|j r ddl m }|}nYts|j strtjr ddlm}|}n(|jr ddlm} | }n|jr ddlm} | }ndd lm} | }||j } t7| ||j|j d S) z1Command to log file system events to the console.r) LoggerTrick)rrrrrrrrrrrN)watchdog.tricksrrrrrrrrrrrrrr rrrrrrrrrrrrrrr) rrrrrrrrrrrrrs r$logrsuN,+++++ .t}d>R S SHok'2G  >>>>>>&  <<<<<<%   7 ] xObOdOd PPPPPP) !  >>>>>>& "  @@@@@@'  0///// |DL111H7D$4OOOOOOr%zDirectories to watch.z-cz --commandraam 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.c>ddlm}|jsd|_|jr ddlm}|}nddlm}|}t|j |j \}}||j|||j |j |j }||j}t|||j|jdS) zDCommand to execute shell commands in response to file system events.r)ShellCommandTrickNrr)rrrrrrr)rrrarrrrrrrrrrrrrrr) rrrrrrrrrs r$ shell_commandrsn211111 <   >>>>>>& ////// .t}d>R S SHo '2. 4 G|DL111H7D$4OOOOOOr%z,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.)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 t |jr ddlm}|}nddlm}|}ddl ddlm}|jsdg|_|j drt |jnt|j} j j ht dr jd fd }D]} ||t#|j|j\}} |jg} | |j|| || |j||j|j|j} | ||j} t;| | |j|jn#t>$rYnwxYw| dS#| wxYw)zLCommand to start a long-running subprocess and restart it on matched events.rrrN)AutoRestartTrickrSIGSIGHUP_signumsignal._SIGNUM_frameobjectrrcRD]}|jt)N)rSIG_IGNr )rrsignumrtermination_signalss r$handler_termination_signalz0auto_restart..handler_termination_signals1) 2 2F MM&&. 1 1 1 1##r%)rrr stop_signalrdebounce_interval_secondsrrr)rrrrrr)!rrrrrrrrr startswithrrSIGTERMrhasattraddrrrrraextendrrrrrrrrrr r)rrrrrr r rrrrarrrrs @@r$ auto_restartrgs.~  >>>>>>& ////// MMM000000  !537+2H2H2O2Oe'&$+...UXY]YdUeUeK">6=9vx  / ...$$$$$$$ &:: f89999 .t}d>R S SHo|nG NN4$%%%'2?"&"8 $ <   G MMOOO|DL111HXw(8DNSSSSS         s*E;:F!; FF!FF!!F7ceZdZdS) LogLevelErrorN)r+r4r5r`r%r$rrsDr%rct|jpg}|dkrd}t||dkrd}t|gdd|zS)NrRz&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.)ERRORWARNINGINFODEBUGrT)sumrPr)rrPrs r$_get_log_level_from_argsrscDN(b))I2~~8E"""1}}>E""" 0 0 0Y ??r%ct}|jtdS t |}ne#t $rX}t d|jdtj t|jYd}~dSd}~wwxYwtj d | ||n#t$rYdSwxYwdS)zEntry-point function.NrTzError: r)rwatchdog)cli parse_argsr< print_helprrprintrrkstderrrWlogging getLoggersetLevelrIKeyboardInterrupt)r log_levelexcs r$mainr*s  >>  D  q,T22  % %%CJ7777()44666qqqqq j!!**9555 $ ss 1s*A B/A B**B/C00 C>=C>__main__)r>r&rr rr?)rrErCrFrDrGrr)rcr&rbr&rr/)rir/rhrrr)rpr&rrq)r{r&r|r&rbr&rr}) rrrrrir/rrrr) rrrrrnr&rrrr)rrrr)rrrr&)rr)Fr6 __future__rrr$ros.pathrkrargparserriortextwraprtypingrr watchdog.utilsr r r watchdog.versionr rrrwatchdog.eventsrrrwatchdog.observers.apir basicConfigrrrrr8rrYadd_subparsers subparsersrWtuplerAr&r?rBrapathseprgroryrrrfloatrrrrr Exceptionrrr*r+exitr`r%r$r>s  #"""""   @@@@@@@@%%%%%%%%FFFFFFFFFF++++++455555555666666//////333333',''''&!!!!!/!!!. 4nFMBBBYGGG   ]  3 3  cC ''''1;$( >8:z******;< ) ) ) ) ) ) ( ( ( (HK % % % % % %:LLLL* *JKKK PrzPPP     R      @    (D]^^^ "0    ".    $1    #3   K*V Y---\>>>]--\>B  H    PrzPPP    C      H    %8((;>   ?> :  8       L        "L       "%2       8       E     (D]^^^ "0    ".    $1    #3   {BDDJ(P(P(PKDDJ(PV c3=TUUU      2    L        "L       "%2       8       E       #W       &B     (D]^^^cRTTjPPPkTTjP< !OPPP     _        L        "L       "%2       8       E      I    (D]^^^ l      !$K      ** A    eY[[x:::y[[x:z     I   @@@@    . z CHTTVVr%