"dzb"dZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZddlmZddlmZdd lmZmZdd lmZej2ej4 d Zd ZGdde ZdZe eeZejAddeejCdZ"iZ#dZ$ge"gfdZ%ejLfdZ'ddZ(dZ)ddZ*dZ+dZ,e%e$dd d!"e$d#d$d%ejLd&'e$d(d)d*d+e-d,-e$d.d/d0d12e$d3d/d45e$d6d/d75e$d8d/d95e$d:d/d;5e$dd?Z.e%e$d@d dA"e$d#d$d%ejLd&'e$dBddC'e$dDdEdFd/dGHgdIg>dJZ/e%e$dKd d$dLMe$dNdOdPdQd dRSe$dTdUdVdWdXdYSe$dZd[d\d/d]He$d^d.d_d/d`He$d(d)d*d+e-da-e$dbd/dc5e$d3d/d45e$d6d/d75e$d8d/d95e$d:d/d;5e$ds&d|!!#f,  r)__name__ __module__ __qualname____doc__rr! __classcell__)rs@rrr/s12* !rrzCopyright 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)destct||fS)z\Convenience function to properly format arguments to pass to the command decorator. )list) name_or_flagsrs rargumentr0Ps   &&rcfd}|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) c|jjdd}t|j}j ||t }|t |<|j}|jddddd |jd d ddd D],}|j|d i|d |j|.|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) r<namedescparserverbosity_groupargr cmd_aliasesparents r decoratorzcommand..decoratoras}}$$S#.dll#"" dK# !' ==?$$ )+nB %  $$ +Ka %  +C F  Q 23q6 2   T  * + r)rrIrHrJs``` rcommandrLWs& rc6t|j|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 separators r path_splitrQws  ##I. //rc^|dddD]"}tjj||$y)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. Nr9)syspathinsert) pathnamesindexpathnames radd_to_sys_pathrYs-ddO) x()rcddl}t|d5}|j|jcdddS#1swYyxYw)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_pathnamer\fs r load_configrbs; "D )(Q~~affh'(((s :Ac^|j|}|j|}|dgk(rg}||fS)zc Parses pattern argument specs and returns a two-tuple of (patterns, ignore_patterns). )rN) patterns_specignore_patterns_specrPpatternsignore_patternss rparse_patternsris> ""9-H*00;O2$ o &&rct|D]}|j||||j tjd#t $r|j YnwxYw|jy)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. r;N)setschedulestarttimesleepr stopjoin)observer event_handlerrV recursiverXs r observe_withrusl N>-9=> NN JJqM   MMOsA A('A(c|D]Z}t|jD]<\}}t|}|di|}t|ddxs|} |j || |>\y)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_directoryNrK)r.itemsr getattrrl) rrrrXrttrickrCvalue TrickClasshandlertrick_pathnames rschedule_tricksrsrB . BKD%#D)J )5)G$W.@$GS8N   g~y A  BBrfiles*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,rtyperz --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).)rHc |jrddlm}n}|jrddlm}njt s |js%t r&tjjdrddl m }n,|jrddlm}n|j rddlm}nddlm}t+t-|j.g}|j0D]+}||j2 }t4j6j9|st5j@t<j>|tC|} |tD}tH|vrt+|tHt4j6jK|}|s1t4j6jMt5jN}tQ||||jR|jU|jW|. tYjZd #tF$rtGd tDd |d wxYw#t\$r*|D]"}|j_|ja$YnwxYw|D]}|jcy)zE Command to execute tricks from a tricks configuration file. rPollingObserverKqueueObserverwinWindowsApiObserverInotifyObserverFSEventsObserverObserverrzNo z key specified in rr;N)2debug_force_pollingwatchdog.observers.pollingrdebug_force_kqueuewatchdog.observers.kqueuerrdebug_force_winapirSplatform startswith)watchdog.observers.read_directory_changesrdebug_force_inotifywatchdog.observers.inotifyrdebug_force_fseventswatchdog.observers.fseventsrwatchdog.observersrrYrQ python_pathrrosrTexistsOSErrorerrnoENOENTstrerrorrbCONFIG_KEY_TRICKSKeyErrorCONFIG_KEY_PYTHON_PATHdirnamerelpathgetcwdrrtrmappendrnror unschedule_allrprq) rr observers tricks_filerrconfigrdir_pathos r tricks_fromrsj J H 7 7]s||OfOfglOm\ ! !J " "L 0Jt//01Izz# DLL1ww~~k*%,, ELL(A;O O[) -.F "V + F#9: ;77??;/wwryy{3H&(DNNC"/#2 JJqM! '**<[O1M  $  A    FFH  s; H-H' H$'0II 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 }|j D],}t |}|j|j.|j}|j|jt|i}|tdz }|j1|js||z}t j"j|yt$j&j)|js||z}t+|jdd5}|j|dddy#1swYyxYw)zV Command to generate Yaml configuration for tricks named on the command line. rNz: azutf-8)encoding)r\rQrrYrrr write generate_yamlgetvalueclosedumprrappend_to_filerrSstdoutrrTrr]) rr\ python_pathsoutput trick_pathr|contentheaderfiles rtricks_generate_yamlrDsFd../LL! ZF&&1  +  Z--/01ooG LLN YY. = >F "#3''F "w&G !ww~~d112w&G $%%sW =  JJw    s 0E  E directoriesz%Directories to watch. (default: '.').)rrrz-pz --patternz --patternsrgz9Matches event paths with these patterns (separated by ;).)r,rrz-iz--ignore-patternz--ignore-patternsrhrdz9Ignores event paths with these patterns (separated by ;).z-Dz--ignore-directoriesignore_directorieszIgnores events for directories.z-Rrtz%Monitors the directories recursively.z2Use this as the polling interval/blocking timeout.z--tracez!Dumps complete dispatching trace.cddlm}ddlm}|jr5t j |j|j|fdt|j|j\}}||||j}|jrddlm}n}|j rddlm}njt&s |j(s%t&r&t*j,j/d rdd lm}n,|j4rdd lm}n|j:rdd lm}ndd l m!}||jD}tG|||jH|jJy)z; Command to log file system events to the console. r) LoggerTrick)echoc&j|SN)info)msgclass_module_loggers rzlog..s7J7O7OPS7Tr)r)rgrhrrrrrrrrrN)&watchdog.tricksrwatchdog.utilsrtracelogging getLoggerr# echo_classrirgrhrrrrrrrrrrSrrrrrrrrrrrrrrurrt) rrrrgrhr}rrrrs @rlogrs\,# zz%// 0F0FG  +TU .t}}d>R>R SHo'22G J H 7 7]s||OfOfglOm\ ! !J " "L 0 -H7D$4$4dnnErzDirectories to watch.z-cz --commandrLam 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.cddlm}|jsd|_|jrddlm}nddlm}t|j|j\}}||j|||j|j|j}||j}t|||j |j"y)zN Command to execute shell commands in response to file system events. r)ShellCommandTrickNrr) shell_commandrgrhrrrr)rrrLrrrrrrirgrhrrrrrurrt)rrrrgrhr}rrs rrrsv2 <<  J/ .t}}d>R>R SHoll'22.. 44 G -H7D$4$4dnnErz,Long-running command to run in a subprocess.)r command_argsrGz 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  |jrddlm}nddlm}ddl ddlm}|jsdg|_|j jdrt |j }nt|j } j jh t dr j j  fd } D]} j ||t#|j$|j&\}}|j(g}|j+|j,|||||j.||j0|j2|j4 } | j7||j8 } t;| | |j|j<| jAy#t>$rYwxYw#| jAwxYw) zV Command to start a long-running subprocess and restart it on matched events. rrrN)AutoRestartTrickrSIGSIGHUPcVD]}j|j tr)rSIG_IGNr )_signum_framesignumrtermination_signalss rhandler_termination_signalz0auto_restart..handler_termination_signals*) 2F MM&&.. 1 2r)rLrgrhr stop_signalrdebounce_interval_secondsrr)!rrrrrrrrrrryintSIGTERMrhasattraddrrirgrhrLextendrrrrrrmrrurtr rp) rrrrrrrgrhrLr}rrrrs @@r auto_restartrdsL J/0   5 {{e$fdkk2 $++& ">>6==9vx  . &: f89:!/t}}d>R>R SHo||nG NN4$$%'22??"&"8"8 $ < < G MMO -HXw(8(8$..I        s$"F99 GGGGGc eZdZy)LogLevelExceptionN)r"r#r$rKrrrrsrrct|jxsg}|dkr td|dkDr tdgdd|zS)Nr9z&-q/--quiet may be specified only once.z,-v/--verbose may be specified up to 2 times.)ERRORWARNINGINFODEBUGr;)sumr7r)rr7s r_get_log_level_from_argsr sJDNN(b)I2~ HII1} NOO 0Y ??rctj}|jtjy t |}tjdj| |j|y#t $rV}t d|jdtjt|jjYd}~yd}~wwxYw#t$rYywxYw)zEntry-point function.Nr;zError: r)rwatchdog)cli parse_argsr+ print_helpr rprintrrSstderrr?rrsetLevelr<KeyboardInterrupt)r log_levelexcs rmainrs >> D  ,T2  j!**95 $    }%CJJ7(()446 s* A9'C9 CA CC C'&C'__main__)r);)9r% __future__rrrros.pathrSrnargparserriortextwraprtypingrwatchdog.observers.apir rr r watchdog.versionr basicConfigrrrrr'r rAadd_subparsers subparsersr?r0rLpathseprQrYrbrirurfloatrrrrr Exceptionrr rr"exitrKrrr(s@"#   @ ?7+',,'&!/!( 4FMBYG   ]  3 'JB@)+ 0 ) ( '0B, *JK &rzzn4OP   R    @   #L?X   "0  ".  $1  #3 O,Z ]/`7a/`7t  H  &rzzn4OP  C    H  %8((;> ?> >  8     L      "L     "%2     8     E    l1T   #L?X   "0  ".  $1  #3 EGIT"FUIT"FJ c3=TU    2    L      "L     "%2     8     E     #W     &B    #L?X cTVnFoVnF8 !OP     "      L      "L     "%2     8     E    I   #L?X   )    !$K    ** A  m]_@<A_@<~  @ . z CHHTVr