o h5@sddlmZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZe r:ddlmZmZd Zd ZGd d d eZGd d d ZGddde ZGddde ZGdddeZdS)) annotationsN) defaultdict)Path) TYPE_CHECKING) BaseThread)SkipRepeatsQueue)FileSystemEventFileSystemEventHandlerg?c@seZdZdZdS) 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__rrJ/var/www/vscode/kcb/lib/python3.10/site-packages/watchdog/observers/api.pyr sr c@seZdZdZddd#d d Zed$ddZed%ddZed&ddZed'ddZ d(ddZ d(ddZ d)dd Z d$d!d"Z dS)* 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 N) event_filterpath str | Path recursiveboolr"list[type[FileSystemEvent]] | NonecCs>t|tr t|n||_||_|durt||_dSd|_dSN) isinstancerstr_path _is_recursive frozenset _event_filter)selfrrrrrr__init__(s zObservedWatch.__init__returnrcC|jS)z"The path that this watch monitors.)rrrrrr-zObservedWatch.pathcCr")z;Determines whether subdirectories are watched for the path.)rr#rrr is_recursive2r$zObservedWatch.is_recursive'frozenset[type[FileSystemEvent]] | NonecCr")z.Collection of event types watched for the path)rr#rrrr7r$zObservedWatch.event_filter9tuple[str, bool, frozenset[type[FileSystemEvent]] | None]cCs|j|j|jfSr)rr%rr#rrrkey<szObservedWatch.keywatchobjectcCst|tstS|j|jkSrrrNotImplementedr(rr)rrr__eq__@  zObservedWatch.__eq__cCst|tstS|j|jkSrr+r-rrr__ne__Er/zObservedWatch.__ne__intcCs t|jSr)hashr(r#rrr__hash__Js zObservedWatch.__hash__cCsZ|jdurdtdd|jD}d|}nd}dt|jd|jd|j|d S) N|css|]}|jVqdSr)r ).0_clsrrr Osz)ObservedWatch.__repr__..z, event_filter=)rjoinsortedtyper rr%)revent_filter_strrrr__repr__Ms  &zObservedWatch.__repr__)rrrrrr)r!r)r!r)r!r&)r!r')r)r*r!r)r!r1)r r r rr propertyrr%rr(r.r0r3r?rrrrrs        rcsdeZdZdZedddfddZedddZedddZdddZ d ddZ d!ddZ Z 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: Iterable[:class:`watchdog.events.FileSystemEvent`] | None Ntimeoutr event_queuer r)rrCfloatrrr!Nonecs<t||_||_||_|durt||_dSd|_dSr)superr _event_queue_watch_timeoutrr)rrDr)rCr __class__rrr ms  zEventEmitter.__init__cCr")z$Blocking timeout for reading events.rJr#rrrrC{r$zEventEmitter.timeoutcCr")z'The watch associated with this emitter.)rIr#rrrr)r$zEventEmitter.watcheventrcs<|jdustfdd|jDr|j|jfdSdS)zQueues a single event. :param event: Event to be queued. :type event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. Nc3s|]}t|VqdSr)r)r5clsrNrrr7sz+EventEmitter.queue_event..)ranyrHputr))rrNrrPr queue_events" zEventEmitter.queue_eventcCdS)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`` NrrrCrrr queue_eventszEventEmitter.queue_eventscCs$|r||j|sdSdSr)should_keep_runningrVrCr#rrrruns zEventEmitter.run) rDr r)rrCrErrr!rFr!rE)r!r)rNrr!rFrCrEr!rFr!rF) r r r rDEFAULT_EMITTER_TIMEOUTr r@rCr)rSrVrY __classcell__rrrKrrAWs     rAcsjeZdZdZeZ eddfddZedd d Z dd d Z edddZ dddZ dddZ ZS)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`` rCrCrEr!rFcstt|_||_dSr)rGr r rHrJrUrKrrr s  zEventDispatcher.__init__cCr")z)Timeout value to construct emitters with.rMr#rrrrCr$zEventDispatcher.timeoutcCsJt|ttj|jtj WddS1swYdSr) rstop contextlibsuppressqueueFullrD put_nowaitr_ stop_eventr#rrrras "zEventDispatcher.stopr cCr")zThe event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread. )rHr#rrrrDszEventDispatcher.event_queuerDcCrT)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)rrDrrrdispatch_eventsrWzEventDispatcher.dispatch_eventscCs>|rz||jWn tjyYqw|sdSdSr)rXrhrDrdEmptyr#rrrrYszEventDispatcher.runr[rZr\)r!r rDr r!rF)r r r rr*rgDEFAULT_OBSERVER_TIMEOUTr r@rCrarDrhrYr^rrrKrr_s      r_cseZdZdZedd9fd d Zd:d dZd:ddZd;ddZdddZ d;fdd Z d d!d"d?d)d*Zds$       :J9