o tBh@sdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z GdddZdd d ZGdddeZd ddZd!ddZGdddZdS)"zBasic introspection of modules.) annotationsN)ProcessQueue) ModuleTypec@s$eZdZ      ddddZdS)ModulePropertiesNFnamestrfile str | Nonepathlist[str] | Noneall is_c_modulebool subpackagesreturnNonecCs,||_||_||_||_||_|pg|_dSNrr r rrr)selfrr r rrrri/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/mypy/moduleinspect.py__init__s  zModuleProperties.__init__)rNNNFN)rr r r r r rr rrrr rr)__name__ __module__ __qualname__rrrrrrsrmodulerrrcCs.|jddur dStj|jdddvS)N__file__T)z.soz.pyd)__dict__getosr splitext)rrrrr"src@s eZdZdS) InspectErrorN)rrrrrrrr$*sr$ package_idr c szt|Wnty}ztt||d}~wwtd|}tdd}tdd}t|ts4d}tdd}|durPzt|}Wn tyOd}Ynwt }|durj|rgfddt D}ng}nt j |jdd d d }d d|D}t||||||d S)zDUse runtime introspection to get information about a module/package.Nrr__path____all__cs<g|]\}}t|r|jjd|krjd|qS).)inspectismoduler).0rvalpackagerr Gs z*get_package_properties..r(cSsdSrr)rrrrQsz(get_package_properties..)prefixonerrorcSsg|]\}}}|qSrr)r+importerqualified_nameispkgrrrr/Ssr) importlib import_module BaseExceptionr$r getattr isinstancelist Exceptionrr) getmemberspkgutil walk_packagesrr) r%err r pkg_allis_cr all_packagesrr-rget_package_properties.s@         rEtasks Queue[str]resultsQueue[str | ModuleProperties]sys_path list[str]rc Cs\|t_ |}zt|}Wnty'}z |t|WYd}~qd}~ww||q)z0The main loop of a worker introspection process.TN)sysr r!rEr$putr )rFrHrJmodproprArrrworkerYs   rPc@sVeZdZdZdddZdddZddd Zdd dZdddZdddZ dddZ dS) ModuleInspecta9Perform runtime introspection of modules in a separate process. Reuse the process for multiple modules for efficiency. However, if there is an error, retry using a fresh process to avoid cross-contamination of state between modules. We use a separate process to isolate us from many side effects. For example, the import of a module may kill the current process, and we want to recover from that. Always use in a with statement for proper clean-up: with ModuleInspect() as m: p = m.get_package_properties('urllib.parse') rrcC |dSr)_startrrrrrv zModuleInspect.__init__cCs>t|_t|_tt|j|jtjfd|_|jd|_ dS)N)targetargsr) rrFrHrrPrLr procstartcounterrTrrrrSys   zModuleInspect._startcCs|jdS)zFree any resources used.N)rX terminaterTrrrcloseszModuleInspect.closer%r rcCsz|j||}|dur|td|t|tr4|jdkr0||| |St||jd7_|S)zReturn some properties of a module/package using runtime introspection. Raise InspectError if the target couldn't be imported. NzProcess died when importing r) rFrM_get_from_queuerSr$r;r rZr\rE)rr%resrrrrEs    z$ModuleInspect.get_package_propertiesModuleProperties | str | NonecCsZd}d} ||kr tdz|jjddWStjy'|js%YdSYnw|d7}q) z{Get value from the queue. Return the value read from the queue, or None if the process unexpectedly died. iXrTzTimeout waiting for subprocessg?)timeoutNr]) RuntimeErrorrHr!queueEmptyrXis_alive)rmax_iternrrrr^s zModuleInspect._get_from_queuecCs|SrrrTrrr __enter__szModuleInspect.__enter__rWobjectcGrRr)r\)rrWrrr__exit__rUzModuleInspect.__exit__N)rrr%r rr)rr`)rrQ)rWrirr) rrr__doc__rrSr\rEr^rhrjrrrrrQfs      rQ)rrrrrk)rFrGrHrIrJrKrr)rl __future__rr7r)r"r?rcrLmultiprocessingrrtypesrrrr=r$rErPrQrrrrs      +