:vjyUddlmZddlZddlZddlZddlmZddlmZddl m Z erddl m Z gdZ ejZded <Gd d ZGd d Zy)) annotationsN)deque) TYPE_CHECKING)Signal)Iterator)_VIRTUAL_FILES FileContentsVirtualFileContentsz5weakref.WeakValueDictionary[str, VirtualFileContents]rcjeZdZdZeeZdddZed dZ e jd dZ d dZ y) r aStores 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: "") c||_yN _contents)selfcontentss i/workspace/moltex-experiments/.pixi/envs/default/lib/python3.12/site-packages/anywidget/_file_contents.py__init__zVirtualFileContents.__init__"s !c|jSr rrs rrzVirtualFileContents.contents%s ~~rcH||_|jj|yr )rchangedemit)rvalues rrzVirtualFileContents.contents)s % rc|jSr )rrs r__str__zVirtualFileContents.__str__.s }}rN))rstrreturnNonerr)rrrr ) __name__ __module__ __qualname____doc__rrrrpropertyrsetterrrrr r sHSkG"__!!rr cXeZdZdZeeZeZdd dZd dZ d dZ d dZ d dZ y) r aObject 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`) cLtj|jj|_|jj sd|j}t |d|_tj|_ d|_ |r|jyy)NzFile does not exist: ) pathlibPath expanduserabsolute_pathis_file ValueErrorr threadingEvent _stop_event_background_threadwatch_in_thread)rpath start_threadmsgs rrzFileContents.__init__Cs\\$'224==? zz!!#)$**6CS/ !%)$??,;?   " rcjyjjtjfdd_jj y)zEWatch for file changes (and emitting signals) from a separate thread.Nc:tjdS)Nr)maxlen)rwatchrsrz.FileContents.watch_in_thread..Ws5a8rT)targetdaemon)r5r4clearr2Threadstartrs`rr6zFileContents.watch_in_threadNsS  " " .   "+"2"29 #  %%'rc|jy|jj|jjd|_y)z.Stops an actively running thread if it exists.N)r5r4setjoinrs r stop_threadzFileContents.stop_thread\s=  " " *   $$&"&rc#K ddlm}m}||j|j D]}|D]\}}||j k(r7|jjs|j jy||j|jfvsgd|_ |jjt|||fy#t$r}d}t||d}~wwxYww)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)Changer=zkwatchfiles is required to watch for file changes during development. Install with `pip install watchfiles`.N) stop_event) watchfilesrIr= ImportErrorr/r4deletedexistsrmodifiedaddedrrr)rrIr=excr9changeschanger7s rr=zFileContents.watchds  0TZZD4D4DEG ' V^^+DJJ4E4E4GLL%%'foov||<<%)DNLL%%c$i0!4.(!(F 9    s.C,C B C,7C, C)C$$C))C,ct|j!|jjd|_|jS)Nzutf-8)encoding)rr/ read_textrs rrzFileContents.__str__s/ >> !!ZZ1171CDN~~rN)T)r7zstr | pathlib.Pathr8boolrr )rr )rzIterator[tuple[int, str]]r!) r"r#r$r%rrrrMrr6rGr=rr(rrr r 2s3 SkGhG # ('Brr ) __future__rr+r2weakref collectionsrtypingrpsygnalrcollections.abcr__all__WeakValueDictionaryr__annotations__r r r(rrrasX" ( C G!E :VVr