"dwdZddlmZmZddlZddlZddlmZddlm Z GddejZ Gdd e Z y) z8Contains the fallback implementation of the Watcher api.)absolute_importprint_functionN) snapshots)Watcherc^eZdZdZfdZedZedZedZdZ dZ xZ S) PollingThreadz.A thread that fires a callback at an interval.c(tt| d|_||_||_t j|_t j|_ t j|_ tj|jy)zInitialize the thread. :param callback: Callback function to repeat. :param interval: Number of seconds to sleep between calls. TN)superr__init__daemoncallbackinterval threadingEvent _shutdown_stopped_startedatexitregisterstop)selfr r __class__s 9/usr/lib/python3/dist-packages/qtsass/watchers/polling.pyr zPollingThread.__init__sa mT+-     "*!) !)  "c6|jjS)z Check if the thread has started.)ris_setrs rstartedzPollingThread.started-}}##%%rc6|jjS)z Check if the thread has stopped.)rrrs rstoppedzPollingThread.stopped2rrc6|jjS)z!Check if the thread has shutdown.)rrrs rshutdownzPollingThread.shutdown7s~~$$&&rc|js |jsy|jj|jj y)z?Set the shutdown event for this thread and wait for it to stop.N)rr#rsetrwaitrs rrzPollingThread.stop<s2||DMM   rc |jj |j|jj |j rn7 |j jy#|j jwxYw)zThreads main loop.N)rr%r rr&rrrs rrunzPollingThread.runDsi MM    >>&&t}}5 MM   DMM   s AA00B ) __name__ __module__ __qualname____doc__r propertyrr!r#rr( __classcell__)rs@rrrsQ8 #&&&&''  rrc.eZdZdZdZdZdZdZdZy)PollingWatcheraPolls a directory recursively for changes. Detects file and directory changes, deletions, and creations. Recursion depth is limited to 2 levels. We use a limit because the scss file we're watching for changes could be sitting in the root of a project rather than a dedicated scss directory. That could lead to snapshots taking too long to build and diff. It's probably safe to assume that users aren't nesting scss deeper than a couple of levels. cd|_tj|j|j|_t |j d|_y)zXSet up the PollingWatcher. A PollingThread is created but not started. )rN)_snapshot_depthrtake _watch_dir _snapshotrr(_threadrs rsetupzPollingWatcher.setup]s: !"9M9MN$TXX: rc8|jjy)zStart the PollingThread.N)r8startrs rr;zPollingWatcher.startfs rc8|jjy)zStop the PollingThread.N)r8rrs rrzPollingWatcher.stopjs rc8|jjy)z`Wait for the PollingThread to finish. You should always call stop before join. N)r8joinrs rr>zPollingWatcher.joinns rctj|j|j}tj|j |}|r||_|j yy)z{Take a new snapshot and call on_change when a change is detected. Called repeatedly by the PollingThread. N)rr5r6r4diffr7 on_change)r next_snapshotchangess rr(zPollingWatcher.runusK "t8L8LM ..? *DN NN  rN) r)r*r+r,r9r;rr>r(rrr0r0Rs ; rr0) r, __future__rrrrqtsass.watchersrqtsass.watchers.apirThreadrr0rDrrrIs>?7&' 4 I$$4 n,W,r