o 沪g!@sUddlmZddlZddlZddlmZddlmZmZm Z m Z m Z ddl m Z mZddlmZddlmZddlmZmZerMdd lmZdd lmZeeZd ed <Gd dde ZdaGdddZdddZ dddZ!dS)) annotationsN)Path) TYPE_CHECKINGAnyCallableFinal NamedTuple)config file_util) get_logger)FolderBlackList)NoOpPathWatcherget_default_path_watcher_class) ModuleType) PagesManagerr_LOGGERc@seZdZUded<ded<dS) WatchedModulerwatcher module_nameN)__name__ __module__ __qualname____annotations__rrc/var/www/html/chatdoc2/venv/lib/python3.10/site-packages/streamlit/watcher/local_sources_watcher.pyr&s  rc@sveZdZd$ddZd%ddZd&d d Zd dZddZddZddZ ddZ ddZ ddZ d'ddZ d(d!d"Zd#S))LocalSourcesWatcher pages_managerrcCsf||_tj|jj|_tj|j|_g|_d|_ t |_ t t d|_i|_t |_|dS)NFzserver.folderWatchBlacklist)_pages_managerospathabspathmain_script_path_main_script_pathdirname_script_folder_on_file_changed _is_closedset_cached_sys_modulesr r get_option_folder_black_list_watched_modules_watched_pagesupdate_watched_pages)selfrrrr__init__1s zLocalSourcesWatcher.__init__returnNonecCs|j}t}|jD]}|dsq||d|d|jvr-|j|dddq|D]}||vrGtj |sG| ||j |q0|j ||_dS)N script_path)r)r,copyr'r get_pagesvaluesadd_register_watcherrrisfile_deregister_watcherremoveunion)r.old_page_pathsnew_pages_paths page_info old_page_pathrrrr-Cs(   z(LocalSourcesWatcher.update_watched_pagescbCallable[[str], None]cCs|j|dSN)r%append)r.r@rrrregister_file_change_callback\sz1LocalSourcesWatcher.register_file_change_callbackcCsb||jvr td|dS|jD]}|jdur$|jtjvr$tj|j=q|jD]}||q(dS)Nz'Received event for non-watched file: %s)r+rerrorr5rsysmodulesr%)r.filepathwmr@rrron_file_changed_s     z#LocalSourcesWatcher.on_file_changedcCs2|jD]}|jqi|_t|_d|_dS)NT)r+r5rcloser'r,r&)r.rIrrrrKws   zLocalSourcesWatcher.closecCsVtdurtattur dSz tt||j|d}Wn ty#YdSw||j|<dS)N)rr) PathWatcherrr rrJPermissionErrorr+)r.rHrrIrrrr7~s  z%LocalSourcesWatcher._register_watchercCs<||jvrdS||jkrdS|j|}|j|j|=dSrB)r+r"rrK)r.rHrIrrrr9s     z'LocalSourcesWatcher._deregister_watchercCs ||jvSrB)r+r.rHrrr _file_is_news z LocalSourcesWatcher._file_is_newcCs"||ot||jpt|SrB)rOr file_is_in_folder_globr$file_in_pythonpathrNrrr_file_should_be_watcheds z+LocalSourcesWatcher._file_should_be_watchedcsTjrdSttjjkr(fddttjD}ttj_|dSdS)Ncs i|] \}}|t|qSr)_exclude_blacklisted_pathsget_module_paths).0namemoduler.rr sz>LocalSourcesWatcher.update_watched_modules..)r&r'rFrGr(dictitems_register_necessary_watchers)r. modules_pathsrrXrupdate_watched_moduless   z*LocalSourcesWatcher.update_watched_modules module_pathsdict[str, set[str]]cCsB|D]\}}|D]}||r|tt||q qdSrB)r[rRr7strrresolve)r.r_rVpathsrrrrr\s z0LocalSourcesWatcher._register_necessary_watchersrcset[str]csfdd|DS)Ncsh|] }j|s|qSr)r*is_blacklistedrUprXrr szALocalSourcesWatcher._exclude_blacklisted_paths..r)r.rcrrXrrSsz.LocalSourcesWatcher._exclude_blacklisted_pathsN)rr)r0r1)r@rAr0r1)r_r`r0r1)rcrdr0rd)rrrr/r-rDrJrKr7r9rOrRr^r\rSrrrrr0s     rrWrr0rdc Csddddddg}t}|D]2}g}z||}Wnty#Ynty7tjd|jdddYnw|d d |Dq|S) NcSs|jgSrB)__file__mrrrsz"get_module_paths..cSs |jjgSrB)__spec__originrjrrrrls cSs t|jjSrB)list__path___pathrjrrrrls zExamining the path of z raised:T)exc_infocSs$g|]}t|rtjt|qSr)_is_valid_pathrrr rarfrrr s$z$get_module_paths..)r'AttributeError Exceptionrwarningrupdate)rWpaths_extractors all_paths extract_pathspotential_pathsrrrrTs(      rTr str | NoneboolcCs"t|totj|ptj|SrB) isinstancerarrr8isdir)rrrrrss"rs)rWrr0rd)rr}r0r~)" __future__rrrFpathlibrtypingrrrrr streamlitr r streamlit.loggerr #streamlit.watcher.folder_black_listr streamlit.watcher.path_watcherr rtypesrstreamlit.runtime.pages_managerrrrrrrLrrTrsrrrrs&      +