o tf@sUddlmZddlZddlZddlZddlmZddlmZddl m Z gdZ e Z ded<Gd d d ZGd d d ZdS) ) annotationsN)deque)Iterator)Signal) FileContentsVirtualFileContents_VIRTUAL_FILESz5weakref.WeakValueDictionary[str, VirtualFileContents]rc@sLeZdZdZeeZddddZeddd Z e j dd d Z dd dZ dS)raStores text file contents in memory and emits a signal when it changes. Calling `str(obj)` on this object will always return the current contents. Parameters ---------- contents : str, optional The initial contents of the file (default: "") contentsstrcCs ||_dSN _contents)selfr ra/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/anywidget/_file_contents.py__init__s zVirtualFileContents.__init__returncC|jSr r rrrrr "szVirtualFileContents.contentsvalueNonecCs||_|j|dSr )rchangedemit)rrrrrr &scCrr )r rrrr__str__+szVirtualFileContents.__str__N)r )r r rr )rr rr) __name__ __module__ __qualname____doc__rr rrpropertyr setterrrrrrrs   rc@sReZdZdZeeZeZddddZdd d Z dd dZ dddZ dddZ dS)raObject that watches for file changes and emits a signal when it changes. Calling `str(obj)` on this object will always return the current contents of the file (as long as the thread is running). Parameters ---------- path : str | pathlib.Path The file to read and watch for content changes start_thread : bool, optional Whether to start watching for changes in a separate thread (default: `True`) Tpathstr | pathlib.Path start_threadboolcCsPt||_|jstdd|_t |_ d|_ |r&| dSdS)Nz!File does not exist: {self._path}) pathlibPath expanduserabsolute_pathis_file ValueErrorr threadingEvent _stop_event_background_threadwatch_in_thread)rr"r$rrrr@s   zFileContents.__init__rrcs>jdurdSjtjfdddd_jdS)zEWatch for file changes (and emitting signals) from a separate thread.NcstddS)Nr)maxlen)rwatchrrrrSsz.FileContents.watch_in_thread..T)targetdaemon)r0r/clearr-Threadstartrrrrr1Js   zFileContents.watch_in_threadcCs,|jdurdS|j|jd|_dS)z.Stops an actively running thread if it exists.N)r0r/setjoinrrrr stop_threadXs    zFileContents.stop_threadIterator[tuple[int, str]]c csz ddlm}m}Wnty}ztd|d}~ww||j|jdD]3}|D].\}}||jkr;|jdS||jksE||j krWd|_ |j t |||fVnq)q%dS)a Watch for file changes and emit changed/deleted signal events. Blocks indefinitely. Returns ------- changes : Iterator[tuple[int, str]] An iterator that yields any time the file changes until the file is deleted. r)Changer3zkwatchfiles is required to watch for file changes during development. Install with `pip install watchfiles`.N)Z stop_event) Z watchfilesr>r3 ImportErrorr*r/deletedrmodifiedaddedrrr )rr>r3excchangesZchanger"rrrr3`s0     zFileContents.watchr cCs |jdur |jjdd|_|jS)Nzutf-8)encoding)rr* read_textrrrrr~s zFileContents.__str__N)T)r"r#r$r%)rr)rr=r) rrrrrr rr@rr1r<r3rrrrrr/s    r) __future__rr&r-weakref collectionsrtypingrZpsygnalr__all__WeakValueDictionaryr__annotations__rrrrrrs