j3ddlmZddlZddlZddlZddlmZddlmZm Z ddl m Z dZ dZ Gdde ZGd d ZGd d eZGd deZGddeZGdde Zy)) annotationsN)Path) BaseThreadProtocol)SkipRepeatsQueueceZdZdZy) EventQueuea.Thread-safe event queue based on a special queue that skips adding the same event (:class:`FileSystemEvent`) multiple times consecutively. Thus avoiding dispatching multiple event handling calls when multiple identical events are produced quicker than an observer can consume them. N)__name__ __module__ __qualname____doc__S/var/www/photos/backend/venv/lib/python3.12/site-packages/watchdog/observers/api.pyr r srr cpeZdZdZd dZedZedZedZedZ dZ d Z d Z d Z y) ObservedWatchzAn scheduled watch. :param path: Path string. :param recursive: ``True`` if watch is recursive; ``False`` otherwise. :param event_filter: Optional collection of :class:`watchdog.events.FileSystemEvent` to watch Nct|tr t|n||_||_|t ||_yd|_yN) isinstancerstr_path _is_recursive frozenset _event_filter)selfpath recursive event_filters r__init__zObservedWatch.__init__2s:",T4"8SYd &8D8PY|4VZrc|jS)z"The path that this watch monitors.)rrs rrzObservedWatch.path7szzrc|jS)z;Determines whether subdirectories are watched for the path.)rr"s r is_recursivezObservedWatch.is_recursive<!!!rc|jS)z.Collection of event types watched for the path)rr"s rrzObservedWatch.event_filterAr%rcH|j|j|jfSr)rr$rr"s rkeyzObservedWatch.keyFsyy$++T->->>>rc4|j|jk(Srr(rwatchs r__eq__zObservedWatch.__eq__Jxx599$$rc4|j|jk7Srr*r+s r__ne__zObservedWatch.__ne__Mr.rc,t|jSr)hashr(r"s r__hash__zObservedWatch.__hash__PsDHH~rc|j1djtd|jD}d|}nd}dt|jd|j d|j |dS) N|c34K|]}|jywr)r ).0_clss r z)ObservedWatch.__repr__..Us.[t}}.[sz, event_filter=)rjoinsortedtyper rr$)revent_filter_strs r__repr__zObservedWatch.__repr__Ss{    ("xx.[IZIZ.[([\ !01A0BC ! 4:&&'wtyym?4K\K\J]^n]oopqqrr)r r r rr propertyrr$rr(r-r0r3rArrrrr'sr[ """"??%%rrrcZeZdZdZedffd ZedZedZdZ dZ dZ xZ S) EventEmitteraProducer thread base class subclassed by event emitters that generate events and populate a queue with them. :param event_queue: The event queue to populate with generated events. :type event_queue: :class:`watchdog.events.EventQueue` :param watch: The watch to observe and produce events for. :type watch: :class:`ObservedWatch` :param timeout: Timeout (in seconds) between successive attempts at reading events. :type timeout: ``float`` :param event_filter: Collection of event types to emit, or None for no filtering (default). :type event_filter: Optional[Iterable[:class:`watchdog.events.FileSystemEvent`]] Nct|||_||_||_|t ||_yd|_yr)superr _event_queue_watch_timeoutrr)r event_queuer,timeoutr __class__s rr zEventEmitter.__init__ss> '  8D8PY|4VZrc|jS)z$Blocking timeout for reading events.rIr"s rrKzEventEmitter.timeoutz}}rc|jS)z'The watch associated with this emitter.)rHr"s rr,zEventEmitter.watchs{{rc|jtfd|jDr(|jj|jfyy)zQueues a single event. :param event: Event to be queued. :type event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. Nc36K|]}t|ywr)r)r7clsevents rr9z+EventEmitter.queue_event..s,bZs-C,bs)ranyrGputr,)rrTs `r queue_eventzEventEmitter.queue_eventsG    %,btOaOa,b)b    ! !5$**"5 6*crcy)aOverride this method to populate the event queue with events per interval period. :param timeout: Timeout (in seconds) between successive attempts at reading events. :type timeout: ``float`` NrrrKs r queue_eventszEventEmitter.queue_eventsrc~|jr-|j|j|jr,yyr)should_keep_runningrZrKr"s rrunzEventEmitter.runs.&&(   dll +&&(r) r r r rDEFAULT_EMITTER_TIMEOUTr rBrKr,rWrZr^ __classcell__rLs@rrDrD]sN*4KY][ 7  ,rrDcheZdZdZeZ effd ZedZ dZ edZ dZ dZ xZS)EventDispatchera7Consumer thread base class subclassed by event observer threads that dispatch events from an event queue to appropriate event handlers. :param timeout: Timeout value (in seconds) passed to emitters constructions in the child class BaseObserver. :type timeout: ``float`` cNt|t|_||_yr)rFr r rGrI)rrKrLs rr zEventDispatcher.__init__s &L rc|jS)z)Timeout value to construct emitters with.rNr"s rrKzEventDispatcher.timeoutrOrctj|tjtj 5|j jtjdddy#1swYyxYwr) rstop contextlibsuppressqueueFullrJ put_nowaitrc stop_eventr"s rrgzEventDispatcher.stopsS   , D    ' '(B(B C D D Ds *A,,A5c|jS)zThe event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread. )rGr"s rrJzEventDispatcher.event_queues    rcy)agOverride this method to consume events from an event queue, blocking on the queue for the specified timeout before raising :class:`queue.Empty`. :param event_queue: Event queue to populate with one set of events. :type event_queue: :class:`EventQueue` :raises: :class:`queue.Empty` Nr)rrJs rdispatch_eventszEventDispatcher.dispatch_eventsr[rc|jr. |j|j|jr-yy#tj$rYTwxYwr)r]rprJrjEmptyr"s rr^zEventDispatcher.runsM&&( $$T%5%56&&(;;  sAAA)r r r robjectrmDEFAULT_OBSERVER_TIMEOUTr rBrKrgrJrpr^r`ras@rrcrcsTJC7 D !!  rrcceZdZdZeffd ZdZdZdZdZ dZ e dZ fd Z dd Zd Zd Zd ZdZdZdZxZS) BaseObserverzBase observer.ct||||_tj|_t |_i|_t |_ i|_ yr) rFr _emitter_class threadingRLock_lockset_watches _handlers _emitters_emitter_for_watch)r emitter_classrKrLs rr zBaseObserver.__init__sG !+__&  "$rcl||j|j<|jj|yr)rr,raddremitters r _add_emitterzBaseObserver._add_emitters(18 . 7#rc|j|j=|jj||j t j t5|jdddy#1swYyxYwr) rr,rremovergrhri RuntimeErrorr=rs r_remove_emitterzBaseObserver._remove_emitters[  # #GMM 2 g&    .  LLN   s A66A?cL|jD]}|j|jD]4}tjt5|j ddd6|jj |jj y#1swYuxYwr)rrgrhrirr=clearrrs r_clear_emitterszBaseObserver._clear_emitterss~~ G LLN ~~ G$$\2       %%'  s BB# c||jvrt|j|<|j|j|yr)r~r|rr event_handlerr,s r_add_handler_for_watchz#BaseObserver._add_handler_for_watchs5  &$'EDNN5 ! u!!-0rc|j|=yr)r~r+s r_remove_handlers_for_watchz'BaseObserver._remove_handlers_for_watchs NN5 !rc|jS)z/Returns event emitter created by this observer.)rr"s remitterszBaseObserver.emitterss~~rc|jjD]} |jt | y#t$r|j |wxYwr)rcopystart ExceptionrrF)rrrLs rrzBaseObserver.startsZ~~**, G      $$W- s AAc|j5t|||}|j|||jj |Z|j |j ||j|}|jr|j|j||jj|ddd|S#1swYSxYw)a9Schedules watching a path and calls appropriate methods specified in the given event handler in response to file system events. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param path: Directory path that will be monitored. :type path: ``str`` :param recursive: ``True`` if events will be emitted for sub-directories traversed recursively; ``False`` otherwise. :type recursive: ``bool`` :param event_filter: Collection of event types to emit, or None for no filtering (default). :type event_filter: Optional[Iterable[:class:`watchdog.events.FileSystemEvent`]] :return: An :class:`ObservedWatch` object instance representing a watch. N)rKr) r{rrrgetrxrJrKis_aliverrr}r)rrrrrr,rs rschedulezBaseObserver.schedules6ZZ %!$ <@E  ' ' u =&&**519--d.>.>t||jv-w==?MMO!!'* MM  e $ %  % s B0CCcj|j5|j||dddy#1swYyxYw)a!Adds a handler for the given watch. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param watch: The watch to add a handler for. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)r{rrs radd_handler_for_watchz"BaseObserver.add_handler_for_watch7s0ZZ >  ' ' u = > > >s)2c|j5|j|j|dddy#1swYyxYw)a'Removes a handler for the given watch. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param watch: The watch to remove a handler for. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)r{r~rrs rremove_handler_for_watchz%BaseObserver.remove_handler_for_watchIs7ZZ 8 NN5 ! ( ( 7 8 8 8s5>c|j5|j|}|j|=|j||jj |dddy#1swYyxYw)zUnschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)r{rr~rr}r)rr,rs r unschedulezBaseObserver.unschedule[s\ZZ (--e4Gu%   ) MM  '  ( ( (s A AA(c|j5|jj|j|jjdddy#1swYyxYw)zTUnschedules all watches and detaches all associated event handlers. N)r{r~rrr}r"s runschedule_allzBaseObserver.unschedule_alljsLZZ " NN "  " MM   ! " " "s AAA$c$|jyr)rr"s ron_thread_stopzBaseObserver.on_thread_stopss rcp|jd}|tjury|\}}|j5t |j j|gD]2}||j j|gvs"|j |4 ddd|jy#1swYxYw)NT)block)rrcrmr{listr~dispatch task_done)rrJentryrTr,handlers rrpzBaseObserver.dispatch_eventsvsd+ O.. .  u ZZ ,  2 25" => ,dnn00;;$$U+ ,  ,  , ,sAB,?B,,B5)FN)r r r rrtr rrrrrrBrrrrrrrrrpr`ras@rrvrvsd.F%$(1 "&P>$8$ ("  rrvceZdZdddZy)BaseObserverSubclassCallablecyrrrYs r__call__z%BaseObserverSubclassCallable.__call__r[rN).)rKfloatreturnrv)r r r rrrrrrsArr) __future__rrhrjrypathlibrwatchdog.utilsrrwatchdog.utils.bricksrr_rtr rrDrcrvrrrrrs{ # /2!2r2rl@,:@,F6j6rj ?j ZB8Br